Azure Event Hub 5.6.0 - 如何将事件发送到特定分区 ID Nodejs？

Question

我在 nodejs 中使用 azure/event-hubs 1.0.8 版本将数据发送到特定的分区 ID。下面是示例代码

有人可以帮助我如何使用 nodejs 中的 azure/event-hubs 5.6.0 版本将数据发送到事件到特定分区 ID？我研究了很多但找不到任何来源。如有任何帮助，我们将不胜感激！

下面是 EventHub 5.6.0 的代码

 const insertOneInPartition = (data, partition, eventsHub) => {
  const dataToInsert = { body: { ...data } };
  return new Promise((resolve, reject) => {
    eventsHub.createBatch({ partitionId : partition }).then(async eventDataBatch => {
      if (data) {
        eventDataBatch.tryAdd(dataToInsert);
        await eventsHub.sendBatch(eventDataBatch);
        resolve(eventsHub);
      } else {
        // eslint-disable-next-line prefer-promise-reject-errors
        reject('error');
      }
    }).catch(error => {
      reject(error);
    });
  });
};

Answer 1

对于 nodejs 客户端，请参阅 createBatch()，它采用可以包含 partitionId 或分区键的选项参数，请参阅 github 处的 sendEvents 示例代码，请参阅第 41 行. 您可以使用此浏览器应用程序将测试消息发送到您的特定分区。

对于Javascript 客户，您应该在创建批处理时传递partition ID。使用分区 ID 构建 batchOptions 并将其发送到 create_batch(batchOptions)，请参阅第 35 行以在 https://github.com/Azure/azure-sdk-for-js/blob/master/sdk/eventhub/event-hubs/samples/v5/javascript/sendEvents.js

的代码示例中设置 partitionId

Azure Event Hub 5.6.0 - 如何将事件发送到特定分区 ID Nodejs？

Azure Event Hub 5.6.0 - How to send an event to a specific partition id Nodejs?

javascript

node.js

azure

azure-eventhub