有没有办法使用Java中的Azure Functions的@EventHubTrigger来获取事件(EventHub)的标题数据?

2024-06-22

我有一个使用 azure-functions-java-library 实现的 Azure 函数,它从一个 EventHub 接收事件,并且我正在使用 @EventHubTrigger,问题是我需要来自事件的标头数据,但我看不到任何方法来获取这个,我已经阅读了文档,但什么也没有。我需要这个的原因是因为我从 EventHub 接收具有不同 Avro 模式的事件,所以我需要区分它们以便解析它。

我真的很感激一些帮助。


是的,您可以通过添加@BindingName("Properties")例如,对方法参数进行注释。这里需要注意的是,您可以使用绑定到事件的任何元数据结合表达 https://learn.microsoft.com/en-us/azure/azure-functions/functions-bindings-event-hubs-trigger?tabs=java#event-metadata。在本例中,它是“属性”。另外,基数应该是 1。

@FunctionName("EventHubExample")
    public void logEventHubMessage(
        @EventHubTrigger(name = "message", eventHubName = "test", connection = "AzureEventHubConnection", consumerGroup = "$Default", cardinality = Cardinality.ONE, dataType = "string") 
        String message,
        final ExecutionContext context,
        @BindingName("Properties")
        Map<String, Object> properties) {            
        context.getLogger().info("Event hub message received: " + message + ", properties: " + properties);
    }

I used Service Bus Explorer as Event Sender to set metadata of the event as below and was able to see those in the consumer side using above code in "Properties" binding. enter image description here

注意: C# 函数 SDK 在这方面比 Java 有优势。在 C# 中,您可以获取整个 Event 对象,在获取输入中的多个事件时,可以更轻松地直接导航元数据。但不幸的是,目前在 Java SDK 中这是不可能的,您必须使用单一基数单独绑定。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

