Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
PySpark:反序列化 eventhub 捕获 avro 文件中包含的 Avro 序列化消息
初始情况 AVRO 序列化事件被发送到 azure 事件中心 这些事件使用 azure 事件中心捕获功能持久存储 捕获的数据以及事件中心元数据以 Apache Avro 格式写入 应使用 py Spark 分析捕获 avro 文件中包含的原
apachespark
PySpark
Avro
azureeventhub
为什么不总是配置事件中心分区的最大数量?
The Azure 事件中心概述 https azure microsoft com en us documentation articles event hubs overview 文章指出以下内容 分区数量在事件中心创建时指定 且必须在
Azure
azureservicebus
azureeventhub
无法通过 KAFKA api 连接到 EventHub
通过 kafka 库连接事件中心时遇到异常 Caused by org apache kafka common protocol types SchemaException Error reading field sasl auth byt
Java
kafkaconsumerapi
azureeventhub
是否可以使用 Apache Beam / Google Cloud Dataflow 从 Azure EventHub 主题进行消费?
Problem 我们希望使用 Google Cloud 中的数据流管道来使用 Azure 中的 EventHub 主题 Question 是否知道 KafkaIO 是否允许直接在 Apache Beam Google Cloud 数据流作业
EventGrid 与 EventHub
我正在开发一个服务结构应用程序 想要从此应用程序发布一些事件 并在另一个应用程序中订阅或处理这些发布事件 我尝试过 EventGrid 概念 并观察到发布和处理事件时存在延迟 所以 现在我正在寻找其他替代方案 例如 EventHub 或队列
了解 Azure 事件中心分区使用者模式
Azure 事件中心使用分区使用者模式中描述的docs https learn microsoft com en us azure event hubs event hubs features 当涉及到现实世界场景时 我在理解该模型的消费者
Azure
Bigdata
Cloud
IOT
azureeventhub
Azure eventhub 多个分区键指向同一分区
我们正在开发一个多租户应用程序 其中 eventhub 将在不同租户之间共享 我们将在租户之间分配分区 每个租户将在不同的分区上发送消息 我们希望在分区级别对租户进行身份验证 正如 Microsoft 网站上所述 我们根据租户 ID 定义分
Azure
azureeventhub
Azure 事件中心如何处理不同的事件?
不同的事件类型通过主题 队列和消息头的某种组合来区分 在 Kafka 中 记录流仍然被分离为主题 https kafka apache org intro https kafka apache org intro 在浏览 Azure 事件中
Messaging
azureeventhub
将 Azure 事件中心与 Data Lake Store 连接
将数据从事件中心发送到 Data Lake Store 的最佳方式是什么 我假设您希望定期将数据从 EventHub 提取到 Data Lake Store 正如 Nava 所说 您可以使用 Azure 流分析将数据从 EventHub 获
Azure
azureeventhub
azuredatalake
C#:OperationCanceledException:操作已取消
下面我尝试将数据发送到 eventhub 它会工作几分钟 然后操作取消异常被抛出 关于我在使用 CancellationToken 时出错的地方有任何提示吗 如果那是我应该使用的 或者我该如何解决这个问题 public async void
c
asyncawait
azureeventhub
Azure Functions - 事件中心不触发函数
我有一个 Azure 基础架构 2 个 HTTP 函数 gt 事件中心 gt 2 个函数 gt 表存储 因此两个 http 函数将消息发送到事件中心 以及两个由事件中心中的消息触发的函数 其中之一将消息保存在表存储中 基础结构每天由 Azu
Azure
azurefunctions
azureeventhub
azurefunctionsruntime
尝试使用 java EventHubClient API 将事件发送到 Azure 事件中心时出现“连接中止”错误
我正在尝试编写一个java发布程序 以向事件中心发送一条消息 但是 当我尝试执行它时 我收到连接中止错误 我正在使用下面的链接 azure eventhubs 和0 9 0版本中指定的maven依赖项下面是我试图遵循的链接和主要方法 htt
Java
Azure
azureeventhub
Azure 函数的多个触发器
我们有一个带有事件中心触发器的 Azure 函数 是否可以在同一 Azure Function 的多个事件中心上设置触发器 不 目前不支持这种情况 来自评论 Ling Toh Jan 18 17 at 18 23 没有计划支持每个函数多个触
Azure
azurefunctions
azureeventhub
Azure 函数在 azure 门户上显示 0 次执行
我是一个蔚蓝新手 我的设置如下 我有一个 IoT 中心 一个事件中心 一个 Azure 函数 其想法是将消息发送到 IoT 中心 根据某种消息类型将它们路由到事件中心 并使用该函数处理这些事件 我创建了一个示例控制台应用程序 用于将消息从我
azurefunctions
azureiothub
azureeventhub
并非所有实例都在 Azure 应用服务中运行
我正在使用 Azure 应用服务 它托管使用以下命令从事件中心读取数据的应用程序EventProcessorHost 我分配了 6 个实例 手动缩放 来运行 我检查了指标 CPU Time 在App Service中发现只有5个实例正在运行
Azure
azureeventhub
azureappserviceplans
eventprocessorhost
Azure Function App 不由事件中心触发
大家好 我编写了 Python 函数来处理传入 EventHub 的 JSON 事件 这些事件是由 Debezium 生成的 这部分工作正常 从 Visual Studio Code 本地执行时 我的 python 代码也运行良好 当我部署
python
Azure
azurefunctions
eventtrigger
azureeventhub
我可以更改 Azure Function Event Hub 触发器启动检查点吗?
当我使用新的消费者组建立一个新的 Azure Function 来侦听我们的事件中心时 它会获取曾经发送到事件中心的所有消息 甚至是几个月前的消息 我认为将集线器上的消息保留设置为一天会限制这一点 但显然不是 不管怎样 我真的只希望新的 A
azurefunctions
azureeventhub
是否可以在不使用实际事件中心的情况下在本地执行事件中心触发的 Azure Functions?
我只是想问是否可以纯粹在本地计算机上执行 Azure 函数 事件中心触发器 而不依赖于任何 Azure 事件中心资源 我一直在关注 Microsoft 在本地开发 Azure Functions 的流程 Link https learn m
Azure
azurefunctions
azureeventhub
如何在本地调试EventHubTrigger?
我正在尝试在本地调试 Azure 函数 这是一个EventHubTrigger 问题是我需要在本地调试代码 因为我仍然没有 真实 设置 我的代码目前如下所示 public static class Notificator FunctionN
Azure
azurefunctions
azureeventhub
如何从 ADLS 将自定义数据帧写入 eventhub
我想将自定义数据框写入 eventhub val customDf spark read json path to json EventHub ConnectionString val connectionString new com mi
Azure
scala
apachespark
apachesparksql
azureeventhub
1
2
»