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

Question

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

Answer 1

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

下面是一个非常简单的查询，它根据JSON输入中变量的值在两个不同的data Lake输出中写入数据。

SELECT * INTO datalake1 from myinput
where windspeed<10

SELECT * INTO datalake2 from myinput
where windspeed>10

谢谢,

JS (Azure流分析)