Azure 流分析查询将输出发送到不同的目标

Question

我们正在使用 Azure 流分析从 IOT Hub 读取消息并写入 Azure 数据湖存储。流分析作业的输入为 JSON 格式，输出应为 CSV 格式。在流分析中，我们创建了多个输出数据接收器，它们指向 Azure 数据湖存储中的不同目录。基于输入 JSON 字符串中的一个字段，我们必须将输入转换为 CSV 并写入相应的输出数据接收器。我们如何在流分析查询中实现这一点？

Answer 1

格式的转换将自动完成。您需要做的就是定义您的流分析逻辑。

这是一个非常简单的查询，它将数据写入两个不同的 Data Lake 输出，具体取决于 JSON 输入中变量的值。

SELECT * INTO datalake1 from myinput
where windspeed<10

SELECT * INTO datalake2 from myinput
where windspeed>10

谢谢，

JS（Azure 流分析）