Как мы можем получить событие из концентратора событий Azure без имени контейнера хранилища, StorageAccountName и StorageAccountKey этой информации

Question

Я новичок в платформе Azure, у меня есть только EventHubConnectionString и EventHubName, и у меня нет имени контейнера хранения, StorageAccountName и ключа учетной записи хранения. Я хочу разработать одно приложение, которое получает события из концентратора событий, но я не понимаю, как мне поступить без этой информации. Пожалуйста, помогите с этой проблемой.

Я перехожу по этой ссылке для справки Azure Event Hub.

Answer 1

Вам придется использовать Пользовательский CheckpointManager для EventProcessorHost (EPH) , если вы не хотите использовать менеджер Azure Checkpoint по умолчанию.У Михаилшилкова есть образец реализации SQL checkpointmanager. Пример SQLcheckpointManager

Answer 2

Я не понимаю, как мне поступить без этой информации

Похоже, что для использования Event Hub вам необходимо что-то для управления контрольными точками. В большинстве примеров и документации показано использование хранилища Azure для хранения контрольных точек, которые автоматически создаются текущей базой кодов .Net Azure SDK. Текущая документация по EventProcessorHost , по-видимому, не отображает один из конструкторов, для которого не требуется учетная запись хранения, но пользовательский класс, который вы пишете, является производным от ICheckpointManager .

Конструктор, который не документирован (на данный момент) выглядит следующим образом:

    //
    // Summary:
    //     Create a new host to process events from an Event Hub.
    //     This overload of the constructor allows maximum flexibility. This one allows
    //     the caller to specify the name of the processor host as well. The overload also
    //     allows the caller to provide their own lease and checkpoint managers to replace
    //     the built-in ones based on Azure Storage.
    //
    // Parameters:
    //   hostName:
    //     Name of the processor host. MUST BE UNIQUE. Strongly recommend including a Guid
    //     to ensure uniqueness.
    //
    //   eventHubPath:
    //     The name of the EventHub.
    //
    //   consumerGroupName:
    //     The name of the consumer group within the Event Hub.
    //
    //   eventHubConnectionString:
    //     Connection string for the Event Hub to receive from.
    //
    //   checkpointManager:
    //     Object implementing ICheckpointManager which handles partition checkpointing.
    //
    //   leaseManager:
    //     Object implementing ILeaseManager which handles leases for partitions.
    public EventProcessorHost(string hostName, string eventHubPath, string consumerGroupName, string eventHubConnectionString, ICheckpointManager checkpointManager, ILeaseManager leaseManager);