问题标签 [azure-stream-analytics]

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

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

接收代码

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

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

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

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

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

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

干杯!

我的查询如下：

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

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

有什么办法解决这个..

谢谢

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

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

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 中的代码：

感谢您的帮助！

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?

我正在尝试使用“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”以便流分析可以理解它？

谢谢你的时间。

我需要将时间戳作为列插入 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

提前致谢