实时数据分析与企业消息集成:Azure Stream Analytics 与 Azure Service Bus 详解
1. Azure Stream Analytics 基础配置
Azure Stream Analytics 是一个用于近实时处理数据流的服务。在配置输入时,根据不同选择会有不同选项。若要配置新的输入源,如 Event Hub,需注意以下字段:
-Event Hub 消费者组:若希望 Azure Stream Analytics 从最初开始读取数据,可在此处输入消费者组。默认使用 $Default,它是 Azure Event Hub 中的默认消费者组。
-事件序列化格式:可从 JSON、Avro 和 CSV 中选择,这样能根据所选格式自动反序列化事件。
-事件压缩类型:若使用 GZip 或 Deflate 压缩,可在此选择相应选项,以便自动反序列化输入。
需注意,要从 Azure Stream Analytics 自动创建 Event Hub,需要有实际的 Azure Event Hub 命名空间。填写完所有必填字段后,点击“创建”按钮即可初始化新输入的创建。可以添加多个输入,它们都会在输入流中可用,方便处理传入事件。
| 配置项 | 说明 |
|---|---|
| Event Hub 消费者组 | 控制数据读取起始点,默认 $Default |