大数据学习

扇出模式 producer不需要指定队列，只需要指定exchange consumer才需要指定队列和交换机，consumer的队列 一般会用默认队列 连接 交换机 channel.exchange_declare(exchange='logs',exchange_type='fanout') result = channel.queue_declare(queue='',exclusive=True) consumer # coding=utf-8 ### 消费者 import pika user_info = pika.

direct模式 producer 只需要往 direct交换机中发消费，producer 向routing key中发消息 routing key 和 队列是 多对一 关系，一个队列可以有多个routing key consumer 只从队列如“direct_queue1”中取数据， 新建maven项目mqtest pom中导入rabbitmq相关依赖 <dependencies> <dependency> <groupId>com.rabbitmq</groupId>

topic模式 producer只需要向topic交换机里发送信息，producer需往routing-key中发信息 routing-key与queue可以是多对一 producer # coding=utf-8 ### 生产线者 import json import pika import sys import datetime import time credentials = pika.PlainCredentials('admin', '123') # mq用户名和密码

RPC调用 Rpc是异步调用，client发送请求，同时告诉server处理完后要发送消息给：回调队列的ID：correlation_id=abc，并调用replay_to回调队列对应的回调函数。 不要对消息进行确认，反复确认会导致进入死循环 client import json import pika import uuid class RpcClient(): ​ def init(self): ​ self.credentials = pika.PlainCredentials('g

安装JDK 下面有三种安装 JDK 的方式，可以任选一种。推荐直接使用第 1 种安装方式。 第 1 种安装 JDK 方式（手动安装，推荐采用本方式） 需要按照下面步骤来自己手动安装 JDK1.8。 我们已经把 JDK1.8 的安装包 jdk-8u162-linux-x64.tar.gz 放在了百度云盘，可以点击这里到百度云盘下载 JDK1.8 安装包（提取码：99bg）。请把压缩格式的文件 jdk-8u162-linux-x64.tar.gz 下载到本地电脑，假设保存在“/home/linziyu/Downloads/”目录下。 在 Linux 命令行界面中，执行如下 She

一、建立HelloWorld工程 # 创建工程文件夹helloworldnbu@ecs:~$ mkdir helloworld# 创建项目package org.nbubigdata.testnbu@ecs:~$ mkdir -p helloworld/src/org/nbubigdata/test# 创建输出文件夹classes 用于保存编译后的class文件及jar包nbu@ecs:~$ mkdir -p helloworld/classes# 新建java文件HelloWorld.javanbu@ecs:~$ cd helloworld/src/org/nbubigdata/te

MAVEN 项目构建是指将源代码、依赖库和资源文件等转换成可执行或可部署的应用程序的过程，在这个过程中包括编译源代码、链接依赖库、打包和部署等多个步骤。 项目构建是软件开发过程中至关重要的一部分，它能够大大提高软件开发效率，使得开发人员能够更加专注于应用程序的开发和维护，而不必关心应用程序的构建细节。 同时，项目构建还能够将多个开发人员的代码汇合到一起，并能够自动化项目的构建和部署，大大降低了项目的出错风险和提高开发效率。常见的构建工具包括Maven、Gradle、Ant等。 1.环境准备 软件名 软件版本 JDK版本 jdk8 Mave

MAVEN 安装openjdk或者oracle 如果已经安装，可以跳过 sudo apt install openjdk-8-jdk查看是否安装成功java -version 查看java版本javac -version 查看javac版本 安装maven 进入maven官网,之后进行下载 按个人习惯安装解压到对应目录 tar zxvf apache-maven-3.3.9.bin.tar.gz 在/etc/profile下添加环境变量 建立Maven的HOME目录变量： export M2_HOME=/解压路

1、Maven项目创建 在~/bigdata下创建空文件夹mongodb后作为我们的项目目录(或其他指定文件夹),切换到项目目录： cd ~/bigdatamkdir mongodbcd mongodb 在该目录下使用maven命令创建一个示例项目: nbu@ecs:~/bigdata/mongodb$ mvn archetype:generate -DgroupId=org.nbubigdata.mongodb -DartifactId=mongodb_java -DarchetypeArtifactId=maven-archetype-quickstart -D

连续查询 介绍 连续查询(Continuous Queries下文统一简称CQ)是InfluxQL对实时数据自动周期运行的查询，然后把查询结果写入到指定的measurement中。 语法 基本语法 CREATE CONTINUOUS QUERY <cq_name> ON <database_name>BEGIN <cq_query>END 语法描述 cq_query cq_query需要一个函数，一个INTO子句和一个GROUP BY time()子句： SELECT <f