Невозможно установить контрольную точку в разделе

Question

Я пытаюсь использовать этот образец (https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-node-get-started-send), но я не могу читать только непрочитанные данные. Еще одна вещь, которую я получаю две разные ошибки

1) подключиться ETIMEDOUT 40.112.242.0: 5671

2) аренда потеряна при обновлении контрольной точки

В примере узла js я не могу установить контрольные точки. Я также попробовал Azure / azure-sdk-for-js. Но он показывает ту же ошибку, перечисленную выше.

Когда я также запускаю .netcore sample, они работают нормально, поэтому я не понимаю, почему узел js sample не работает нормально?

Можетпожалуйста, сообщите мне, как можно решить эту проблему с непрочитанными и новыми данными только для чтения?

Answer 1

Для node.js используйте код ниже, чтобы установить контрольную точку, она хорошо работает на моей стороне:

const { EventProcessorHost, delay } = require("@azure/event-processor-host");

//your eventhub name
const path = "myeventhub"; 

//your azure storage connection string
const storageCS = "DefaultEndpointsProtocol=https;AccountName=xx;AccountKey=xx;EndpointSuffix=core.windows.net";

//your eventhub namespace connectionstring 
const ehCS = "Endpoint=sb://xxx.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=xxx"

//your blob storage container name
const storageContainerName = "test6";

async function main() {
  // Create the Event Processo Host
  const eph = EventProcessorHost.createFromConnectionString(
    EventProcessorHost.createHostName("my-host"),
    storageCS,
    storageContainerName,
    ehCS,
    {
      eventHubPath: path
    }

  );
  let count = 0;
  // Message event handler
  const onMessage = async (context/*PartitionContext*/, data /*EventData*/) => {
    console.log(">>>>> Rx message from '%s': '%s'", context.partitionId, data.body);
    count++;

    return await context.checkpoint();
  };
  // Error event handler
  const onError = (error) => {
    console.log(">>>>> Received Error: %O", error);
  };
  // start the EPH
  await eph.start(onMessage, onError);
  // After some time let' say 2 minutes
  await delay(120000);
  // This will stop the EPH.
  await eph.stop();
}

main().catch((err) => {
  console.log(err);
});

И я вижу, что контрольная точка установлена ​​правильно в контейнере BLOB-объектов: