我有一个场景,我将两个事件数据发送到具有不同分区键/分区 ID 的事件中心。
现在在我的流分析中,我创建了两个具有相同连接字符串的输入别名(比如 machine1input 和 machine2input )和两个不同的输出别名,但这里每个输出别名都指向单独的表存储。
现在我的事件数据是这样的。
{
"MachineName": "M1",
"Date": "2016-05-26T13:35:30.1557995+05:30"
}
{
"MachineName": "M2",
"Date": "2016-05-26T13:35:30.1557995+05:30"
}
在这里,我将 MachineName-M1 发送到单独的分区,例如 1,将 MachineName-M2 发送到单独的分区,例如 2。
现在我有两个 azure storage tableMachine1Record
和Machine2Record
. 现在我想在流分析查询窗口中编写查询,这样机器 M1 记录应该存储在Machine1Record
表中,机器 M2 记录应该Machine2Record
作为数据自动存储在表中。
我已经尝试了很多查询来实现这一点。
SELECT * INTO machine1output From machine1input PARTITION BY PartitionId where PartitionId = "1"
SELECT * INTO machine2output From machine2input PARTITION BY PartitionId where PartitionId = "2"
SELECT * INTO machine1output From machine1input where MachineName = "M1"
SELECT * INTO machine2output From machine2input where MachineName = "M2"
但他们都没有工作。请在这方面提供帮助。谢谢。