事件中心内的可用性和一致性

若要将事件发送到特定分区，请使用 EventHubProducerClient.CreateBatchAsync 方法通过在 CreateBatchOptions 中指定 PartitionId 或 PartitionKey 来创建批处理。 以下代码通过指定分区键将一批事件发送到特定分区。 事件中心确保共享分区键值的所有事件存储在一起，并按到达顺序进行传递。

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

还可以通过在 SendEventOptions 中指定 PartitionId 或 PartitionKey 来使用 EventHubProducerClient.SendAsync 方法 。

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

若要将事件发送到特定分区，请使用 createBatch 方法通过在 createBatchOptions 中指定分区 ID 或分区键来 。 以下代码通过指定分区键将一批事件发送到特定分区。

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

还可以通过在 SendOptions 中指定分区 ID 或分区键来使用 EventHubProducerClient.send 方法 。

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

若要将事件发送到特定分区，请在使用 EventHubProducerClient.create_batch 方法创建批处理时，指定 partition_id 或 partition_key。 然后，使用 EventHubProducerClient.send_batch 方法将批处理发送到事件中心的分区。

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

还可以通过指定 partition_id 或 partition_key 参数的值来使用 EventHubProducerClient.send_batch 方法。

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

若要将事件发送到特定分区，请通过指定 partitionId 或 partitionKey 使用 EventHubProducerClient.CreateBatchOptions 对象来创建批处理。 然后，使用 EventHubProducerClient.SendBatch 方法将批处理发送到事件中心。

请参阅以下示例。

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

还可以通过在 SendBatchOptions 中指定分区 ID 或分区键来使用 EventHubProducerClient.sendBatch 方法 。

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