有没有办法使用Java中的Azure Functions的@EventHubTrigger来获取事件(EventHub)的标题数据? 的相关文章

  • 有没有办法获取 JList 中的所有元素?

    我想知道是否有一种方法可以检索已添加到 JList 的所有元素的列表 例如 我希望 JList 从自定义单元格渲染器返回字符串或 JLabels 的数组或列表 您可以使用getModel http docs oracle com javas
  • 在记录活动中使用 readConfiguration 方法

    为了在小型 Java 桌面应用程序中使用日志记录 我试图深入了解一些方法的操作 我使用一个非常愚蠢的小Java程序来测试它们 特别是 在测试 LogManager readConfiguration 方法的行为时 我发现了一些奇怪的事情 在
  • 从 ArrayList Java 中的 HashMap 键中检索所有值

    美好的一天 这让我现在有点困惑 大脑冻结 并且似乎遗漏了一些东西 有一个 ArrayList 我用 HashMap 填充它 现在我放入 HashMap 和 arraylist Map put DATE value1 Map put VALU
  • 单击按钮时更改照片

    import javax swing Icon import javax swing ImageIcon public class Stage1 extends javax swing JFrame int score 0 int iter
  • 在Java中,为什么equals()和hashCode()必须一致?

    如果我重写类上的任一方法 它必须确保如果A equals B true then A hashCode B hashCode也一定是真的 有人可以给我看一个简单的例子 如果违反了这一点 就会导致问题吗 我认为这与您是否使用该类作为 Hash
  • 在java中将HTML转换为RTF?

    我需要将 HTML 转换为 RTF 我正在使用以下代码 private static String convertToRTF String htmlStr OutputStream os new ByteArrayOutputStream
  • Linux 上的 JavaFX

    Linux x86 和 x64 上的 JavaFX 情况如何 JavaFX 应用程序可以在 Linux 操作系统上顺利执行吗 我发现了 2011 年和 2012 年的一些问题 当时应用程序不稳定 目前发布的 JFX 版本是 2 2 4 在
  • java中简单程序中的“未为类型定义方法”错误

    所以我只是想学习 Java 在观看了一些教程并阅读了一些基本内容之后 我对为什么它无法运行感到困惑 package Test public class TestProg public static void main String args
  • Azure 服务总线:什么是“请求”和“消息”?

    在 Microsoft Azure 中 在服务总线下 您可以看到不同队列 主题等的活动图 该图显示了各种不同的线 例如收到的消息 传出消息 成功请求 etc 什么是Request 什么是Message 请求似乎不断发生 并且通常远远大于消息
  • Run As JUnit 未出现在 Eclipse 中 - 使用 JUnit4

    我正在尝试为我的 Web 应用程序编写 JUnit4 测试 它们之前一直工作正常 但是 现在当我尝试通过右键单击类文件 gt Run As gt JUnit Test 来运行测试时 我看不到该选项 我认为这可能是因为一位同事意外提交了一些
  • 无法在 PHP 中接收 JSON POST 请求

    我正在将 JSON 对象从 Java 传递到 PHP 我正在使用 jdk 1 8 和 WAMPserver 下面是Java代码 import java io IOException import org apache http client
  • 获取 Spring Boot 中当前活动数据源的引用

    我想通过实现数据库数据初始化DataSourceInitializer 我将这些方法放在我的 Spring Boot 主方法下面 但似乎它根本没有被执行 我尝试故意删除字符只是为了触发一个错误来确认执行 什么也没有发生 Configurat
  • 将 Tango 3D 点投影到屏幕 Google Project Tango

    Project Tango 提供了点云 如何获取点云中 3D 点的像素位置 以米为单位 我尝试使用投影矩阵 但得到的值非常小 0 5 1 3 等 而不是 1234 324 以像素为单位 我包含我尝试过的代码 Get the current
  • 控制台中的 Java msg - 两个方法具有相同的方法签名但不提供可分配的类?

    在迁移到 java 1 8 时 我升级了项目中的许多依赖项 它是基于spring 4 3的应用程序 有很多外部依赖 例如 JMS HTTP客户端 FTP XML等 当应用程序启动时 我现在在控制台中收到以下消息 两个方法具有相同的方法签名但
  • Scala 不可变 Map 速度慢

    当我创建地图时 我有一段代码 val map gtfLineArr 8 split map split collect case Array k v gt k v toMap 然后我使用这张地图来创建我的对象 case class MyOb
  • JPA2+Hibernate 3.6.0 中的 JTA 还是 LOCAL 事务?

    我们正在重新思考我们的技术堆栈 以下是我们的选择 由于应用程序的复杂性等 我们不能没有 Spring 和 Hibernate 我们还从 J2EE 1 4 迁移到 Java EE 5 技术栈 Java EE 5 JPA 2 0 我知道Java
  • GridLayout 中的 JLabel

    如何添加JLabel出于GridLayout 我有一个 8x8 网格布局 Container content getContentPane content setLayout new GridLayout 8 8 2 2 for int f
  • Java:当计时器处于活动状态时,JSplitPane 将顶部面板的内容复制到底部面板

    所以我有一个 JSplitPane 和两个 JPanel 一个在顶部 一个在底部 在这两个面板中 我重写了paintComponent方法并添加了我自己的图形 在底部面板中 我想添加动画 当面板不重新绘制时 这很好 但是一旦计时器 java
  • Java中ThreadFactory的使用

    有人可以简要解释一下如何以及何时使用 ThreadFactory 吗 使用和不使用 ThreadFactory 的示例可能确实有助于理解差异 Thanks 这是一种可能的用法 假设您有一个ExecutorService它执行你的Runnab
  • 从 google play 中提取统计信息

    我正在建立一些统计数据 并希望获得来自 google play 应用程序商店 的统计数据 最受欢迎 下载量 价格等信息 有谁知道是否有这个 API 或者我必须自己抓取它 有一个名为 android market api 的项目http co

