logo
icon

集蜂云

文档中心
价格
解决方案
资源中心
moneyLogo推广返现

如何使用RabbitMQ集成

集蜂云 / 2024-05-29 20:08
本文介绍了如何使用 RabbitMQ 集成,将采集的数据及时发送给用户。

使用 RabbitMQ 集成,可以将采集到的数据及时地通过 RabbitMQ 发送出去,用户可以通过消息队列来获取采集的数据。

下面介绍如何使用 RabbitMQ 集成。

选择 RabbitMQ 集成

1、配置采集器的集成,集成选择集蜂云选择集蜂云集成

2、选择 RabbitMQ 集成,点击连接选择 RabbitMQ 集成

3、配置触发时机,触发时间可以选择运行成功、运行失败、运行超时等情况,当运行达到选择的触发时机是,会启动 RabbitMQ 集成。

选择触发时机

4、配置 RabbitMQ 参数,配置连接信息、交换机名称、交换机类型等设置,确保能够正确连接。内存配置可以设置为 512MB 。点击最下面的创建,就会保存配置。

RabbitMQ配置参数

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,
    },
)

导航目录