问题标签 [azure-stream-analytics]

我有格式为“1234.567.111”的字符串。我想把它分成三个int。

我在 azure 流分析中看不到拆分功能。是否有可能以任何其他方式做到这一点。

谢谢

更新：

我在这里添加了一个拆分功能的请求..，如果你们投了同样的票，将不胜感激..

假设我有一个 JSON 对象进入 Azure 流分析作业：

我可以执行以下操作来获得“Long”和“Lat”的各个值吗？

我可以执行以下操作来隔离数组值 [115.17348, -8.72263]：

但是我在抓取数组的单个元素时遇到了麻烦。我在网上看到了有关 GetArrayElement() 的模糊文档，流分析一直说“GetArrayElement 在这种情况下不受支持或不可用”。

试图获得我的大门状态的实时仪表板（开，关）

我的有效载荷的 JSON 格式是

有没有人有关于如何在不使用 Azure 流分析或事件中心的情况下将状态发送到 power bi 的经验？

编辑：尝试将两个 json 包从 Node-Red 发送到 Power BI，以在我的仪表板上获取实时更新

我根据演练中的示例创建了一个流：使用流分析从 Application Insights 导出到 SQL。输出已配置并测试正常。查询已定义并且测试正常。输入（数据流）配置为从 Blob 中提取并测试 OK，此外示例数据正常工作并成功从 BLOB 获取 JSON。但是，当我开始工作时，我继续收到错误：

流作业失败：流分析作业存在验证错误：输入分区方案未正确定义。

我该如何解决这个问题？

输入：

• 订阅、存储帐户、密钥和容器都正确。
• 序列化：JSON
• 编码：UTF8
• 路径前缀模式：analyticsAccount_xxx...xxxx/Event/{date}/{time}
• 日期格式：YYYY-MM-DD
• 时间格式：HH

我正在尝试将事件中心用作 Azure 流分析的输出接收器，执行此操作的代码如下所示。

我想要做的是将流分析的结果发送到事件中心中的特定分区。我通过将 PartitionKey 属性设置为我定义的字符串来做到这一点。但是，这是行不通的。EventHubOutputDataSourceProperties 中的 partitionKey 属性似乎不是事件中心中使用的分区键。然后我的问题是如何将其发送到特定分区并将分区键设置为我想要的。

任何帮助表示赞赏。

我在 Azure 中创建了流分析作业。我想使用 Power BI 作为流作业的输出。但似乎只有具有组织 ID 的 azure 帐户可以在那里使用。是否有任何解决方法可以使用没有组织 ID 的 Azure 帐户将 Azure 流分析与 Power BI 结合使用？

我已将 Azure 流分析作业输出设置为 Power BI。但是我在分析工作中收到PBI 服务不支持的 System.Object 类型的警告。

我也无法在 Power BI 中看到任何数据。但是我可以看到那里创建的数据库可以确保流分析作业输出到那里。

下面是发送到 Power BI 的示例数据。我知道发生错误是因为其中一个属性是 object 。我可以在 Power BI 做些什么来处理这个问题吗？

I have a very basic setup, in which I never get any output if I use the TIMESTAMP BY statement.

I have a stream analytics job which is reading from Event Hub and writing to the table storage.

The query is the following:

If the query uses timestamp statement, I never get any output events. I do see incoming events in the monitoring, there are no errors neither in monitoring nor in the maintenance logs. I am pretty sure that the source data has the right column in the right format.

If I remove the timestamp statement, then everything is working fine. The reason why I need the timestamp statement in the first place is because I need to write a number of queries in the same job, writing various aggregations to different outputs. And if I use timestamp in one query, I am required to use it in all other queries itself.

Am I doing something wrong? Perhaps SELECT * does not play well with TIMESTAMP BY? I just did not find any documentation explaining that...

我正在使用输出到事件中心的服务。

我们希望存储该输出，每天由运行在 Apache Spark 上的批处理作业读取一次。基本上我们认为，只需将所有消息转储到 blob 即可。

将消息从事件中心捕获到 Blob 存储的最简单方法是什么？

我们的第一个想法是流分析工作，但它需要解析原始消息（CSV/JSON/Avro），我们当前的格式不是这些。

更新我们通过更改消息格式解决了这个问题。我仍然想知道是否有任何低影响的方式将消息存储到 blob。在 Streaming Analytics 出现之前，EventHub 是否有解决方案？

我有一个输出到 PowerBI 的 Azure 流分析作业 - 输出存在并且数据集存在于 PowerBI 中 - 但是，由于我必须手动刷新页面才能接收更新的数据，所以该图不存在。

如何获得实时数据源？

干杯!