问题标签 [azure-eventhub]
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.
azure - 从 Azure 事件中心记录所有消息的最简单方法
我正在使用输出到事件中心的服务。
我们希望存储该输出，每天由运行在 Apache Spark 上的批处理作业读取一次。基本上我们认为，只需将所有消息转储到 blob 即可。
将消息从事件中心捕获到 Blob 存储的最简单方法是什么？
我们的第一个想法是流分析工作，但它需要解析原始消息（CSV/JSON/Avro），我们当前的格式不是这些。
更新我们通过更改消息格式解决了这个问题。我仍然想知道是否有任何低影响的方式将消息存储到 blob。在 Streaming Analytics 出现之前，EventHub 是否有解决方案？
azure - 事件中心租赁管理
有谁知道我在哪里可以找到有关事件中心租赁管理工作原理的详细信息？具体来说，我试图找到我如何知道 EventProcess 在事件中心的哪个位置进行处理（在重新启动、关闭、租约丢失之后）？在开发过程中将索引设置为开头的最佳方法是什么？
谢谢
python - 如何使用 Python SDK 将变量发送到 Azure 事件中心
如果我有一个包含温度值的变量，如何使用 ServiceBusService.send_event 发送它？
amqp - 带有空消息的 EventHub Reciever RecieveTime 问题
我正在使用AzureSBLite包装器来轮询来自eventhub具有特定分区的消息。事件数据将被发送到一个事件中心，流分析将从那里读取。处理后流分析会将其写入特定分区中的不同事件中心。
接收部分通常采用60-150s接收方法，这里不应该是这种情况。我不确定包装中发生了什么以及它在哪里。我已经验证了 的输出streamanalytics，它几乎是即时的，但接收器什么也没得到。
接收代码
尝试使用 Same EventHub 但两个不同的分区更糟糕。
注意：Windows 10 IoT Core 不支持 Azure.SeriveBus。因此无法使用 EventProcessorHost。
azure - 使用 Azure 流分析进行资产跟踪
我有一个事件中心和一个将数据发送到 Power BI 的流分析作业。我想知道配置事件中心/资产跟踪的最佳方式是什么？
例如，我有多个客户端发送到事件中心 -> 流分析作业，我希望能够确定具有特定 ID 的客户端是否离线？
干杯!
python - 使用 rest api 时选择 Azure 事件中心的分区
在一些失败的实验之后，我尝试使用 python 和其余 API 将消息发送到 Azure 事件中心，但我发现了工作代码（见下文），但我希望能够选择将事件发送到哪个分区。
这是否可以使用其余的 API，如果可以，应该怎么做？
java - 如何通过rest api在事件中心发送和消费消息
我是 Azure EventHub 的新手。我想编写一个简单的原型，它可以通过它的 rest api 从 AzureEventHub 发送和接收消息。
您能否通过提供代码片段来帮助我，演示如何使用 EventHub 中公开的 rest api 进行消息生成和消费。
node.js - 如何使用节点 js 获取 Azure EventHub 数据
我是Microsoft 活动中心的初学者。我成功地将数据发送到eventHub使用节点 js（refrence）。
如何接收和显示来自事件中心的数据？任何的想法？
python - 在嵌入式 Linux 设备中安装 Qpid-Proton
我正在尝试在嵌入式 Linux 设备中安装 Qpid-Proton(Python) 以连接 Azure 事件中心。以前，我已经使用https://git-wip-us.apache.org/repos/asf?p=qpid-proton.git;a=blob_plain中给出的安装步骤成功测试了将 Linux PC 与 Azure 事件中心连接 ;f=INSTALL.md;hb=0.10
为了在基于嵌入式 Linux 的设备上做同样的事情，我修改了 Linux yocto 映像以包含“pip”安装程序包和使用 Linux PC 安装 Qpid-proton 所需的包。
使用该图像，我尝试在板上进行安装的第二部分（从创建“构建”目录）。它在 cmake 部分失败，将错误抛出为：
$ cmake -D CMAKE_C_COMPILER=/usr/bin/arm-poky-linux-gnueabi-gcc -DCMAKE_INSTALL_PREFIX=/usr/bin .. -DSYSINSTALL_BINDINGS=ON
-- C 编译器标识未知 -- 检查工作 C 编译器：/usr/bin/arm-poky-linux-gnueabi-gcc -- 检查工作 C 编译器：/usr/bin/arm-poky-linux-gnueabi -gcc -- 在 /usr/share/cmake-2.8/Modules/CMakeTestCCompiler.cmake:61 (message) 处出现错误的 CMake 错误：C 编译器“/usr/bin/arm-poky-linux-gnueabi-gcc”不能编译一个简单的测试程序。
PS：我是 Linux 的初学者，并且通过谷歌搜索完成了上述所有操作。如果有任何在嵌入式 linux 设备中安装 Qpid 的过程，请与我分享。谢谢你。
c# - 使用 EventHub 和 Async 的突发请求模式
我正在尝试将音频文件（wav）从IoT设备发送到Eventhub. 由于Eventhub每条消息的大小限制为 64Kb，因此每条消息都被分块成一个7kb字节数组并发送到Eventhub. 我正在尝试从客户端实现最大发送速率[不超过阈值]。
录制实时音频，将其保存在文件流中并分块发送。我通过自定义流实现避免了这部分
但是我无法通过 REST 实现以相同的速度发送字节。对于发送，我正在使用第三方包装器，所以我不能在那一边做。
但是我可以跨越线程以在交互时使应用程序响应，所以我使用
我不想等待任务完成任务的结果。但是当我这样做时，我的大部分请求都得到了“ Request Timed out”，并且由于这些请求，应用程序被卡住了。
无论如何我可以在不阻塞线程的情况下使应用程序响应。
编辑：当前已应用Parallel.Invoke并且没有丢失一条消息，并且应用程序也有响应，但发送下降到 2-3 条消息/秒
我应该切换到多线程模型而不是使用异步。发现类似这样的类似问题.Net 4.5 中的异步 HttpClient 对于密集负载应用程序来说是一个糟糕的选择吗？