检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
移动云RocketMQ版 本章节介绍在事件流里添加移动云 RocketMQ版事件源的方法。 目前支持region：上海二 前提条件 已在移动云购买RocketMQ实例。 当源端为移动云RocketMQ时，目标端只支持选择FunctionGraph（函数计算）。 创建移动云 RocketMQ版事件源
服务RocketMQ版事件源其状态为“创建失败”或“异常”，可能是以下原因导致： 未创建私网访问端点。 检查是否创建所需私网访问端点，其VPC及子网需要与RabbitMQ或RocketMQ实例配置相同，具体步骤，请参考创建私网访问端点。 用户default安全组规则配置不正确。
consumer_max_wait Integer 批量消费最大等待时长，单位：秒 最小值：0 最大值：450 缺省值：5 vpc_id String 虚拟私有云 subnet_id String 子网 表10 SourceCommunityMQParameters 参数 参数类型 描述
consumer_max_wait Integer 批量消费最大等待时长，单位：秒 最小值：0 最大值：450 缺省值：5 vpc_id String 虚拟私有云 subnet_id String 子网 表8 SourceCommunityMQParameters 参数 参数类型 描述
consumer_max_wait 否 Integer 批量消费最大等待时长，单位：秒 最小值：0 最大值：450 缺省值：5 vpc_id 否 String 虚拟私有云 subnet_id 否 String 子网 表7 SourceCommunityMQParameters 参数 是否必选
consumer_max_wait 否 Integer 批量消费最大等待时长，单位：秒 最小值：0 最大值：450 缺省值：5 vpc_id 否 String 虚拟私有云 subnet_id 否 String 子网 表7 SourceCommunityMQParameters 参数 是否必选
Topic 选择Topic。先选目标连接以加载Topic选项。 消息Key配置 关闭 不启用消息Key。 开启 变量：从CloudEvents标准事件中获取变量值，将变量值作为Key值。 常量：将指定的常量作为key值。若选择常量，所有消息将发送至同一分区。 规则配置 类型 变量：data
权限 权限名称 描述 VPC Administrator 目标连接功能需要使用函数工作流服务打通用户VPC网络，需要用户必须为函数工作流服务配置具备VPC管理权限的委托。 DNS ReadOnlyAccess 目标连接功能需要使用函数工作流服务打通用户VPC网络，需要用户必须为函
检查事件流集群创建页面中配置的vpc和子网是否与源端Kafka实例网络畅通。 原因二：无法连接源端Kafka实例，请检查填写的实例信息是否正确。 解决方案： 进入Kafka的控制台页面，检查源端实例状态是否正常。 检查事件流集群创建页面中配置的vpc和子网是否与源端Kafka实例网络畅通。
检查事件流集群创建页面中配置的vpc和子网是否与源端RocketMQ实例网络畅通。 原因二：无法连接源端RocketMQ实例，请检查填写的实例信息是否正确。 解决方案： 进入RocketMQ的控制台页面，检查源端实例状态是否正常。 检查事件流集群创建页面中配置的vpc和子网是否与源端实例网络畅通。
ault 最小长度：1 最大长度：128 description 否 String 目标连接描述 最大长度：255 vpc_id 是 String 待连接的VPC ID 最大长度：128 subnet_id 是 String 待连接的子网ID 最大长度：128 type 否 String
endpoint名称，租户下唯一，由字母、数字、点、下划线和中划线组成，必须以字母或数字开头 最小长度：1 最大长度：128 vpc_id 是 String 访问端点所在的VPC的ID 最大长度：64 subnet_id 是 String 访问端点所在的子网的ID 最大长度：64 description
指定查询访问端点的类型 枚举值： PRIVATE PUBLIC name 否 String 指定查询访问端点的名称 vpc_id 否 String 指定查询访问端点的vpcId fuzzy_name 否 String 指定查询访问端点的名称,模糊查询 subnet_id 否 String
√ 删除访问端点 √ × × × 查看访问端点 √ × √ √ 发布事件到事件通道 √ √ × √ 当涉及到访问端点时，需要配置额外权限：VPCEndpoint Administrator。 EG CommonAccess权限能满足基本使用场景。 表3 额外权限参数 配置 权限 当
EG.00513005 invalid channel 事件通道不可用 请重新选择事件通道 400 EG.00513006 vpc CONFLICT 该VPC已创建内网访问端点 请无需重复创建 400 EGS.00516010 压缩包格式错误，非ZIP格式。 压缩包格式错误，非ZIP格式。
CREATING CREATED CREATE_FAILED error_info ErrorInfo object vpc_id String 待连接的VPC ID subnet_id String 待连接的子网ID agency String 私网目标连接使用的用户委托名称 flavor
CREATING CREATED CREATE_FAILED error_info ErrorInfo object vpc_id String 待连接的VPC ID subnet_id String 待连接的子网ID agency String 私网目标连接使用的用户委托名称 flavor
响应Body参数 参数 参数类型 描述 id String 访问端点ID name String 用户指定的访问端点名称 vpc_id String 访问端点所在的VPC的ID subnet_id String 访问端点所在的子网的ID domain String 访问域名 description
已购买分布式消息服务RabbitMQ版实例，实例中存在消息队列Queue，且实例状态处于“运行中”。具体步骤，请参考购买实例。 已创建私网访问端点，其VPC及子网与RabbitMQ实例相同。 已正确配置default安全组和RabbitMQ实例所属的安全组规则，具体规则请参考创建事件源如何配置安全组。
CREATING CREATED CREATE_FAILED error_info ErrorInfo object vpc_id String 待连接的VPC ID subnet_id String 待连接的子网ID agency String 私网目标连接使用的用户委托名称 flavor
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
