问题标签 [azure-stream-analytics]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
0 回答
256 浏览

amqp - 带有空消息的 EventHub Reciever RecieveTime 问题

我正在使用AzureSBLite包装器来轮询来自eventhub具有特定分区的消息。事件数据将被发送到一个事件中心,流分析将从那里读取。处理后流分析会将其写入特定分区中的不同事件中心。

接收部分通常采用60-150s接收方法,这里不应该是这种情况。我不确定包装中发生了什么以及它在哪里。我已经验证了 的输出streamanalytics,它几乎是即时的,但接收器什么也没得到。


接收代码


在此处输入图像描述

尝试使用 Same EventHub 但两个不同的分区更糟糕。


在此处输入图像描述

注意:Windows 10 IoT Core 不支持 Azure.SeriveBus。因此无法使用 EventProcessorHost。

0 投票
2 回答
189 浏览

powerbi - 将位置从 ASA 映射到 powerbi

我有一个流分析工作,可以为 powerbi 生成位置纬度和经度。我正在尝试从这些位置在 powerbi.com 上创建地图。我正在创建地图并将纬度和经度字段添加到地图纬度和经度字段。但是什么也没有产生。它也需要一些位置字段。我应该在那里提供什么数据?

0 投票
1 回答
1572 浏览

powerbi - 来自 ASA 的 PowerBi 最新值

是否可以显示从流分析到达 PowerBi 的最新值?例如,在卡片图表类型中,我想为测量时间字段选择最新值或其他内容的过滤器值?

0 投票
1 回答
202 浏览

azure - 使用 Azure 流分析进行资产跟踪

我有一个事件中心和一个将数据发送到 Power BI 的流分析作业。我想知道配置事件中心/资产跟踪的最佳方式是什么?

例如,我有多个客户端发送到事件中心 -> 流分析作业,我希望能够确定具有特定 ID 的客户端是否离线?

干杯!

0 投票
1 回答
540 浏览

azure - 按连接的字符串 azure 流分析分组

我的查询如下:

这给出了一个错误:列 'dummy1' 在选择列表中无效,因为它既不包含在聚合函数中,也不包含在 GROUP BY 子句中。

我不希望按单独的列 dummy1 或 dummy2 进行分组,但使用连接数据 dummydata..

有什么办法解决这个..

谢谢

0 投票
1 回答
1005 浏览

azure - 有没有办法将流分析输出写入 Azure documentdb

我正在开发一个应用程序。我正在将数据推送到事件中心。从事件中心我需要使用流分析并将数据推送到 DOcumentdb 以进行分析。谁能指导我将数据从流分析推送到documentdb。我只能看到 SQL 数据库、Blob 存储、事件中心、Power BI 预览、表存储、服务总线队列、服务总线主题的输出

0 投票
1 回答
248 浏览

twitter - 无法查看任何推文的时区、地点或地理位置

我现在正在关注两个教程,并且都已启动并正在运行,并且我从它们那里获得了很多推文/情绪评分:

1) Azure 上的 Twitter 流分析 https://azure.microsoft.com/en-us/documentation/articles/stream-analytics-twitter-sentiment-analysis-trends/

2)使用 Spark Streaming 进行 Twitter 分析http://ampcamp.berkeley.edu/3/exercises/realtime-processing-with-spark-streaming.html

我正在使用apps.twitter.com 提供的免费oauth 工具。

问题 我在 Spark Streaming 应用程序中尝试了 getPlace、getGeoLocation,我得到的每条推文对于这两个字段都有一个空值。我尝试过滤只有 getPlace 值的推文,获取 GeoLocation 并且两者都为空(我运行该应用程序将近 20 分钟)。

我还尝试在 Azure 应用程序中获取 TimeZone(这样我就可以获得某种地理数据),即便如此,我仍然不断获得 TimeZone 的空值。

可能的障碍 1) 免费的 twitter api 是否会过滤掉地点/地理位置信息,所以我最终会购买更好的 api 订阅?

2) 我是否需要明确搜索具有地理位置/地点的推文?而不是获取所有推文,然后过滤掉具有地理位置/地点的推文?如果是这样,我可以在 Spark Streaming 中执行此搜索吗?这是我在 Spark Streaming 中的代码:

感谢您的帮助!

0 投票
1 回答
766 浏览

azure - Azure Eventhub alerting system

We have an IoT service running on Azure which produces a lot of events. We need to build a new feature which allows our end-user to configure alerts based on system events. It allows the user to pick an event and configure an action (e-mail, webhook, etc) to be executed when such an event occurs. We're evaluating Azure Eventhub and possibly Azure Stream Analtyics as candidates for the job.

The problem we face is: We think we will get a lot of stream analytics jobs running. When for example we have 3000 customers each configuring 3 alerts we need to run 9000 stream analtyics jobs which select specific events from the eventhub pushing it in a queue which does the alert processing. This will not only be a tough maintenance job, but I think it not a really cost effective solution.

Any thoughts on this or better solutions?

0 投票
1 回答
729 浏览

serialization - 流分析“无效的 Avro 格式,删除无效记录。”

我正在尝试使用“Microsoft Avro Library”将我的 C# 类序列化为“Avro”并将其发送到事件中心。但是,当我尝试通过流分析读取数据时,它会在日志“无效 Avro 格式,删除无效记录”中出现此错误

更多详细信息.. 使用https://azure.microsoft.com/en-in/documentation/articles/hdinsight-dotnet-avro-serialization/中所示的反射方法 序列化为 avro 格式并将其发送到事件中心

事件可以很好地发布到事件中心。我创建了一个可以使用这些事件并能够反序列化它们的工作角色。

但是,当我将此事件中心设置为流分析的输入并将事件序列化格式设置为“avro”时,它会出现以下错误。

消息:无效的 Avro 格式,删除无效记录。

消息:IncorrectSerializationFormat 错误发生得太快。他们被暂时压制

我想我也必须包括 Avro Schema。谁能指导我正确的方法将 C# 类序列化为“avro”以便流分析可以理解它?

谢谢你的时间。

0 投票
1 回答
2238 浏览

azure - 在 Azure 分析作业中格式化日期时间

我需要将时间戳作为列插入 Azure 表中,格式为yyyy-MM-dd-HH-mm

在普通的 T-SQL 中,我会执行以下操作:

我认为 CONCAT 和 DATENAME/DATEPART 函数会帮助我,我最终得到了这个,但它没有产生我需要的输出:

2015-10-12T05:17:37.807Z被格式化2015-10-12-5-17,我期待2015-10-12-17-17

提前致谢