当前位置: 首页 > 知识库问答 >
问题:

Azure WebJob Sdk beta 0.5中的ServiceBusTrigger批处理

郑桐
2023-03-14

是否有方法使用新的Azure WebJob Sdk Beta0.5从订阅中检索批消息。我们每秒处理相当多的消息,理想情况下会使用以下语法

共有1个答案

长孙雅志
2023-03-14

不幸的是,这在今天是不可能的。

您想要使用该绑定的场景是什么?

 类似资料:
  • 我有以下工作要处理在一定的时间间隔或特别的基础上。 作业中的步骤如下: 我也想要用户界面,在那里我可以触发一个特别的基础上的工作,而且我应该能够提供参数从用户界面。 我想用Spring batch来完成这个任务,但它更多的是用于读->处理->写之类的工作。这里,在第一步中,我正在生成由第二步读取的数据。我不确定我是否还可以使用Spring batch来实现这个,或者有更好的方法来实现这个。

  • 毒消息处理如何为Azure WebJobs SDK的工作?我正在寻找推送的服务总线队列消息已退出队列超过'x'时间到不同的ServiceBus(或)存储队列 这里和这里的在线留档以及这里的SDK示例没有关于ServiceBusTrigger如何处理有毒消息的示例。这是半成品吗? 我尝试使用参数实现自定义毒药消息处理,但ServiceBurstriggers似乎不支持它,因为我得到了运行时异常

  • 我的Azure函数需要用我的服务总线触发器(主题)定义的连接是什么? 跑步看起来像这样 是ServiceBus的共享访问策略下的策略的连接字符串(endpoint:sb://...)?

  • 我是Spring批处理的新手,我只想问如何从多行结果集中检索数据。我有以下场景: > 有两个不同的表说员工 使用时,我只能创建一个工资单子级,但该表可能有多个子级。请帮助...

  • 我在中看到了几个答案(例如这里),因此建议批次中的记录将成为单个RDD。我对此表示怀疑,因为假设batchInterval为1分钟,那么单个RDD将包含最后一分钟的所有数据? 注意:我不是直接将批次与RDD进行比较,而是将Spark内部处理的批次进行比较。

  • 我正在制作一个应用程序,其中每周一次必须根据系统的所有用户执行多个操作(计算)。最初估计大约有300个用户。 我的问题是,有没有一种方法可以执行这种类型的操作?比如批量处理?现在,我只使用一个用户测试脚本,在本地主机上,我使用foreach循环来循环用户并生成​​所有查询、计算和插入结果。。 我怀疑是否有更多的用户饱和了脚本或托管或类似的东西。。我如何处理这种情况? 欢呼;)