node.js - 如何知道客户端已连接Eventhub

Question

不知道如何判断客户端是否已连接。如果 EVENTHUB_CONNECTION_STRING 完全错误，则会引发异常。但万一 key 错了怎么办？如果不会抛出异常。如何判断客户端连接成功。

我的代码如下。

var EventHubClient = require('azure-event-hubs').EventHubClient; 

const connectionString = "EVENTHUB_CONNECTION_STRING";
const entityPath = "EVENTHUB_NAME";
const connStr = process.env[connectionString] || "";
const path = process.env[entityPath] || "";

var client = EventHubClient.createFromConnectionString(connStr, path);

 const eventData = {
            body: {
                test1: aaa,
                test2: bbb
            }
        };
await client.send(eventData);

Answer 1

createFromConnectionString(connStr, path) 返回一个 Promise，您应该等待它或在它解决连接或错误时注册一个回调。此外，为了发送数据，您还需要一个分区 ID，可以使用 eventHubClient.getPartitionIds()

检索该分区 ID

var EventHubClient = require('azure-event-hubs').EventHubClient; 

const connectionString = "EVENTHUB_CONNECTION_STRING"; 
const entityPath = "EVENTHUB_NAME"; 
const connStr = process.env[connectionString] || ""; 
const path = process.env[entityPath] || "";

  var client;
  EventHubClient.createFromConnectionString(connStr, path).then((connection) => {
    client = connection;
    ( async function () {
      const pids = client.getPartitionIds();
      const eventData = {
        body: {
          test1: aaa,
          test2: bbb
        }
      };
      pids.forEach((id) => {
        client.send(eventData, id).then((success) => {
          console.log(success);
        }, (error) => {
          console.log(error);

        });

      });
    }())
  }, (connectionError) => {
    console.log(connectionError);
  });