Disponibilidade e consistência em Hubs de Eventos

Este artigo fornece informações sobre a disponibilidade e consistência suportadas pelo Hubs de Eventos do Azure.

Disponibilidade

Hubs de Eventos do Azure propaga o risco de falhas catastróficas de máquinas individuais ou mesmo de racks completos em clusters que abrangem vários domínios de falha num datacenter. Implementa mecanismos transparentes de deteção de falhas e ativação pós-falha de forma a que o serviço continue a funcionar dentro dos níveis de serviço garantidos e, normalmente, sem interrupções visíveis quando tais falhas ocorrem.

Se um espaço de nomes dos Hubs de Eventos for criado numa região com zonas de disponibilidade, o risco de indisponibilidade será distribuído por três instalações fisicamente separadas e o serviço tem reservas de capacidade suficientes para lidar instantaneamente com a perda total e catastrófica de toda a instalação. Para obter mais informações, veja Hubs de Eventos do Azure – Recuperação após desastre geográfico.

Quando uma aplicação cliente envia eventos para um hub de eventos sem especificar uma partição, os eventos são distribuídos automaticamente entre partições no hub de eventos. Se uma partição não estiver disponível por algum motivo, os eventos são distribuídos entre as restantes partições. Este comportamento permite a maior quantidade de tempo de espera. Para casos de utilização que requerem o tempo máximo de utilização, este modelo é preferido em vez de enviar eventos para uma partição específica.

Consistência

Em alguns cenários, a ordenação de eventos pode ser importante. Por exemplo, poderá querer que o seu sistema de back-end processe um comando de atualização antes de um comando eliminar. Neste cenário, uma aplicação cliente envia eventos para uma partição específica para que a ordenação seja preservada. Quando uma aplicação de consumidor consome estes eventos da partição, estes são lidos por ordem.

Com esta configuração, tenha em atenção que, se a partição específica para a qual está a enviar estiver indisponível, receberá uma resposta de erro. Como ponto de comparação, se não tiver uma afinidade com uma única partição, o serviço Hubs de Eventos envia o evento para a partição disponível seguinte.

Por conseguinte, se a elevada disponibilidade for mais importante, não direcione uma partição específica (utilizando o ID/chave da partição). A utilização do ID de partição/chave reduz a disponibilidade de um hub de eventos para o nível de partição. Neste cenário, está a fazer uma escolha explícita entre a disponibilidade (sem ID/chave de partição) e a consistência (afixar eventos a uma partição específica). Para obter informações detalhadas sobre as partições nos Hubs de Eventos, veja Partições.

Apêndice

Enviar eventos sem especificar uma partição

Recomendamos o envio de eventos para um hub de eventos sem definir informações de partição para permitir que o serviço dos Hubs de Eventos balancee a carga entre partições. Veja os seguintes guias de introdução para saber como fazê-lo em diferentes linguagens de programação.

• Enviar eventos com .NET
• Enviar eventos com Java
• Enviar eventos com JavaScript
• Enviar eventos com o Python

Enviar eventos para uma partição específica

Nesta secção, vai aprender a enviar eventos para uma partição específica através de diferentes linguagens de programação.

.NET

Para enviar eventos para uma partição específica, crie o lote com o método EventHubProducerClient.CreateBatchAsync ao especificar o PartitionId ou o PartitionKey em CreateBatchOptions. O código seguinte envia um lote de eventos para uma partição específica ao especificar uma chave de partição. Os Hubs de Eventos garantem que todos os eventos que partilham um valor de chave de partição são armazenados em conjunto e entregues por ordem de chegada.

var batchOptions = new CreateBatchOptions { PartitionKey = "cities" };
using var eventBatch = await producer.CreateBatchAsync(batchOptions);

Também pode utilizar o método EventHubProducerClient.SendAsync ao especificar PartitionId ou PartitionKey em SendEventOptions.

var sendEventOptions  = new SendEventOptions { PartitionKey = "cities" };
// create the events array
producer.SendAsync(events, sendOptions)

Java

Para enviar eventos para uma partição específica, crie o lote com o método createBatch ao especificar o ID da partição ou a chave de partição em createBatchOptions. O código seguinte envia um lote de eventos para uma partição específica ao especificar uma chave de partição.

CreateBatchOptions batchOptions = new CreateBatchOptions();
batchOptions.setPartitionKey("cities");

Também pode utilizar o método EventHubProducerClient.send ao especificar o ID da partição ou a chave de partição em SendOptions.

List<EventData> events = Arrays.asList(new EventData("Melbourne"), new EventData("London"), new EventData("New York"));
SendOptions sendOptions = new SendOptions();
sendOptions.setPartitionKey("cities");
producer.send(events, sendOptions);

Python

Para enviar eventos para uma partição específica, ao criar um lote com o EventHubProducerClient.create_batch método , especifique o partition_id ou o partition_key. Em seguida, utilize o EventHubProducerClient.send_batch método para enviar o lote para a partição do hub de eventos.

event_data_batch = await producer.create_batch(partition_key='cities')

Também pode utilizar o método EventHubProducerClient.send_batch ao especificar valores para partition_id ou partition_key parâmetros.

producer.send_batch(event_data_batch, partition_key="cities")

JavaScript

Para enviar eventos para uma partição específica, crie um lote com o objeto EventHubProducerClient.CreateBatchOptions ao especificar o partitionId ou o partitionKey. Em seguida, envie o lote para o hub de eventos com o método EventHubProducerClient.SendBatch .

Veja o seguinte exemplo.

const batchOptions = { partitionKey = "cities"; };
const batch = await producer.createBatch(batchOptions);

Também pode utilizar o método EventHubProducerClient.sendBatch ao especificar o ID da partição ou a chave de partição em SendBatchOptions.

const sendBatchOptions = { partitionKey = "cities"; };
// prepare events
producer.sendBatch(events, sendBatchOptions);

Passos seguintes

Pode saber mais sobre os Hubs de Eventos ao aceder às seguintes ligações:

• Descrição geral do serviço Hubs de Eventos
• Terminologia dos Hubs de Eventos