如何使用RabbitMQ集成

使用 RabbitMQ 集成，可以将采集到的数据及时地通过 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,
    },
)