【问题标题】:Azure storage account queue get new messages arrived (Ideally Logic App)Azure 存储帐户队列获取新消息到达(理想的逻辑应用程序)
【发布时间】:2021-04-24 02:50:22
【问题描述】:

我正在尝试设计一个逻辑应用程序,当消息到达或被中毒队列(位于 azure 存储帐户中)接收时,它会发布到松弛通道。

我知道如何做 slack 部分,我可以让触发器在位于我的服务总线资源中的队列上触发,因为 azure 逻辑应用程序包含用于此的触发器。

但是,当消息到达或在队列中接收时,我看不到存储帐户中队列的 Azure 逻辑应用触发器。

我的问题是:当消息到达这些存储帐户队列时,我可以利用触发器或其他过程吗?如果没有,当数据(消息和消息内容)到达存储帐户中的毒队列时,获取该数据(消息和消息内容)的最佳方法是什么,然后获取该信息并将该信息扔到松弛通道中?

“存储帐户”队列上是否有一个触发器(用于逻辑应用),可以在收到消息时触发?(我看到长度,并扫描队列中的所有消息)

我在“服务总线”队列中找到了触发此事件的触发器。

这些是我为“服务总线队列”找到的触发选项:https://i.stack.imgur.com/nS0nu.png

这些是我为“存储帐户队列”找到的触发选项:https://i.stack.imgur.com/AqxB4.png

理想情况下,我只想配置一个简单的逻辑应用程序,当队列消息到达存储帐户中的毒队列时,然后将信息放入 slack,我知道如何通过服务总线队列中的逻辑应用程序将信息放入 slack 但还没有能够弄清楚如何设置将消息传递给 slack 的操作,因为我不知道在收到消息时如何做,我可以将其设置为作业并获取队列的长度和所有项目队列,但在到达时不会触发,因为我找不到触发。

如果我无法弄清楚或者无法完成,我可能会在 Azure 函数上启动逻辑应用程序和 Azure 队列存储触发器,这似乎是 MS 希望我们做的还是去做吧。

https://docs.microsoft.com/en-us/azure/app-service/webjobs-sdk-how-to ctrl+f “绑定参考信息”,然后查看子标题“用法:您可以绑定到的类型以及有关绑定如何工作的信息。例如:轮询算法、毒队列处理。”

再次感谢大家的投入,谢谢!

【问题讨论】:

    标签: azure asp.net-core .net-core azure-functions azure-logic-apps


    【解决方案1】:

    根据一些测试,在我这边使用“When a specified number of messages are in a given queue”触发器可以正常工作。当我向队列中添加一条名为 myqueue-items-poison 的消息时,逻辑应用触发成功。

    所以请检查您是否正确配置了触发器。

    请检查是不是你设置的触发间隔太长了,我设置的是1分钟。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2020-12-12
      • 1970-01-01
      • 1970-01-01
      • 2018-01-29
      • 2015-12-13
      • 1970-01-01
      相关资源
      最近更新 更多