检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
状态码 错误码 错误信息 描述 处理措施 400 EG.00513000 invalid parameters 参数错误 请检查参数是否正确 400 EG.00513001 name duplicated 命名重复 请重新输入新名称 400 EG.00513002 invalid
区域:与事件网格所在区域保持一致 桶名称:输入“eg-test” 默认存储类别:选择“标准存储” 桶策略:选择“私有” 默认加密:不勾选 归档数据直读:选择“关闭” 企业项目:选择“default” 图4 创建桶 单击“立刻创建”,根据提示信息完成桶的创建。
图1 配置事件源 参考表1,填写事件源的配置信息。 表1 分布式消息服务RocketMQ版参数说明 参数名称 说明 事件提供方 选择分布式消息服务 RocketMQ版。 实例 请选择实例。 Group 请输入消费组。 Topic 请输入Topic。
Kafka实例未创建消费组时,事件流启动用后,Kafka实例会自动创建输入的消费组,详情请参见查看Kafka消费组信息。 Kafka实例已创建消费组时,此处输入创建好的消费组名称即可,详情请参见创建Kafka消费组。 并发数 输入并发数,输入值范围1~1000。
规则配置 类型 变量:data.value 如果需要了解更多转换类型的信息,请参考事件内容转换。 消息推送 批量推送 配置是否开启批量推送,批量推送可帮您批量聚合多个事件。
objects 访问端点终端节点列表 表5 ErrorInfo 参数 参数类型 描述 error_code String 错误码 最小长度:1 最大长度:128 error_detail String 错误详情 最小长度:1 最大长度:128 error_msg String 错误信息
objects 访问端点终端节点列表 表6 ErrorInfo 参数 参数类型 描述 error_code String 错误码 最小长度:1 最大长度:128 error_detail String 错误详情 最小长度:1 最大长度:128 error_msg String 错误信息
发布区域:华北-北京四、华东-上海一、华东-上海二 目标连接 访问端点 事件监控 事件网格实现了对事件订阅和事件通道的监控,用户无需任何配置,即可查询事件投递和事件接入的监控信息。
参考图2,填写自定义事件源的配置信息。 事件源类型:下拉框选择。 事件源名称:自定义,例如输入“egsdk-source”。 描述:自定义。 图2 创建自定义事件源 单击“确定”,完成自定义事件源的创建。 创建成功后,在“自定义事件源”页签,查看创建的事件源。
状态 枚举值: CREATED ENABLED DISABLED FROZEN ERROR channel_id String 通道ID channel_name String 通道名称 used Array of SubscriptionUsedInfo objects 标签信息
objects 访问端点终端节点列表 表7 ErrorInfo 参数 参数类型 描述 error_code String 错误码 最小长度:1 最大长度:128 error_detail String 错误详情 最小长度:1 最大长度:128 error_msg String 错误信息
状态 枚举值: CREATED ENABLED DISABLED FROZEN ERROR channel_id String 通道ID channel_name String 通道名称 used Array of SubscriptionUsedInfo objects 标签信息
状态 枚举值: CREATED ENABLED DISABLED FROZEN ERROR channel_id String 通道ID channel_name String 通道名称 used Array of SubscriptionUsedInfo objects 标签信息
状态 枚举值: CREATED ENABLED DISABLED FROZEN ERROR channel_id String 通道ID channel_name String 通道名称 used Array of SubscriptionUsedInfo objects 标签信息
状态 枚举值: CREATED ENABLED DISABLED FROZEN ERROR channel_id String 通道ID channel_name String 通道名称 used Array of SubscriptionUsedInfo objects 标签信息
状态 枚举值: CREATED ENABLED DISABLED FROZEN ERROR channel_id String 通道ID channel_name String 通道名称 used Array of SubscriptionUsedInfo objects 标签信息
状态 枚举值: CREATED ENABLED DISABLED FROZEN ERROR channel_id String 通道ID channel_name String 通道名称 used Array of SubscriptionUsedInfo objects 标签信息
事件源,一个事件流中事件源只有一个 sink EventStreamingSink object 事件目标,一个事件流中只有一个 rule_config rule_config object 事件规则,包括过滤规则和转换规则 option RunOption object 运行时配置信息
事件源,一个事件流中事件源只有一个 sink EventStreamingSink object 事件目标,一个事件流中只有一个 rule_config rule_config object 事件规则,包括过滤规则和转换规则 option RunOption object 运行时配置信息
一个事件流中事件源只有一个 sink 是 EventStreamingSink object 事件目标,一个事件流中只有一个 rule_config 否 rule_config object 事件规则,包括过滤规则和转换规则 option 否 RunOption object 运行时配置信息