如何将消息重定向到死信队列Azure服务总线

2023-12-13

我正在使用隔离的天蓝色函数从队列接收消息。我需要验证收到的消息,如果无效,则将其发送到死信队列。我发现唯一的方法是抛出异常,重试 10 次后,消息将被移至死信队列。当然这不是一个好的解决方案。也许有人面临同样的任务?谢谢!

 [Function("Example")]
 public async Task ExampleAsync([ServiceBusTrigger("example", Connection = "ServiceBusConnection")] string entityId)
 {
     if (!int.TryParse(entityId, out var id))
     {
         // TODO: Move to dead-letter queue
     }
 }  

如果您正在使用进程内工作程序,则可以通过绑定到死信ServiceBusMessageActions在你的函数中然后调用它DeadLetterMessageAsync方法。这还需要您绑定到ServiceBusMessage而不仅仅是string entityId.

例如:

[FunctionName("BindingToMessageActions")]
public static async Task Run(
    [ServiceBusTrigger("<queue_name>", Connection = "<connection_name>")]
    ServiceBusReceivedMessage message,
    ServiceBusMessageActions messageActions)
{
    if (!int.TryParse(message.Body.ToString()), out var id))
    {
        await messageActions.DeadLetterMessageAsync(message);
    }
}

更多示例可以在包中找到README.

不幸的是,这在隔离进程模型中尚不可用。

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

如何将消息重定向到死信队列Azure服务总线 的相关文章

