检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
开通事件网格服务并授权 使用事件网格服务前,您需要: 已注册华为账号并开通华为云。 当前登录账号拥有使用事件网格的权限。账号权限授权与绑定,请参考创建用户并授权使用EG。 如果您的账号为IAM用户,请先联系华为云账号拥有者为IAM用户授权,然后才能使用事件网格服务。 登录事件网格控制台
分布式消息服务RocketMQ版 本章节介绍在控制台添加分布式消息服务RocketMQ版自定义事件源的方法。 前提条件 (可选)创建自定义事件源前,需要先创建自定义事件通道。 已购买分布式消息服务RocketMQ版实例,实例中已创建Topic,且实例状态处于“运行中”。具体步骤,请参考购买实例。
String 访问端点所在的子网的ID domain String 访问域名 description String 描述 status String 访问端点状态 枚举值: CREATED CREATING CREATE_FAILED DELETE_FAILED error_info ErrorInfo
华为云服务事件发送流程 本章节介绍华为云服务事件发送的整个流程。 华为云对象存储服务(Object Storage Service,简称OBS)作为云服务事件源将产生的云服务事件发送到事件网格,事件规则对云服务事件进行过滤和转换,通过转换后的事件触发事件目标(即函数工作流服务中的函数)。
分布式消息服务RocketMQ版 本章节介绍在事件流里添加分布式消息服务RocketMQ版事件源的方法。 前提条件 已在分布式消息服务RocketMQ版中购买RocketMQ实例。 当源端为分布式消息服务RocketMQ版时,目标端只支持选择FunctionGraph(函数计算)。
路由到对象存储服务OBS 本章节介绍在创建事件流时如何配置对象存储服务OBS为事件目标。 前提条件 已开通对象存储服务OBS作为事件目标。 事件源选择为“分布式消息服务 Kafka版”。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”
String 访问端点所在的子网的ID domain String 访问域名 description String 描述 status String 访问端点状态 枚举值: CREATED CREATING CREATE_FAILED DELETE_FAILED error_info ErrorInfo
{"Sid":"allow_account_to_put_events","Effect":"Allow","Principal":{"IAM":["domain_id_a", "domain_id_b"]},"Action":"eg:channels:putEvents","Resource":"urn:eg:
华为云官方kafka实例 枚举值: WEBHOOK KAFKA kafka_detail 否 KafkaConnectionDetail object 表4 KafkaConnectionDetail 参数 是否必选 参数类型 描述 instance_id 是 String kafka实例id。
表5 QuotaResourceResp 参数 参数类型 描述 resources Array of QuotaItemInfo objects 错误描述 表6 QuotaItemInfo 参数 参数类型 描述 name String 名称 type String 配额类型 枚举值:
tracking. Format is request_uuid-timestamp-hostname. 表6 响应Body参数 参数 参数类型 描述 failed_count Integer 预校验发布事件失败的个数 sources Array of CheckPutEventsResult objects
String 错误码 最小长度:1 最大长度:128 error_msg String 错误消息 最小长度:1 最大长度:512 error_details String 具体错误消息 最小长度:1 最大长度:1024 request_id String 请求处理ID 最小长度:1 最大长度:128
String 错误码 最小长度:1 最大长度:128 error_msg String 错误消息 最小长度:1 最大长度:512 error_details String 具体错误消息 最小长度:1 最大长度:1024 request_id String 请求处理ID 最小长度:1 最大长度:128
String 错误码 最小长度:1 最大长度:128 error_msg String 错误消息 最小长度:1 最大长度:512 error_details String 具体错误消息 最小长度:1 最大长度:1024 request_id String 请求处理ID 最小长度:1 最大长度:128
String 错误码 最小长度:1 最大长度:128 error_msg String 错误消息 最小长度:1 最大长度:512 error_details String 具体错误消息 最小长度:1 最大长度:1024 request_id String 请求处理ID 最小长度:1 最大长度:128
String 错误码 最小长度:1 最大长度:128 error_msg String 错误消息 最小长度:1 最大长度:512 error_details String 具体错误消息 最小长度:1 最大长度:1024 request_id String 请求处理ID 最小长度:1 最大长度:128
String 错误码 最小长度:1 最大长度:128 error_msg String 错误消息 最小长度:1 最大长度:512 error_details String 具体错误消息 最小长度:1 最大长度:1024 request_id String 请求处理ID 最小长度:1 最大长度:128
目标连接类型。目前支持webhook:http连接;kafka:华为云官方kafka实例 枚举值: WEBHOOK KAFKA kafka_detail KafkaConnectionDetail object created_time String 创建UTC时间 updated_time String 更新UTC时间
目标连接类型。目前支持webhook:http连接;kafka:华为云官方kafka实例 枚举值: WEBHOOK KAFKA kafka_detail KafkaConnectionDetail object created_time String 创建UTC时间 updated_time String 更新UTC时间
数组长度:0 - 100 表5 EventSubMetricsItem 参数 参数类型 描述 fail_num Long 失败数 retry_success_num Long 重试成功数 retry_fail_num Long 重试失败数 retry_times Integer 重试数 timestamp