函数计算

创建消息流出任务

1. 登录云消息队列 RabbitMQ 版控制台，然后左侧导航栏选择消息集成 > 消息流出。

2. 在顶部菜单栏选择地域，如华东1（杭州），然后在消息流出页面，单击创建任务。

3. 在消息流出创建面板，设置任务名称，选择流出类型为函数计算，配置以下信息，然后单击确定。

   1. 在资源配置区域，设置以下参数。

      表 1. 源端消息队列RabbitMQ版参数配置

      参数	说明	示例
      地域	默认选择创建消息流出任务时选择的地域且不可更改。	华东1（杭州）
      RabbitMQ 实例	选择生产消息的源云消息队列 RabbitMQ 版实例。	amqp-cn-******lpc00a
      Vhost	选择源云消息队列 RabbitMQ 版实例的Vhost。	test
      Queue	选择源云消息队列 RabbitMQ 版实例的Vhost。	queue_test

      表 1. 目标端函数计算参数配置

      参数	说明	示例
      服务	选择已创建的函数计算的服务。	service
      函数	选择已创建的函数计算的函数。	test
      执行方式	异步方式：消息都发给函数计算，错误处理由函数计算保证。 同步方式：调用的错误处理及重试由事件总线EventBridge负责。	异步
      批量推送	批量推送可帮您批量聚合多个事件，当批量推送条数和批量推送间隔两者条件达到其一时即会触发批量推送。例如：您设置的推送条数为100条，间隔时间为15 s，在10 s内消息条数已达到100 条，那么该次推送则不会等15s后再推送。	开启
      批量推送条数	一次调用函数发送的最大批量消息条数，当积压的消息数量到达设定值时才会发送请求，取值范围为 [1, 10000]。当批量推送设置为开启时，需要设置此参数。	1
      批量推送间隔	调用函数的间隔时间，系统每到间隔时间点会将消息聚合后发给函数计算，取值范围为 [0,15]，单位：秒。0秒表示无等待时间，直接投递。	10

   2. 在数据处理区域，设置消息的过滤、转换、重试和死信。

      • 消息过滤

        • 无需过滤：默认投递全部事件。

        • 自定义配置：使用事件模式匹配特定事件。详细规则，请参见消息过滤。

      • 重试和死信：配置事件推送失败时的重试策略及错误发生时的处理方式。更多信息，请参见重试和死信。

4. 返回消息流出页面，找到创建好的任务，在其右侧操作列，单击启用。

5. 在提示对话框，阅读提示信息，然后单击确认。

   启用任务后，会有30秒~60秒的延迟时间，您可以在消息流出页面的状态栏查看启动进度。

其他操作

在消息流出页面，找到目标任务，在其右侧操作列，执行其他操作。

• 查看任务详情：单击详情，在消息流出详情页面，查看任务的源端配置、目标端配置及资源信息。
• 编辑任务配置：单击编辑，在消息流出编辑面板，修改资源配置和规则配置。
• 启停任务：单击启用或者停用，然后在提示对话框，单击确认。
• 删除任务：单击删除，然后在提示对话框，单击确认。