随机推荐

  • Haskell 继承、数据、构造函数

    所以我想为我的小行星游戏 作业定义多个数据类 data One One oneVelocity Velocity onePosition Position other properties unique to One data Two Tw
  • 如何在C#中从mysql结果中读取某些数据

    我想从 C 对 mysql 进行某些查询 这样我就可以返回例如姓名和姓氏 我不知道如何在 C 中处理这个问题 我想尽量减少 SQLinjection 这是我的代码 con new MySqlConnection server localho
  • 无法加载实体框架提供程序类型“Oracle.ManagedDataAccess.EntityFramework”

    我正在尝试在 MVC 应用程序中使用 Entity Framework v6 使用 Oracle Data Provider NET ODP NET 连接到 Oracle 我从这里安装了 ODP NET https www nuget or
  • 根据 WooCommerce 中的产品类别自定义“缺货”文本

    每件缺货产品都显示 缺货 有很多functions php覆盖文本的脚本 但我只是尝试覆盖特定于 类别 A 的文本 或者如果我知道类别 id 编号 那也可以工作 我找到了这个脚本 但它只允许您修改每个产品 ID 的 txt add filt
  • 视图内的 Rails 布局名称

    如何打印视图中当前布局的名称 Example puts controller current layout Thx 这适用于 Rails 3 0 7 controller send layout 显然 这是一种私有方法 因此使用时需要您自担
  • VHDL:IEEE std_logic 库中的真值表

    我研究了 IEEE 如何定义其库 当我打开的时候标准逻辑库 我看到了一些被定义为常数的真值表 我不知道真值表是如何运作的 请解释如何使用真值表返回结果 这是我找到的 AND 门 TYPE stdlogic table IS ARRAY st
  • SQL 创建 UDF 计算列

    我尝试创建一个计算列 但由于其中一列位于另一个表中 我知道我需要创建一个 udf 这是 ERD 的链接 以便您可以查看其中的关系 http imageshack us photo my images 23 databaseassignmen
  • 如何使用Androidfragmentmanager传递变量[重复]

    这个问题在这里已经有答案了 我有以下简单的代码可以在内容框架中从一个片段切换到另一个片段 在下面的代码中是否有一种简单的方法来传递变量 FragmentManager fm getActivity getFragmentManager fm
  • 试图理解这个简短的汇编指令,但我不明白

    我们有一个任务 给定的是 2 寻址的汇编指令 机器 mov 202 100 r1 记下替代此的最小汇编指令序列 说明 见上文 where n rx 按后增量索引的寄存器 n 是索引值 rx 是寄存器 x 单个数值 直接寻址 存储 我们应该使
  • 如何在 TypeScript 中设置类型参数的下限?

    在 TypeScript 我的版本 2 1 1 中 可以为类型参数设置上限 如下所示 class Animal class Cat extends Animal class Kitten extends Cat function foo a
  • 存储 bcrypt 哈希值

    根据 PHP 的文档 bcrypt salt 是由 2a 两位数的成本参数 以及字母表中的 22 位数字 0 9A Za z 因此 如果我使用 crypt 函数对我的密码进行哈希处理 则结果输出包括前 7 个字符 2a 10 如果 10 是
  • WindowsFormsHost 上的工具栏覆盖

    我有一个嵌入在 WPF 窗口内的 WindowsFormsHost 控件中的 SWF 对象 我想在 swf 影片上添加一个工具栏 我下面的代码片段的问题是 当新的子控件添加到主机控件时 或者加载电影 我还没有弄清楚是哪一个 工具栏实际上是不
  • Grails:Spring Security CAS 在 2.2.3 中工作,但在 2.3.0 中不起作用

    我有一个使用 Groovy 2 0 的 Grails 2 2 3 项目 我使用 Spring Security 将其设置为使用 CAS 进行身份验证 使用 LDAP 进行用户角色 当我运行应用程序时 一切都按预期进行 任何人都允许访问 ap
  • 当选择另一个复选框时,如何启用/禁用复选框?

    我了解了如何在选中一个复选框时选中 取消选中或隐藏 显示 但我正在寻找的是当用户单击 快餐 时 当我有 5 个复选框 快餐 餐饮 外带 送货 和 酒吧 时 当用户选中时 其余复选框将被禁用餐饮 休息被禁用 但当用户选中 携带 时 仅快餐和餐
  • imagettftext() - 找不到字体位置

    我正在使用 imagettftext 函数创建自定义验证码脚本 我已在运行 PHP 版本 5 3 8 的 PC 上成功运行并测试了代码 但是当我上传到运行 PHP 版本 5 2 17 的共享托管帐户时 出现以下错误 Warning imag
  • window.fullScreen=true 不起作用

    我想以全屏模式打开我的 html 页面 我尝试在 body 的 onload 事件处理程序中执行此 javascript window fullScreen true 但不幸的是这似乎不起作用 有没有其他方法可以达到同样的效果 我不认为你可
  • Identity列增量值差距巨大

    我创建了一个带有标识列的表 当我在该表中插入值时 标识列显示值之间存在巨大的增量差距 身份值从 6 跳到 10001 这是按部门 id 排序的输出 输出截图在这里 这是我创建的表 Create Table STG2 Department D
  • 更改 Eclipse 中的默认 XML 编辑器

    Eclipse 挂起时使用 XML 默认编辑器太慢并且会出现很多问题 我读到 如果我们更改编辑器 它就可以正常工作 那么如何删除现有编辑器 您可以自定义它们 窗口 gt 首选项 gt 常规 gt 编辑器 gt 文件关联 在那里 您必须选择一
  • jqGrid 中使用工具栏搜索默认在列中间搜索

    阅读 jqGrid wiki 后 并以以下示例为例 jqGrid 中不区分大小写的搜索 包括隐藏字段 我找不到我想做的事情 是否有任何搜索选项可以在列中的任何位置启用搜索 自动通配符 如果该列包含 Apple Iphone 我将能够通过搜索
  • 如何将消息重定向到死信队列Azure服务总线

    我正在使用隔离的天蓝色函数从队列接收消息 我需要验证收到的消息 如果无效 则将其发送到死信队列 我发现唯一的方法是抛出异常 重试 10 次后 消息将被移至死信队列 当然这不是一个好的解决方案 也许有人面临同样的任务 谢谢 Function