PluggableCheckpointStoreEventProcessor<TPartition> Classe
Definição
Importante
Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.
Fornece uma base para criar um processador de eventos com lógica de processamento personalizada que consome eventos em todas as partições de um determinado Hub de Eventos para um grupo de consumidores específico. O processador é capaz de colaborar com outras instâncias para o mesmo hub de eventos e emparelhamento de grupo de consumidores para compartilhar o trabalho usando uma plataforma de armazenamento comum para se comunicar. A tolerância a falhas também é interna, permitindo que o processador seja resiliente diante de erros.
public abstract class PluggableCheckpointStoreEventProcessor<TPartition> : Azure.Messaging.EventHubs.Primitives.EventProcessor<TPartition> where TPartition : EventProcessorPartition, new()type PluggableCheckpointStoreEventProcessor<'Partition (requires 'Partition :> EventProcessorPartition and 'Partition : (new : unit -> 'Partition))> = class
inherit EventProcessor<'Partition (requires 'Partition :> EventProcessorPartition and 'Partition : (new : unit -> 'Partition))>Public MustInherit Class PluggableCheckpointStoreEventProcessor(Of TPartition)
Inherits EventProcessor(Of TPartition)Parâmetros de tipo
- TPartition
O contexto da partição para a qual uma operação está sendo executada.
- Herança
Comentários
Para habilitar a coordenação para o compartilhamento de partições entre PluggableCheckpointStoreEventProcessor<TPartition> instâncias, elas declararão acesso de leitura exclusivo a partições para o grupo de consumidores. Nenhum outro leitor deve estar ativo no grupo de consumidores além dos processadores que pretendem colaborar. Leitores não exclusivos terão acesso negado; leitores exclusivos, incluindo processadores que usam diferentes locais de armazenamento, interferirão na operação e no desempenho do processador.
O PluggableCheckpointStoreEventProcessor<TPartition> é seguro para armazenar em cache e usar durante o tempo de vida de um aplicativo, e essa é a melhor prática quando o aplicativo processa eventos regularmente ou semestralmente. O processador é responsável pelo gerenciamento eficiente de recursos, trabalhando para manter o uso de recursos baixo durante períodos de inatividade e gerenciar a integridade durante períodos de maior uso. Chamar o método ou StopProcessing(CancellationToken) quando o StopProcessingAsync(CancellationToken) processamento for concluído ou como o aplicativo está sendo desligado garantirá que os recursos de rede e outros objetos não gerenciados sejam limpos corretamente.
Construtores
Propriedades
| ConsumerGroup |
O nome do grupo de consumidores ao qual esse processador de eventos está associado. Os eventos serão lidos somente no contexto desse grupo. (Herdado de EventProcessor<TPartition>) |
| EventHubName |
O nome do Hub de Eventos ao qual o processador está conectado, específico ao namespace dos Hubs de Eventos que o contém. (Herdado de EventProcessor<TPartition>) |
| FullyQualifiedNamespace |
O namespace dos Hubs de Eventos totalmente qualificado ao qual o processador está associado. É provável que isso seja semelhante a |
| Identifier |
Um nome exclusivo usado para identificar esse processador de eventos. (Herdado de EventProcessor<TPartition>) |
| IsRunning |
Indica se esse processador de eventos está ou não em execução no momento. (Herdado de EventProcessor<TPartition>) |
| RetryPolicy |
A política ativa que rege as tentativas de repetição para o processador. (Herdado de EventProcessor<TPartition>) |
Métodos
| ClaimOwnershipAsync(IEnumerable<EventProcessorPartitionOwnership>, CancellationToken) |
Tenta reivindicar a propriedade das partições especificadas para processamento. Essa operação é usada pelo balanceamento de carga para permitir a distribuição da responsabilidade pelo processamento de partições para um hub de eventos e emparelhamento de grupo de consumidores entre os processadores de eventos ativos. |
| CreateConnection() |
Cria um EventHubConnection a ser usado para se comunicar com o serviço hubs de eventos. (Herdado de EventProcessor<TPartition>) |
| GetCheckpointAsync(String, CancellationToken) |
Retorna um ponto de verificação para o Hub de Eventos, o grupo de consumidores e o identificador da partição associada à instância do processador de eventos, para que o processamento de uma determinada partição possa ser inicializado corretamente. |
| ListOwnershipAsync(CancellationToken) |
Solicita uma lista das atribuições de propriedade para partições entre cada uma das instâncias do processador de eventos cooperando para um determinado emparelhamento de grupo de consumidores e Hub de Eventos. Esse método é usado durante o balanceamento de carga para permitir que o processador descubra outros colaboradores ativos e tome decisões sobre como equilibrar melhor o trabalho entre eles. |
| ListPartitionIdsAsync(EventHubConnection, CancellationToken) |
Consultas para os identificadores das partições do Hub de Eventos. (Herdado de EventProcessor<TPartition>) |
| OnInitializingPartitionAsync(TPartition, CancellationToken) |
Executa as tarefas para inicializar uma partição e seu contexto associado para processamento de eventos. (Herdado de EventProcessor<TPartition>) |
| OnPartitionProcessingStoppedAsync(TPartition, ProcessingStoppedReason, CancellationToken) |
Executa as tarefas necessárias ao processar uma partição que está sendo interrompida. Isso geralmente ocorre quando a partição é reivindicada por outra instância do processador de eventos ou quando a instância atual do processador de eventos está sendo fechada. (Herdado de EventProcessor<TPartition>) |
| OnProcessingErrorAsync(Exception, TPartition, String, CancellationToken) |
Executa as tarefas necessárias quando ocorre uma exceção inesperada dentro da operação da infraestrutura do processador de eventos. (Herdado de EventProcessor<TPartition>) |
| OnProcessingEventBatchAsync(IEnumerable<EventData>, TPartition, CancellationToken) |
Executa as tarefas necessárias para processar um lote de eventos para uma determinada partição conforme eles são lidos do serviço hubs de eventos. (Herdado de EventProcessor<TPartition>) |
| ReadLastEnqueuedEventProperties(String) |
Um conjunto de informações sobre o último evento enfileirado de uma partição, conforme observado pelo cliente do EventHubs associado a esse contexto à medida que os eventos são recebidos do serviço hubs de eventos. Isso só estará disponível se o consumidor tiver sido criado com TrackLastEnqueuedEventProperties set. (Herdado de EventProcessor<TPartition>) |
| StartProcessing(CancellationToken) |
Sinaliza o EventProcessor<TPartition> para começar a processar eventos. Se esse método for chamado enquanto o processador estiver em execução, nenhuma ação será tomada. (Herdado de EventProcessor<TPartition>) |
| StartProcessingAsync(CancellationToken) |
Sinaliza o EventProcessor<TPartition> para começar a processar eventos. Se esse método for chamado enquanto o processador estiver em execução, nenhuma ação será tomada. (Herdado de EventProcessor<TPartition>) |
| StopProcessing(CancellationToken) |
Sinaliza o para interromper o EventProcessor<TPartition> processamento de eventos. Se esse método for chamado enquanto o processador não estiver em execução, nenhuma ação será executada. (Herdado de EventProcessor<TPartition>) |
| StopProcessingAsync(CancellationToken) |
Sinaliza o para interromper o EventProcessor<TPartition> processamento de eventos. Se esse método for chamado enquanto o processador não estiver em execução, nenhuma ação será executada. (Herdado de EventProcessor<TPartition>) |
| UpdateCheckpointAsync(String, Int64, Nullable<Int64>, CancellationToken) |
Cria ou atualiza um ponto de verificação para uma partição específica, identificando uma posição no fluxo de eventos da partição da qual um processador de eventos deve começar a ler. |
| ValidateProcessingPreconditions(CancellationToken) |
Executa as tarefas necessárias para validar a configuração básica e as permissões das dependências necessárias para o processador funcionar. (Herdado de EventProcessor<TPartition>) |
Aplica-se a
Azure SDK for .NET