npm 包 @microsoft.azure/eventing 使用教程-JavaScript中文网-JavaScript教程资源分享门户

在当今的云计算时代，事件驱动架构已成为应用程序开发的一种首选方式。为了在云计算时代建立可靠和可扩展的应用程序，Azure Event Grid 和 Azure Event Hubs 被引入作为事件中心来处理和分发事件。@microsoft.azure/eventing 是一个用于 Azure 事件流程处理的 npm 包，提供了封装和处理事件的方便性和可操作性，使得开发人员可以更高效地开发事件驱动微服务。

安装 @microsoft.azure/eventing

使用 npm 包管理程序进行安装，打开终端并输入以下命令：

npm install @microsoft.azure/eventing

如何使用 @microsoft.azure/eventing

创建订阅

创建订阅是为了处理特定事件类型的流。@microsoft.azure/eventing 允许您使用 eventProcessorHost 对象来创建订阅。eventProcessorHost 负责启动和停止事件流处理器宿主，并管理事件传输和流序列化过程。

const { EventProcessorHost } = require("@microsoft.azure/eventing");

const host = new EventProcessorHost({
  consumerGroup: "TestConsumerGroup",
  connectionString: "Endpoint=sb://<namespace>.servicebus.windows.net/;SharedAccessKeyName=<key-name>;SharedAccessKey=<key-value>",
  // eventHubPath is OPTIONAL - this is optional because it can also be specified in the 'storageConnectionString'.
  eventHubPath: "TestEventHub",
  storageConnectionString: "DefaultEndpointsProtocol=https;AccountName=<your-storage-account>;AccountKey=<your-storage-account-key>;EndpointSuffix=<your-storage-endpoint-suffix>",
  storageContainerName: "test-container",
});

host.start(eventhubProcessorCallback);

在本示例中，我们使用 EventProcessorHost 创建了一个新的事件流处理器宿主，并定义了以下参数：

consumerGroup - 消费组名称。
connectionString - Azure 服务总线连接字符串。
eventHubPath - Azure Event Hub 名称。
storageConnectionString - Azure 存储连接字符串。
storageContainerName - Azure 存储组件的容器名称。

处理事件

处理事件是 eventProcessor 的主要功能。eventProcessor 对象封装了 context，使得订阅的用户可以轻松地读取和处理输入事件。此外，eventProcessor 还负责事件的处理和确认，以确保您的订阅可以无缝地处理大量的流和事件。

以下是使用 eventProcessor 处理事件的示例：

const { EventProcessor, delay } = require("@microsoft.azure/eventing");

class TestEventProcessor extends EventProcessor {
  async processEvents(context, events) {
    for (const event of events) {
      console.log(`Event (${event.body}),  Foo (${event.headers.foo}),  Bar (${event.headers.bar})`);
    }
    await delay(1000);
    context.checkpoint();
  }
}

async function eventhubProcessorCallback(context, messages) {
  const eventProcessor = new TestEventProcessor();
  eventProcessor.processMessages(context, messages);
}

host.start(eventhubProcessorCallback);

在本示例中，我们定义了一个 TestEventProcessor 类，并使用 eventProcessor.processMessages() 方法处理传入的事件流。processMessages() 方法通过 context.checkpoint() 函数来确认处理成功，确保事件在处理之后不再重新发送。

结论

@microsoft.azure/eventing 是 Azure 事件中心处理的一个方便和易于使用的 npm 包。通过本文提供的教程和示例代码，开发人员可以更快速和高效地开发和运行事件驱动型应用程序。如果您是一个微服务开发人员或者是云计算架构设计师，@microsoft.azure/eventing 将是您不可错过的工具之一。

来源：JavaScript中文网，转载请注明来源本文地址：https://www.javascriptcn.com/post/600673e0fb81d47349e53cd5