本文介绍如何在事件中心使用日志压缩功能。 若要了解日志压缩的详细信息,请参阅 日志压缩。
在本文中,你将遵循以下关键步骤:
- 创建压缩的事件中心/Kafka 主题。
- 将事件发布到已压缩的事件中心。
- 从紧凑的事件中心中消费事件。
注释
基本层不支持日志压缩功能。
创建压缩事件中心/Kafka 主题
本部分介绍如何使用 Azure 门户和 Azure 资源管理器 (ARM) 模板创建压缩事件中心。
- Azure 门户
- ARM 模板
可以按照以下步骤使用 Azure 门户创建压缩事件中心。
- 导航到事件中心命名空间。
- 在“事件中心命名空间”页上,选择左侧菜单中的事件中心。
- 在窗口顶部,选择“+ 事件中心”。
- 键入事件中心 的名称 ,并指定 分区计数。 由于我们正在创建压缩事件中心,请选择压缩策略为压缩,并提供墓碑保留时间所需的值。
- 选择 “创建 ”并创建压缩事件中心。
触发压缩
事件中心服务确定何时应执行给定压缩事件中心的压缩作业。 压缩事件中心在有相当数量的事件或给定事件日志的总大小显著增长时达到压缩阈值。
将事件信息发布到压缩主题
将事件发布到压缩的事件中心与将事件发布到常规事件中心相同。 作为客户端应用程序,您只需确定压缩键,并根据分区键来设置它。
使用事件中心 SDK(AMQP)
使用事件中心 SDK,可以设置分区键并发布事件,如下所示:
var enqueueOptions = new EnqueueEventOptions
{
PartitionKey = "Key-1"
};
await producer.EnqueueEventAsync(eventData, enqueueOptions);
使用 Kafka
使用 Kafka,可以在创建 ProducerRecord 分区键时设置分区键,如下所示:
ProducerRecord<String, String> record = new ProducerRecord<String, String>(TOPIC, "Key-1" , "Value-1");
配额和限制
| 限度 | 基本 | 标准 | 高级 |
|---|---|---|---|
| 压缩事件中心的大小 | N/A | 每个分区 1 GB | 每个分区 250 GB |
有关其他的配额和限制,请参阅 事件中心配额和限制。
消费压缩主题的事件
消费者端无需更改即可从精简的事件中心获取事件。 因此,可以使用任何现有的消费者应用程序从压缩事件中枢读取数据。
后续步骤
- 有关日志压缩工作原理的概念性信息,请参阅 日志压缩。