我在Azure门户中创建了一个事件中心,它有两个分区(0和1)。因为在像服务总线这样的事件中心中没有主题的概念。我试图在分区0和分区1中存储不同的数据
ehClient = EventHubClient.createFromConnectionStringSync(eventHubConnectionString.toString());
byte[] payload = "Storing data in partion 0".getBytes("UTF-8");
/** Storing data in partion 0*/
EventData data =
我将Stream Analytics用于一个简单的数据直通场景。
作业有多个SQL Server输出(三个)和一个EventHub输入。事件计数很小。问题是我的SU %利用率一直在增加。我的临时解决方案是每天重新启动Job一到两次。
我做错了什么吗?下面是我的查询示例。我尝试将查询更改为使用TUMBLINGWINDOW,但我得到了相同的结果。
SELECT field_1, field_2, field_3, field_4, field_5
INTO [out-alias-1]
FROM [in-alias]
WHERE field_1 LIKE 'Event1:%' OR
我有一个应用程序,可以将设备从物理世界映射到 in 。每次从设备接收消息时,我都希望将消息推送到事件中心。
我现在要做的是为每条消息创建/使用/关闭EventHubClient对象。
这是非常低效的(花费大约1500 is ),但它解决了我过去在内存中保存EventHubClient的一个问题。当我有很多设备时,底层虚拟机就会很快耗尽网络连接。
我正在考虑创建一个新的参与者,负责将数据推送到EventHub (通过保持EventHubClient活动)。由于可靠行为者的基于转换的并发模型,我不确定这是一个好主意。如果我得到10000个设备“同时”推送数据,它们的每个参与者都会阻止将消息推送到将
我使用EventHubConsumerClient.ReadEventsAsync方法读取eventHub中的事件。当我使用默认的eventHub时,它工作得很好。但是,当我将其路由到一个新的eventHub时,我会不时地得到EventHubsExeception(ConsumerDisconnected)。从文件上看。它说,这是由于A client was forcefully disconnected from an Event Hub instance. This typically occurs when another consumer with higher OwnerLevel
我试图通过添加一个临时结果集来修改现有的蔚蓝流分析作业。但是当我运行SA作业时,它会抛出运行时错误,水印延迟会增加。
以下是流分析工作中现有的SAQL:
-- Reading from Event Hub
WITH INPUTDATASET AS (
SELECT
udf.udf01([signals2]) AS flat
FROM [signals2]
PARTITION BY PartitionId
WHERE [signals2].ABC IS NOT NULL
),
INPUT1 AS (
SELECT
ID,