本文介绍如何在云消息队列 RocketMQ 版控制台创建流出目标为函数计算的消息流出任务。
前提条件
您已购买并部署云消息队列 Kafka 版实例，且实例处于服务中状态。具体步骤，请参见步骤二：购买和部署实例。
您已开通函数计算服务，具体操作，请参见开通服务。
什么是函数计算？
函数计算（Function Compute，FC）是一个事件驱动的全托管Serverless计算服务，您无需管理服务器等基础设施，只需编写代码并上传，函数计算会为您准备好计算资源，并以弹性、可靠的方式运行您的代码。更多信息，请参见什么是函数计算。
函数计算能做什么？
利用函数实现业务消息的处理，通过函数计算平台开发、运行业务消息处理逻辑，订单处理，任务执行。
利用函数对消息进行快速加工处理，ETL清洗。
利用函数计算灵活扩展将消息转储到指定VPC中的其他下游系统。
利用函数连接消息系统和其他阿里云产品服务，将消息数据发送给其他云服务系统。
创建消息流出任务
登录云消息队列 Kafka 版控制台，在左侧导航栏选择。
在顶部菜单栏选择地域，如华东1（杭州），然后在任务列表页面中，单击创建任务列表。
在创建任务面板，设置任务名称和描述，配置以下参数，单击保存。
任务创建
在Source（源）配置向导，选择数据提供方为消息队列 Kafka 版，设置以下参数，然后单击下一步。
参数
说明
示例
地域
选择云消息队列 Kafka 版源实例所在的地域。
华北2（北京）
kafka 实例
选择生产云消息队列 Kafka 版消息的源实例。
MQ_INST_115964845466****_ByBeUp3p
Topic
选择生产云消息队列 Kafka 版消息的Topic。
topic
Group ID
选择源实例的消费组名称。请使用独立的消费组来创建事件源，不要和已有的业务混用消费组，以免影响已有的消息收发。
GID_http_1
并发配额（消费者数）
选择源实例的消费者数。
1
消费位点
选择开始消费消息的位点。
最新位点
网络配置
选择路由消息的网络类型。
默认网络
专有网络VPC
选择VPC ID。当网络配置设置为自建公网时需要设置此参数。
vpc-bp17fapfdj0dwzjkd****
交换机
选择vSwitch ID。当网络配置设置为自建公网时需要设置此参数。
vsw-bp1gbjhj53hdjdkg****
安全组
选择安全组。当网络配置设置为自建公网时需要设置此参数。
alikafka_pre-cn-7mz2****
批量推送
批量推送可帮您批量聚合多个事件，当批量推送条数和批量推送间隔（单位：秒）两者条件达到其一时即会触发批量推送。
例如：您设置的推送条数为100 条，间隔时间为15 s，在10 s内消息条数已达到100条，那么该次推送则不会等15 s后再推送。
开启
批量推送条数
调用函数发送的最大批量消息条数，当积压的消息数量到达设定值时才会发送请求，取值范围为 [1,10000]。
100
批量推送间隔（单位：秒）
调用函数的间隔时间，系统每到间隔时间点会将消息聚合后发给函数计算，取值范围为[0,15]，单位为秒。0秒表示无等待时间，直接投递。
3
在Filtering（过滤）配置向导，设置数据模式内容过滤发送的请求。更多信息，请参见消息过滤。
在Transform（转换）配置向导，设置数据清洗，实现分割、映射、富化及动态路由等繁杂数据加工能力。更多信息，请参见数据清洗。
在Sink（目标）配置向导，选择服务类型为函数计算，配置以下参数。
参数
说明
示例
服务
选择已创建的函数计算的服务。
test
函数
选择已创建的函数计算的函数。
test
服务版本和别名
选择服务版本或服务别名。
默认版本
执行方式
选择同步执行或异步执行。
异步
事件
选择事件内容转换类型。更多信息，请参考事件内容转换。
完整事件
任务属性
设置此任务的重试策略及死信队列。更多信息，请参见重试和死信。
返回任务列表页面，找到创建好的任务，在其右侧操作列，单击启用。
在提示对话框，阅读提示信息，然后单击确认。
启用任务后，会有30秒~60秒的延迟时间，您可以在任务列表页面的状态栏查看启动进度。
其他操作
在消息流出页面，找到目标任务，在其右侧操作列，执行其他操作。
查看任务详情：单击详情，在消息流出详情页面，查看任务的源端配置、目标端配置及资源信息。
编辑任务配置：单击编辑，在消息流出编辑面板，修改资源配置和规则配置。
启停任务：单击启用或者停用，然后在提示对话框，单击确认。
删除任务：单击删除，然后在提示对话框，单击确认。
- 本页导读 （1）