azure-stream-analytics

    0热度

    1回答

    我们的一位开发人员正在使用Azure Stream Analytics将数据从Azure blob存储中提取出来,然后将其插入到Azure SQL数据库表中。目标SQL表具有整数数据类型的列。 Azure流分析不支持整数类型,只支持bigint类型。所以当SA试图向我们的表中插入一行时,我们会得到一个数据类型不匹配的错误。 将行写入SQL表时,有没有办法让Stream Analytics将数据写入

    0热度

    1回答

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

    0热度

    1回答

    作为标题。如果我从视觉工作室2017发布工作,这个工作会做什么?它是否会从停止的同一点重新开始读取,还是从新的时间开始并错过一些数据?

    0热度

    1回答

    虽然在TumblingWindow中传递参考数据字段的持续时间,但我得到的编译时间与窗口持续时间有关的错误需要正浮点数常量。 任何人都可以请指导? group by TumblingWindow(minute, referencetable.EntryTime)

    0热度

    1回答

    我收到的错误与我在查询中发送的内容不匹配。 我的查询: SELECT udf.CreateGuid('') AS [id], udf.CreateGuid('') AS [DocumentId], BlobName, BlobLastModifiedUtcTime, [telmetry].[event_type] as PartitionKey,

    1热度

    1回答

    我不必查看Azure流分析中的流,但知道它处于该工具的功能范围内。我有许多小型消息将从许多来源进入我的解决方案,并且会在数据湖转到其最终目的地之前通过函数“正常化”数据。我需要通过符合特定条件的解决方案的数据才能触发通知,但需要确保通知中不会产生太多噪音,所以要限制给定组合在给定时间段内发送一次。 对于我愿做一个例子,考虑温度例如: { Location: "Server",

    0热度

    2回答

    我有写一个查询提取表了从JSON文件阵列的一个问题: 的问题是如何让数组的信息“数据包”,其数组的内容,然后将它们全部放在一个普通的sql表中。 有一个棘手的问题是“CrashNotification”和“CrashMaxModuleAccelerations”,我不知道如何定义和使用它们。 文件看起来是这样的: { "imei": { "imei": "351631044527130F", "i

    0热度

    1回答

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

    1热度

    1回答

    我流的分析工作是获取数据,它现在停止产生输出事件 这可以防止数据被发送到双向电力在电力BI显示 我只想过去24小时的数据 我怎样才能做到这一点? 我试图减少时间窗口,但我不想这样做的修复。 SELECT [Timestamp], Broker, Price, COUNT(*) INTO [powerbi2] FROM [eventhubinput] TIMESTAMP BY [TimeStam

    0热度

    1回答

    如何将图像添加到Power BI 报告?我知道如何将图像添加到仪表板 这是指电力BI在浏览器内,无法开机BI桌面 我不能使用Power BI的桌面,不支持流分析数据 干杯 Paul