stream-analytics

    0热度

    1回答

    我有一系列正在由流分析作业处理的动态数据。有几个可以明确查询的统一属性,但在查询时大部分有效负载是未知类型。我的目标是获取这个未知数据(记录)并将所有属性提升为写入Azure Table的结果查询中的顶级字段。 我能够扁平化记录的属性,它总是作为子对象添加到查询中。 GetRecordProperties()没有帮助,因为我不想为每个属性返回一个单独的记录。 我的查询看起来是这样的: WITH

    0热度

    1回答

    我确定我忽略了一些非常基本的东西。如果任何人都可以提供帮助,或者指向相关主题,我会非常感激。另外,如果你需要更多的代码,我很乐意提供它。 我有一个简单的银行账户程序。在main()类,我有以下功能: void deposit(const Bank bank, ofstream &outfile) { int requested_account, index; double a

    0热度

    1回答

    我有一个Stream分析作业,它从外部来源获取数据(我对数据格式化方式没有发言权)。我试图将数据导入到我的数据湖中,并将其存储为JSON。这工作正常,但我也想获得在CSV输出,这是我有麻烦。 由于输入数据有一个数组作为列之一,所以当以JSON导入时它会识别它并提供正确的数据,即将它们放在括号[A,B,C]中,但是当我在CSV中使用它时获得表示为“Array”一词的列。我想我会将它转换为XML,使用

    0热度

    1回答

    在我有时间获取流程设置的提取策略&之前,我开始收集最终将通过流分析作业的数据。现在我坐在一个Azure blob存储容器中,其中有超过500,000个blob(没有文件夹组织),另一个容器有300,000个,另外一个容器的容量为10,000 - 90,000。 生产收集过程现在将这些斑点写入YYYY-MM-DD/HH格式的不同容器,但这只是前进的很棒。我拥有的这些归档数据对于进入我的系统至关重要,

    1热度

    1回答

    我正在使用azure流分析,并且希望将同一时间的多个输入分组到一个输出。 current output 如何修改我的代码,它在第一行打印,例如: {"HO","KSPF","07","03","#300","46091240","2017-05-31T10:17:34:4430000Z"}

    1热度

    1回答

    我有一个使用spring框架的大型GWT项目。它在Jetty上运行。 当我启动这个Web应用程序时 - Web浏览器进入状态'Not Responding'10-15秒。 这很奇怪,因为我无法想象浏览器可以挂起的原因。 是否有人知道为什么会出现这种奇怪的行为?一些JavaScript的计算?

    1热度

    1回答

    在创建流工作,其输出到Blob存储,人们必须指定一个“路径模式”,如: telemetry/{date}/{time} 这似乎是在UTC,甚至仅指定一个{日期}时,时区是相关的。 这是什么时候使用的,是否可以引用时区? 它是否使用TIMESTAMP,如果是的话,我可以用时区修改它吗? 编辑:2017年2月27日 - 这里是我的工作典型查询: SELECT measurement.Ar

    0热度

    1回答

    我试图进入的JSON对象作为JSON对象格式化成输出 输入: { "id" : "001", "firstArray":[ { "tid" : 9, "secondArray":[ { "keep1" : "value1", "keep2" : "value2", "remove1" : "

    0热度

    1回答

    我正在使用流分析查询来过滤我输入的复杂Json对象。 输入: { "id" : "001", "firstArray":[ { "tid" : 9, "secondArray":[ { "key1" : "value1", "key2" : "value2" }, {...}

    6热度

    2回答

    我遵循IOT Hub tutorial并使其工作。然后,我创建了一个Stream Analytics作业,并将上述内容用作输入(在测试连接工作时)。 但是我没有看到任何收到的输入。在运行样本测试时,出现以下错误: Description Error code: ServiceUnavailable Error message: Unable to connect to input source a