随机推荐

  • 在 Selenium Webdriver 中何时使用显式等待与隐式等待?

    我在用 driver manage timeouts implicitlyWait 180 TimeUnit SECONDS 但对于以下元素它仍然连续失败 driver findElement By id name clear driver
  • C 中的 malloc 可以有多大?

    我在 C 中有一个 malloc 它是 26901 2 sizeof double 这让我思考这里的最大价值是多少 另外 定义宏来访问这个二维数组时会遇到任何问题吗 define DN i j int i ny int j 因为这似乎对我不
  • 如何为 PostgreSQL 构建系统

    为 MS SQL Server 构建系统很简单 cmd sqlcmd S i file selector source sql shell true 对于 PostgreSQL 我尝试了这个 env PGPASSWORD password
  • 需要重写的虚拟函数来调用基本实现

    在 C 类层次结构中 是否可以强制要求特定虚拟函数也始终调用其基类的实现 就像构造函数链的方式一样 我正在研究一种情况 其中深层类层次结构具有一些每个子级都会重写的通用接口函数 我希望每个派生类的重写都链接到基类 明确地执行此操作很简单eg
  • NSCondition 是如何工作的?

    我在这个意义上使用 NSCondition 类 void method1 cocoaCondition lock lock while someCheckIsTrue cocoaCondition wait Do something coc
  • 对于同一文件描述符,可以从两个线程并行调用 fwrite 和 fclose 吗?

    如果会发生什么fwrite fclose从两个线程并行调用同一文件描述符 POSIX 要求FILE访问是线程安全的 但是因为fclose关闭文件并使指针无效 没有办法使用 即 这不仅仅是一个规范问题 而且是一个永远无法 修复 或消失的基本
  • 多行 overrideValues Helm 安装 Azure DevOps

    是否可以指定要在 Azure devOps 管道中的 HelmDeploy 任务中覆盖的值 例如 类似下面的任务 显然不完全按原样工作 task HelmDeploy 0 displayName helm install inputs co
  • 如果断言失败则停止测试

    我有一个简单的赛普拉斯测试 describe My First Test gt it Go to login page gt cy visit http localhost 3000 cy contains Log in click it
  • 在 AngularJS 中从 Firebase 实时更新信息

    我使用 Angular JS 从 Firebase 制作了一个显示信息的应用程序 目前 刷新页面后信息会更新 但我想实时更新我的 信息 这是我的角度代码 var root angular module root services fireb
  • R 中 data.table 的聚合

    该练习包括通过 R 中的 data table 的因素组合来聚合数值向量 以以下数据表为例 require data table require plyr dtb lt data table cbind expand grid month
  • Multidex安装失败

    我正在使用 CircledImageView 库 它在棒棒糖 Android 版本上运行良好 但在 Kitkat 中 它崩溃了 于是在google上搜索之后 我发现我必须在我的应用程序中实现 multidex 这是我的应用程序类 publi
  • 类的方法之间的区别,哪些是“函数”,哪些是“绑定方法”?

    我做了一些实验 通过检查 dict 对于类或实例 我可以看到某些方法具有类型function还有一些bound method 实验很乱 下面的问题我都想不出来 在Python 3中 类或实例的方法之间有什么区别 哪些是 函数 哪些是 绑定方
  • “ListView”已从 React Native 中删除

    我的模拟器说 ListView 已从 React Native 中删除 是的 它自 2017 年 3 月版本以来已被删除 您无法再使用它 来自docs https facebook github io react native blog 2
  • 计算指定窗口内的滚动计数

    示例数据可能比解释它更有助于解释我正在尝试做的事情 所以我将从它开始 这是我目前正在使用的数据 CallStart CallDuration 2017 09 15 09 15 15 313 00 01 28 2017 09 15 09 15
  • AWS:在 Redshift 中自动查询

    我想自动化每天运行的 redshift 插入查询 我们实际上使用的是aws环境 有人告诉我使用 lambda 不是正确的方法 这是在 Redshift 中自动执行查询的最佳 ETL 流程 要在 Redshift 上自动化 SQL 您有 3
  • Angular 7:将 HTML 转换为 PDF

    我正在尝试将 HTML 表格转换为 PDF 但没有成功 我已经使用 jsPDF 来做到这一点 但结果非常差 我试图理解为什么 考虑到我有一台平板电脑 我想要的是将此表以横向模式打印在 A4 页面上 使用所需的所有页面 我的问题是 PDF 是
  • 将 NSPoint 从窗口坐标转换为视图坐标

    我的应用程序有一个自定义视图 显示事件的时间线 该视图包含在NSScrollView支持时间线的水平滚动 使用通知 我实现了一种机制 该机制应该显示另一个自定义视图 当用户在时间线中单击该事件时 该视图会显示有关该事件的详细信息 下面是时间
  • Laravel 5.2:如何从自己的事件监听器访问请求和会话类?

    In Laravel 5 2 我添加了我的事件监听器 到app Providers EventServiceProvider php like protected listen Illuminate Auth Events Login gt
  • 如何使用Python从网页下载文本文件或某些对象?

    我正在编写一个函数 用于下载并存储今天的预发布域 txt 文件列表http www namejet com pages downloads aspx http www namejet com pages downloads aspx 我正在
  • 有没有办法使用Java中的Azure Functions的@EventHubTrigger来获取事件(EventHub)的标题数据?

    我有一个使用 azure functions java library 实现的 Azure 函数 它从一个 EventHub 接收事件 并且我正在使用 EventHubTrigger 问题是我需要来自事件的标头数据 但我看不到任何方法来获取