使用 RabbitMQ 集成,可以将采集到的数据及时地通过 RabbitMQ 发送出去,用户可以通过消息队列来获取采集的数据。
下面介绍如何使用 RabbitMQ 集成。
1、配置采集器的集成,集成选择集蜂云。
2、选择 RabbitMQ 集成,点击连接。
3、配置触发时机,触发时间可以选择运行成功、运行失败、运行超时等情况,当运行达到选择的触发时机是,会启动 RabbitMQ 集成。
4、配置 RabbitMQ 参数,配置连接信息、交换机名称、交换机类型等设置,确保能够正确连接。内存配置可以设置为 512MB 。点击最下面的创建,就会保存配置。
5、运行采集器,可以测试是否正确发送数据。可以在运行查看是否运行成功。
或者查看集成运行记录:
RabbitMQ 集成会读取运行的数据集,按照数据集的保存先后顺序,原封不动地将数据(JSON)格式发送出去。
同时,消息设置了 Headers,Headers 包含 runId、datasetId、kvStoreId、requestQueueId 等参数信息,方便用户使用。
发送的消息需要得到 Confirm ,才认为发送成功。
dConfirmation, err := ch.PublishWithDeferredConfirm(
exchange,
routingKey,
true,
false,
amqp.Publishing{
Headers: amqp.Table{
"runId": payload.RunId,
"datasetId": payload.DatasetId,
"kvStoreId": payload.KvStoreId,
"requestQueueId": payload.RequestQueueId,
},
ContentType: "text/plain",
ContentEncoding: "utf-8",
DeliveryMode: amqp.Persistent,
Priority: 0,
AppId: appId,
Body: body,
},
)