EventHubConsumerClient class
A classe EventHubConsumerClient é usada para consumir eventos de um Hub de Eventos.
Há várias maneiras de criar um EventHubConsumerClient
- Use a cadeia de conexão da política SAS criada para sua instância do Hub de Eventos.
- Use a cadeia de conexão da política SAS criada para o namespace do Hub de Eventos e o nome da instância do Hub de Eventos
- Use o namespace completo como
<yournamespace>.servicebus.windows.nete um objeto de credenciais.
Opcionalmente, você também pode passar:
- Um pacote de opções para definir a política de repetição ou as configurações de proxy.
- Um armazenamento de ponto de verificação que é usado pelo cliente para ler pontos de verificação para determinar a posição de onde ele deve continuar recebendo eventos quando seu aplicativo for reiniciado. O armazenamento de ponto de verificação também é usado pelo cliente para balancear a carga de várias instâncias do seu aplicativo.
Construtores
| Event |
A classe |
| Event |
A classe |
| Event |
A classe |
| Event |
A classe |
| Event |
A classe |
| Event |
A classe |
Propriedades
| default |
O nome do grupo de consumidores padrão no serviço Hubs de Eventos. |
| event |
O nome da instância do Hub de Eventos para a qual esse cliente foi criado. |
| fully |
O namespace totalmente qualificado da instância do Hub de Eventos para a qual esse cliente é criado. É provável que isso seja semelhante ao <seunamespace.servicebus.windows.net>. |
| identifier | O nome usado para identificar esse EventHubConsumerClient. Se não for especificado ou vazio, um único aleatório será gerado. |
Métodos
| close() | Fecha a conexão AMQP com a instância do Hub de Eventos, retornando uma promessa que será resolvida quando a desconexão for concluída. |
| get |
Fornece as informações de tempo de execução do Hub de Eventos. |
| get |
Fornece a id para cada partição associada ao Hub de Eventos. |
| get |
Fornece informações sobre o estado da partição especificada. |
| subscribe(string, Subscription |
Subscrever eventos a partir de uma única partição. Chame close() no objeto retornado para parar de receber eventos. Exemplo de uso: |
| subscribe(Subscription |
Subscreva eventos de todas as partições. Se o armazenamento de ponto de verificação for fornecido ao Chame close() no objeto retornado para parar de receber eventos. Exemplo de uso: |
Detalhes do Construtor
EventHubConsumerClient(string, string, CheckpointStore, EventHubConsumerClientOptions)
A classe EventHubConsumerClient é usada para consumir eventos de um Hub de Eventos.
Use o parmeter options para definir a política de repetição ou as configurações de proxy.
new EventHubConsumerClient(consumerGroup: string, connectionString: string, checkpointStore: CheckpointStore, options?: EventHubConsumerClientOptions)Parâmetros
- consumerGroup
-
string
O nome do grupo de consumidores do qual você deseja processar eventos.
- connectionString
-
string
A cadeia de conexão a ser usada para se conectar à instância do Hub de Eventos. Espera-se que as propriedades de chave compartilhada e o caminho do Hub de Eventos estejam contidos nessa cadeia de conexão. por exemplo, 'Endpoint=sb://my-servicebus-namespace.servicebus.windows.net/; SharedAccessKeyName=my-SA-name; SharedAccessKey=my-SA-key; EntityPath=my-event-hub-name'.
- checkpointStore
- CheckpointStore
Um armazenamento de ponto de verificação que é usado pelo cliente para ler pontos de verificação para determinar a posição de onde ele deve continuar recebendo eventos quando seu aplicativo for reiniciado. Ele também é usado pelo cliente para balancear a carga de várias instâncias do seu aplicativo.
- options
- EventHubConsumerClientOptions
Um conjunto de opções a serem aplicadas ao configurar o cliente.
-
retryOptions: Configura a política de repetição para todas as operações no cliente. Por exemplo,{ "maxRetries": 4 }ou{ "maxRetries": 4, "retryDelayInMs": 30000 }. -
webSocketOptions: Configura a canalização da conexão AMQP através de Web Sockets. -
userAgent: Uma cadeia de caracteres para acrescentar à cadeia de caracteres do agente do usuário interna que é passada para o serviço.
EventHubConsumerClient(string, string, EventHubConsumerClientOptions)
A classe EventHubConsumerClient é usada para consumir eventos de um Hub de Eventos.
Use o parmeter options para definir a política de repetição ou as configurações de proxy.
new EventHubConsumerClient(consumerGroup: string, connectionString: string, options?: EventHubConsumerClientOptions)Parâmetros
- consumerGroup
-
string
O nome do grupo de consumidores do qual você deseja processar eventos.
- connectionString
-
string
A cadeia de conexão a ser usada para se conectar à instância do Hub de Eventos. Espera-se que as propriedades de chave compartilhada e o caminho do Hub de Eventos estejam contidos nessa cadeia de conexão. por exemplo, 'Endpoint=sb://my-servicebus-namespace.servicebus.windows.net/; SharedAccessKeyName=my-SA-name; SharedAccessKey=my-SA-key; EntityPath=my-event-hub-name'.
- options
- EventHubConsumerClientOptions
Um conjunto de opções a serem aplicadas ao configurar o cliente.
-
retryOptions: Configura a política de repetição para todas as operações no cliente. Por exemplo,{ "maxRetries": 4 }ou{ "maxRetries": 4, "retryDelayInMs": 30000 }. -
webSocketOptions: Configura a canalização da conexão AMQP através de Web Sockets. -
userAgent: Uma cadeia de caracteres para acrescentar à cadeia de caracteres do agente do usuário interna que é passada para o serviço.
EventHubConsumerClient(string, string, string, CheckpointStore, EventHubConsumerClientOptions)
A classe EventHubConsumerClient é usada para consumir eventos de um Hub de Eventos.
Use o parmeter options para definir a política de repetição ou as configurações de proxy.
new EventHubConsumerClient(consumerGroup: string, connectionString: string, eventHubName: string, checkpointStore: CheckpointStore, options?: EventHubConsumerClientOptions)Parâmetros
- consumerGroup
-
string
O nome do grupo de consumidores do qual você deseja processar eventos.
- connectionString
-
string
A cadeia de conexão a ser usada para se conectar ao namespace Hubs de Eventos. Espera-se que as propriedades de chave compartilhada estejam contidas nessa cadeia de conexão, mas não no caminho do Hub de Eventos, por exemplo, 'Endpoint=sb://my-servicebus-namespace.servicebus.windows.net/; SharedAccessKeyName=my-SA-name; SharedAccessKey=my-SA-key;'.
- eventHubName
-
string
O nome do Hub de Eventos específico ao qual conectar o cliente.
- checkpointStore
- CheckpointStore
Um armazenamento de ponto de verificação que é usado pelo cliente para ler pontos de verificação para determinar a posição de onde ele deve continuar recebendo eventos quando seu aplicativo for reiniciado. Ele também é usado pelo cliente para balancear a carga de várias instâncias do seu aplicativo.
- options
- EventHubConsumerClientOptions
Um conjunto de opções a serem aplicadas ao configurar o cliente.
-
retryOptions: Configura a política de repetição para todas as operações no cliente. Por exemplo,{ "maxRetries": 4 }ou{ "maxRetries": 4, "retryDelayInMs": 30000 }. -
webSocketOptions: Configura a canalização da conexão AMQP através de Web Sockets. -
userAgent: Uma cadeia de caracteres para acrescentar à cadeia de caracteres do agente do usuário interna que é passada para o serviço.
EventHubConsumerClient(string, string, string, EventHubConsumerClientOptions)
A classe EventHubConsumerClient é usada para consumir eventos de um Hub de Eventos.
Use o parmeter options para definir a política de repetição ou as configurações de proxy.
new EventHubConsumerClient(consumerGroup: string, connectionString: string, eventHubName: string, options?: EventHubConsumerClientOptions)Parâmetros
- consumerGroup
-
string
O nome do grupo de consumidores do qual você deseja processar eventos.
- connectionString
-
string
A cadeia de conexão a ser usada para se conectar ao namespace Hubs de Eventos. Espera-se que as propriedades de chave compartilhada estejam contidas nessa cadeia de conexão, mas não no caminho do Hub de Eventos, por exemplo, 'Endpoint=sb://my-servicebus-namespace.servicebus.windows.net/; SharedAccessKeyName=my-SA-name; SharedAccessKey=my-SA-key;'.
- eventHubName
-
string
O nome do Hub de Eventos específico ao qual conectar o cliente.
- options
- EventHubConsumerClientOptions
Um conjunto de opções a serem aplicadas ao configurar o cliente.
-
retryOptions: Configura a política de repetição para todas as operações no cliente. Por exemplo,{ "maxRetries": 4 }ou{ "maxRetries": 4, "retryDelayInMs": 30000 }. -
webSocketOptions: Configura a canalização da conexão AMQP através de Web Sockets. -
userAgent: Uma cadeia de caracteres para acrescentar à cadeia de caracteres do agente do usuário interna que é passada para o serviço.
EventHubConsumerClient(string, string, string, TokenCredential | NamedKeyCredential | SASCredential, CheckpointStore, EventHubConsumerClientOptions)
A classe EventHubConsumerClient é usada para consumir eventos de um Hub de Eventos.
Use o parmeter options para definir a política de repetição ou as configurações de proxy.
new EventHubConsumerClient(consumerGroup: string, fullyQualifiedNamespace: string, eventHubName: string, credential: TokenCredential | NamedKeyCredential | SASCredential, checkpointStore: CheckpointStore, options?: EventHubConsumerClientOptions)Parâmetros
- consumerGroup
-
string
O nome do grupo de consumidores do qual você deseja processar eventos.
- fullyQualifiedNamespace
-
string
O namespace completo que provavelmente será semelhante ao <seunamespace.servicebus.windows.net>
- eventHubName
-
string
O nome do Hub de Eventos específico ao qual conectar o cliente.
- credential
Um objeto de credencial usado pelo cliente para obter o token para autenticar a conexão com o serviço Hubs de Eventos do Azure.
Consulte @azure/identity para criar credenciais que suportam AAD auth. Use o AzureNamedKeyCredential de @azure/core-auth se quiser passar um SharedAccessKeyName e SharedAccessKey sem usar uma cadeia de conexão. Esses campos são mapeados para o campo name e key, respectivamente, em AzureNamedKeyCredential.
Use o AzureSASCredential de @azure/core-auth se quiser passar um SharedAccessSignature sem usar uma cadeia de conexão. Este campo é mapeado para signature em AzureSASCredential.
- checkpointStore
- CheckpointStore
Um armazenamento de ponto de verificação que é usado pelo cliente para ler pontos de verificação para determinar a posição de onde ele deve continuar recebendo eventos quando seu aplicativo for reiniciado. Ele também é usado pelo cliente para balancear a carga de várias instâncias do seu aplicativo.
- options
- EventHubConsumerClientOptions
Um conjunto de opções a serem aplicadas ao configurar o cliente.
-
retryOptions: Configura a política de repetição para todas as operações no cliente. Por exemplo,{ "maxRetries": 4 }ou{ "maxRetries": 4, "retryDelayInMs": 30000 }. -
webSocketOptions: Configura a canalização da conexão AMQP através de Web Sockets. -
userAgent: Uma cadeia de caracteres para acrescentar à cadeia de caracteres do agente do usuário interna que é passada para o serviço.
EventHubConsumerClient(string, string, string, TokenCredential | NamedKeyCredential | SASCredential, EventHubConsumerClientOptions)
A classe EventHubConsumerClient é usada para consumir eventos de um Hub de Eventos.
Use o parmeter options para definir a política de repetição ou as configurações de proxy.
new EventHubConsumerClient(consumerGroup: string, fullyQualifiedNamespace: string, eventHubName: string, credential: TokenCredential | NamedKeyCredential | SASCredential, options?: EventHubConsumerClientOptions)Parâmetros
- consumerGroup
-
string
O nome do grupo de consumidores do qual você deseja processar eventos.
- fullyQualifiedNamespace
-
string
O namespace completo que provavelmente será semelhante ao <seunamespace.servicebus.windows.net>
- eventHubName
-
string
O nome do Hub de Eventos específico ao qual conectar o cliente.
- credential
Um objeto de credencial usado pelo cliente para obter o token para autenticar a conexão com o serviço Hubs de Eventos do Azure.
Consulte @azure/identity para criar credenciais que suportam AAD auth. Use o AzureNamedKeyCredential de @azure/core-auth se quiser passar um SharedAccessKeyName e SharedAccessKey sem usar uma cadeia de conexão. Esses campos são mapeados para o campo name e key, respectivamente, em AzureNamedKeyCredential.
Use o AzureSASCredential de @azure/core-auth se quiser passar um SharedAccessSignature sem usar uma cadeia de conexão. Este campo é mapeado para signature em AzureSASCredential.
- options
- EventHubConsumerClientOptions
Um conjunto de opções a serem aplicadas ao configurar o cliente.
-
retryOptions: Configura a política de repetição para todas as operações no cliente. Por exemplo,{ "maxRetries": 4 }ou{ "maxRetries": 4, "retryDelayInMs": 30000 }. -
webSocketOptions: Configura a canalização da conexão AMQP através de Web Sockets. -
userAgent: Uma cadeia de caracteres para acrescentar à cadeia de caracteres do agente do usuário interna que é passada para o serviço.
Detalhes de Propriedade
defaultConsumerGroupName
O nome do grupo de consumidores padrão no serviço Hubs de Eventos.
static defaultConsumerGroupName: stringValor de Propriedade
string
eventHubName
O nome da instância do Hub de Eventos para a qual esse cliente foi criado.
string eventHubNameValor de Propriedade
string
fullyQualifiedNamespace
O namespace totalmente qualificado da instância do Hub de Eventos para a qual esse cliente é criado. É provável que isso seja semelhante ao <seunamespace.servicebus.windows.net>.
string fullyQualifiedNamespaceValor de Propriedade
string
identifier
O nome usado para identificar esse EventHubConsumerClient. Se não for especificado ou vazio, um único aleatório será gerado.
identifier: stringValor de Propriedade
string
Detalhes de Método
close()
Fecha a conexão AMQP com a instância do Hub de Eventos, retornando uma promessa que será resolvida quando a desconexão for concluída.
function close(): Promise<void>Devoluções
Promise<void>
Promessa<anulada>
getEventHubProperties(GetEventHubPropertiesOptions)
Fornece as informações de tempo de execução do Hub de Eventos.
function getEventHubProperties(options?: GetEventHubPropertiesOptions): Promise<EventHubProperties>Parâmetros
- options
- GetEventHubPropertiesOptions
O conjunto de opções a serem aplicadas à chamada de operação.
Devoluções
Promise<EventHubProperties>
Uma promessa que é resolvida com informações sobre a instância do Hub de Eventos.
getPartitionIds(GetPartitionIdsOptions)
Fornece a id para cada partição associada ao Hub de Eventos.
function getPartitionIds(options?: GetPartitionIdsOptions): Promise<string[]>Parâmetros
- options
- GetPartitionIdsOptions
O conjunto de opções a serem aplicadas à chamada de operação.
Devoluções
Promise<string[]>
Uma promessa que é resolvida com uma matriz de cadeias de caracteres que representam a id de cada partição associada ao Hub de Eventos.
getPartitionProperties(string, GetPartitionPropertiesOptions)
Fornece informações sobre o estado da partição especificada.
function getPartitionProperties(partitionId: string, options?: GetPartitionPropertiesOptions): Promise<PartitionProperties>Parâmetros
- partitionId
-
string
O id da partição para a qual as informações são necessárias.
- options
- GetPartitionPropertiesOptions
O conjunto de opções a serem aplicadas à chamada de operação.
Devoluções
Promise<PartitionProperties>
Uma promessa que se resolve com informações sobre o estado da partição.
subscribe(string, SubscriptionEventHandlers, SubscribeOptions)
Subscrever eventos a partir de uma única partição. Chame close() no objeto retornado para parar de receber eventos.
Exemplo de uso:
import { EventHubConsumerClient, earliestEventPosition } from "@azure/event-hubs";
const client = new EventHubConsumerClient("my-consumer-group", "connectionString", "eventHubName");
const partitionIds = await client.getPartitionIds();
const subscription = client.subscribe(
partitionIds[0],
{
processEvents: async (events, context) => {
console.log("Received event count: ", events.length);
},
processError: async (err, context) => {
console.log("Error: ", err);
},
},
{ startPosition: earliestEventPosition },
);
function subscribe(partitionId: string, handlers: SubscriptionEventHandlers, options?: SubscribeOptions): SubscriptionParâmetros
- partitionId
-
string
O id da partição para assinar.
- handlers
- SubscriptionEventHandlers
Manipuladores para o ciclo de vida da assinatura - inicialização da assinatura da partição, recebimento de eventos, manipulação de erros e o fechamento de uma assinatura para a partição.
- options
- SubscribeOptions
Configura a maneira como os eventos são recebidos.
Os mais comuns são maxBatchSize e maxWaitTimeInSeconds que controlam o fluxo de eventos para o manipulador fornecido para receber eventos, bem como a posição inicial. Por exemplo, { maxBatchSize: 20, maxWaitTimeInSeconds: 120, startPosition: { sequenceNumber: 123 } }
Devoluções
subscribe(SubscriptionEventHandlers, SubscribeOptions)
Subscreva eventos de todas as partições.
Se o armazenamento de ponto de verificação for fornecido ao EventHubConsumerClient e houver várias instâncias do seu aplicativo, cada instância assinará um subconjunto das partições de modo que a carga seja balanceada entre elas.
Chame close() no objeto retornado para parar de receber eventos.
Exemplo de uso:
import { EventHubConsumerClient, earliestEventPosition } from "@azure/event-hubs";
const client = new EventHubConsumerClient("my-consumer-group", "connectionString", "eventHubName");
const subscription = client.subscribe(
{
processEvents: async (events, context) => {
console.log("Received event count: ", events.length);
},
processError: async (err, context) => {
console.log("Error: ", err);
},
},
{ startPosition: earliestEventPosition },
);
function subscribe(handlers: SubscriptionEventHandlers, options?: SubscribeOptions): SubscriptionParâmetros
- handlers
- SubscriptionEventHandlers
Manipuladores para o ciclo de vida da assinatura - inicialização da assinatura por partição, recebimento de eventos, manipulação de erros e fechamento de uma assinatura por partição.
- options
- SubscribeOptions
Configura a maneira como os eventos são recebidos.
Os mais comuns são maxBatchSize e maxWaitTimeInSeconds que controlam o fluxo de eventos para o manipulador fornecido para receber eventos, bem como a posição inicial. Por exemplo, { maxBatchSize: 20, maxWaitTimeInSeconds: 120, startPosition: { sequenceNumber: 123 } }