azure-eventhub相关内容

在C#中读取事件中心存档文件

C#中是否有用于读取Azure Event Hub存档文件(Avro格式)的示例代码? 我正在尝试使用Microsoft.Hadoop.Avro库.我使用产生此结果的java avro工具转储了该模式: { ""type"":""record"", ""name"":""EventData"", ..
发布时间：2020-09-15 05:16:51 C#/.NET

找不到Azure DocumentDB读取文档资源

我正在构建.Net控制台应用程序以读取DocumentDB中的信息.控制台应用程序具有来自EventHub的数据，并在其进入​​云时插入/更新最新数据. 我正在尝试从DocumentDB中读取单个文档，并且可以在请求文档之前确认该文档是否存在. if (DocumentDBRepository.DoesItemExist(name)) { ..
发布时间：2020-09-07 23:11:20 C#/.NET

使用pySpark在Azure Databricks中消耗EventHub中的事件

我可以看到火花接头&在Azure Databricks中使用Scala从事件中心使用事件的准则. 但是，如何使用pySpark从蔚蓝的数据块中消耗事件中心中的事件? 任何建议/文档详细信息都会有所帮助.谢谢 解决方案 下面是用于从蔚蓝数据块上的pyspark从事件中心读取事件的代码段. // With an entity path val with = "Endpoin ..
发布时间：2020-09-04 07:27:46 其他开发

Azure IoT中心AMQP通信复用

在某些 Microsoft文档中它与Azure IoT集线器一起使用时提到，在多个简单设备与功能强大的本地集线器设备进行通信的本地集线器设备进行通信的情况下，可以在单个TLS连接下(使用AMQP协议)复用多个设备的通信.物联网中心是否有任何示例说明如何实现这种多路复用? DeviceClient库似乎不支持此功能(尽管我可以错误的).也曾提到过针对这种情况的IoT Gateway SDK，但我还没 ..
发布时间：2020-08-24 01:46:35 其他开发

Microsoft Azure EventHub中的事件保留

我正在检查有关事件中心中邮件保留的详细信息. 假设我已将tentionalPolicy设置为1天，并且已经发送了一些消息.然后，如果我将邮件的retentionPolicy更改为3天，现有的eventData也会保留3天吗? 解决方案 关于保留策略的另一个重要细节-EventHubs 不在消息级别应用保留策略.它在文件系统级别. EventHubs是高吞吐量事件获取管道.简而言之，它是云上 ..
发布时间：2020-08-23 03:11:18 其他开发

订阅/侦听Azure Event Hub的python脚本?

我有兴趣从Python脚本监听事件中心，并在检测到入站消息时执行一些代码. 在Ubuntu上，将Python 2.7与 https://pypi.python.org一起使用/pypi/python-qpid-proton/0.10 和示例“接收器"脚本，我尝试订阅一个看起来像这样的URI: amqps://:@.servicebus ..
发布时间：2020-07-05 01:37:07 Python

从Azure事件中心获取事件后，是否应该将事件放入队列中？

我目前正在开发使用Azure事件中心在Azure上托管的应用程序。基本上，我是从Web API向事件中心发送消息（或应该说事件）的，我有两个侦听器： 用于实时分析的流分析任务 标准工作角色，该角色根据接收到的事件计算一些内容，然后将它们存储到Azure SQL数据库（这是lambda体系结构） 。 我当前正在使用 EventProcessorHost 库，以从我的辅助角色中的事件中心 ..
发布时间：2020-06-06 20:01:59 C#/.NET

事件中心指标显示许多“其他错误”，如何获取详细信息？

因此，我已经使用新门户创建了事件中心。当我访问“事件中心”刀片并浏览到“监视”部分的“度量”刀片时，我得到以下图表： 我想知道在哪里可以找到有关这些错误的更多信息。有人知道吗？ 解决方案 事件中心还可以发出诊断日志，其中包含有关错误的详细诊断信息。请参阅 https://docs.microsoft.com/zh-cn/azure/monitoring-and-diagnostics ..
发布时间：2020-06-06 20:01:19 其他开发

Azure功能-事件中心未触发功能

我有一个Azure基础结构： 2个HTTP函数->事件中心-> 2个函数->表存储 （所以有两个将消息发送到事件中心的http函数，以及两个由事件中心的消息触发的函数，其中一个将消息存储在表存储中） Azure ARM模板每天使用Azure CLI自动创建基础结构。最近两个月我没有改变逻辑，但是自4月初以来，我注意到了新的怪异行为。 设置结束后，将自动执行E2E测试。他们正 ..
发布时间：2020-06-06 20:00:03 其他开发

来自Android的Azure Event Hub授权

我正在开发一个将数据发送到azure事件中心的应用程序.这类似于此处的博客文章: http://sreesharp.com/send-events-from-android-app-to-microsoft-azure-event-hubs/ 但是，我更新了连接代码以使用OkHttp: public void sendMessageOkHttp(String dataPacket, S ..
发布时间：2020-05-19 21:59:40 Java开发

Azure事件中心如何处理不同的事件?

通过主题/队列和消息头的某种组合来区分不同的事件类型.在Kafka中，记录流仍作为主题分开( https://kafka.apache.org/intro).在浏览Azure Event Hubs文档时，我没有看到任何这样的想法.有分区，但这些分区与消费者并行性有关( 解决方案 是.我为Kafka中的“主题"创建了一个事件中心，即每个事件中心都充当一个数据流. Event Hub中的分区就像K ..
发布时间：2020-05-09 01:35:20 其他开发

我们可以与蔚蓝的通知集线器连接蔚蓝的活动中心？

我给从Windows窗体应用程序的消息，蔚蓝的活动中心。我使用的数据流分析为一些实时操作，并从事件中心的数据之后。该操作后，我发送结果消息事件枢纽。现在我要显示结果的消息，使用移动应用（Android或Windows Mobile应用程序）通过湛蓝的通知中心的用户。我们可以连接蔚蓝的通知中心，并直接蔚蓝的活动中心？ 解决方案 没有它不能直接完成，一些中间层应该得到从事件中心再发送邮件到通过 ..
发布时间：2016-10-04 15:44:29 C#/.NET

SignalR与Azure的EventHub向外扩展

我要寻找SignalR高频率缩放的解决方案。我想知道如果我能与天青EventHub做到这一点。如果我使用EventHub作为我背板SignalR的消息，它会成为一个瓶颈给我吗？ 我检查此页面，但并没有什么关于EventHub，因为它是相当新的。 解决方案 我不说话SignalR的precise细节;但是，可以在原则上使用EventHubs的背板，但你需要知道的局限性。 SignalR背 ..
发布时间：2016-07-29 17:52:21 C#/.NET

最简单的记录从Azure的事件集线器的所有邮件的方式

我使用它输出到事件中心的服务。 我们要存储输出，通过在Apache星火运行的批处理作业读取每天一次。基本上我们算了一下，一下就转储到斑点的所有消息。 什么是捕获从事件中心消息Blob存储最简单的方法？ 我们的第一个想法是一个流媒体分析工作，但它需要解析的原始消息（CSV / JSON / Avro的），我们目前的格式是没有这些的。 的更新的我们改变我们的信息格式，解决了这个问题。我还是想知 ..
发布时间：2016-07-29 17:40:28 云存储

Azure的活动中心和多个消费群体

需要在以下情况下使用Azure的事件中心的帮助。我认为，消费群体可能是这种情况下正确的选择，但我没能在网上找到一个具体的例子。 这是问题的粗略描述和使用事件中心的建议的解决方案（我不知道这是否是最佳的解决方案。请问AP preciate您的反馈） 我有多个事件源产生大量的事件数据（来自传感器遥测数据），这需要被保存到我们的数据库和一些分析，像跑步平均值，最小值，最大值应平行 发送者可以只 ..
发布时间：2016-07-29 17:38:39 云存储

使用REST API时，选择Azure的事件枢纽分区

我试图使用python和REST API将消息发送到Azure的活动中心 经过一些失败的实验我已经找到工作code（见下文），但我希望能够选择到哪个分区发送的事件。 这是可能使用REST API，如果是这样应该怎么做呢？ ＃！/用户/斌/蟒蛇 进口JSON 从日期时间日期时间进口 从多进口游泳池 ＃从azure.servicebus进口_service_bus_error_handler从a ..
发布时间：2016-07-29 17:25:55 Python