事件源-华为云

事件网格 EG-云服务事件源:云服务事件源列表

云服务事件源列表事件网格支持的云服务事件源列表如下：表1 云服务事件源云应用引擎 CAE 数据库和应用迁移 UGO Classroom 内容审核 Moderation 虚拟私有云 VPC 代码检查 CodeCheck 云数据库 GaussDB NoSQL GaussDB API网关 APIG 数据仓库服务 DWS 部署 CloudDeploy 统一身份认证 IAM 事件网格 EG 华为云 U CS 弹性文件服务 SFS CloudIDE 人脸识别 FRS 微服务引擎 CSE 云专线 DC 数据可视化 DLV NAT网关 NAT 云桌面 Workspace 设备接入服务 IoTDA 分布式消息服务 DMS 知识图谱 KG IoT边缘 IoTEdge 云日志服务 LTS 编译构建 CloudBuild 对象存储迁移服务 OMS 云备份服务 CBR 消息&短信服务 MSG SMS 弹性公网IP EIP 云审计服务 CTS 云搜索服务 CSS 视频分析服务 VAS 数据管理服务 DAS 裸金属服务器 BMS 云测 CloudTest VPC终端节点 VPCEP 云存储网关服务 CSG 虚拟专用网络 VPN 企业路由器 ER 推荐系统 RES 云服务器备份服务 CSBS 内容分发网络服务 CDN 容器安全服务 CGS 态势感知 SA 代码托管 CodeHub 表格存储服务 CloudTable 云硬盘备份服务 VBS 云速建站 CloudSite 云手机 CPH 云性能测试服务 CPTS 智能边缘云 IEC 函数工作流服务 FunctionGraph 主机迁移服务 SMS 标签管理服务 TMS 对话机器人服务 CBS 关系型数据库 RDS 云解析服务的Region级 DNS 存储容灾服务 SDRS 语音通话 VoiceCall 应用性能管理 APM 应用编排服务 AOS 数据接入服务 DIS 数据库安全服务 DBSS 慧眼HiLens HiLens 云数据迁移 CDM 多活高可用服务 MAS 流水线 CloudPipeline 图像识别 Image OBS应用事件源对象存储服务 OBS 智能边缘平台 IEF 容器镜像服务 SWR 分布式缓存服务 DCS 弹性伸缩 AS 漏洞扫描服务 VSS 图引擎服务 GES 数据湖探索 DLI 云容器实例 CCI 需求管理 CodeArts Req 文档数据库服务 DDS 数据复制服务 DRS AI平台ModelArts 分布式数据库中间件 DDM 消息通知服务 SMN 应用管理与运维平台 ServiceStage 软件开发生产线 CodeArts 区块链服务 BCS 应用运维管理 AOM MapReduce服务 MRS 云堡垒机 CBH 企业主机安全 HSS Web应用防火墙 WAF 弹性负载均衡 ELB 云硬盘 EVS 应用与数据集成平台 ROMA Connect 云容器引擎 CCE 镜像服务 IMS 弹性云服务器 ECS 目前只支持写事件，不支持读事件。

事件网格 EG 事件源

事件网格 EG-云服务事件源:查看事件类型

查看事件类型登录事件网格控制台。在左侧导航栏选择“事件源”，进入“事件源”页面。在“云服务事件源”页签，单击待查看事件类型的事件源名称，弹出“查看云服务事件源”对话框。在“事件类型”区域，查看事件类型和对应的描述信息，如图2所示。图1 事件类型单击操作列“查看示例”，可在弹窗查看示例详情，若事件实例如果有多个实例，弹窗里可以查询实例。图2 查看示例图3 多个示例目前只支持云服务事件模型列表中的六个场景，除此以外的点开暂无示例。

事件网格 EG 事件源

事件网格 EG-资源和成本规划

资源和成本规划本实践涉及到的资源和成本规划，如下表所示。表1 资源和成本规划资源资源说明数量费用（元）虚拟私有云VPC 创建一个虚拟私有云VPC。 1 00.00 虚拟私有云子网创建一个虚拟私有云子网。 1 00.00 安全组创建一个安全组。 1 00.00 对象存储服务OBS 创建一个OBS桶。说明：创建OBS桶免费，使用阶段请参考OBS计费说明。 1 00.00 分布式消息服务 Kafka版购买一个Kafka实例，按需计费。 1 例如：kafka.2u4g.cluster 4.35元/小时事件网格EventGrid 创建一个事件订阅，事件源为OBS应用事件源，事件目标为分布式消息服务Kafka版。创建一个目标连接，类型为“分布式消息服务 Kafka版”。 1 00.00 本文提供的成本预估费用仅供参考，资源的实际费用以华为云管理控制台显示为准。父主题：基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版

事件网格 EG 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版

事件网格 EG-移动云RocketMQ版:创建移动云 RocketMQ版事件源

创建移动云 RocketMQ版事件源登录事件网格控制台。在左侧导航栏选择“事件流”，进入“事件流”页面。单击“创建事件流”，进入“创建事件流”页面。图1 创建事件流单击“事件源”，弹出“配置事件源”对话框。图2 配置事件源参考表1，填写事件源的配置信息。表1 移动云 RocketMQ版参数说明参数名称说明事件提供方选择移动云 RocketMQ版。实例ID 请输入实例ID。 Group ID 请输入Group ID。 Topic 请输入Topic。 Tag 请输入Tag。说明：表示订阅指定Topic下的Tags。 * 表示订阅所有消息。 TagA || TagB || TagC 表示订阅TagA或TagB或TagC的消息。开启保存消息轨迹请选择是否开启保存消息轨迹。启用鉴权认证请选择是否启用鉴权认证。 Access Key（启用鉴权认证）请输入Access Key。 Secret Key（启用鉴权认证）请输入Secret Key。订阅方式请选择集群或广播。接入点类型请选择公网或私网。地址请输入地址。客户端SDK 请输入客户端SDK上传到OBS的地址。说明：客户端SDK上传到OBS的地址获取方式可参考常见问题。消费超时时间（毫秒）请输入1000到900000之间的整数。消息类型请选择普通消息。消费线程数请输入20到64之间的整数。批量消费最大消息数请输入1到32之间的整数。批量消费最大等待时长（秒）请输入0到450之间的整数。单击“下一步”，进入规则配置页面，规则配置可参考过滤规则参数说明。图3 规则配置单击“下一步”完成规则配置，您可以参考路由到函数工作流，继续配置事件流的事件目标。事件源配置为移动云RocketMQ版时，配置事件目标为FunctionGraph（函数计算）时，执行方式可选择为“同步”或“异步”。当事件源和事件目标都配置完成后，单击“保存”，完成事件流的创建。 MQ采集函数首次启动分钟级后生效。广播模式下不支持失败重试，即消费失败后，失败消息不再重试，消费者继续消费新的消息。发送到目标端失败时，将利用RocketMQ本身的重试能力进行重试，目标端需支持处理重复事件，达到重试上限时，源端消息进入RocketMQ对应topic的死信队列，EG事件不再投递。

事件网格 EG 事件源

事件网格 EG-分布式消息服务RocketMQ版:事件格式查看

事件格式查看前提条件：创建rocketmq实例。图1 rocketmq实例创建和rocketmq实例同一vpc、子网的访问端点。创建事件通道。图2 创建事件通道创建rocketmq事件源。图3 rocketmq事件源创建rocketmq事件订阅。图4 创建rocketmq事件订阅图5 创建事件订阅成功后rocketmq事件源变为运行中发送事件。图6 发送事件查看事件消息格式。查看事件轨迹的事件详情：图7 事件轨迹详情消息体事件格式如下： { "datacontenttype": "application/json", "data": { "context": "{\"hello\":\"world\"}", "topic": "topic-test" }, "subject": "ROCKETMQ:cn-north-4:f003dc69-2fc3-4c44-9062-0b9a2c6cb8cc/0ef1e7a03280f3ed2f69c00c652a5744:ROCKETMQ:source-rocketmq", "specversion": "1.0", "id": "e6cc599b-0664-4078-87dd-5630087d5f7e", "source": "source-rocketmq", "time": "2024-02-05T14:20:31Z", "type": "ROCKETMQ:CloudTrace:RocketmqCall" } 查看目标函数日志：图8 目标函数日志

事件网格 EG 创建自定义事件源

事件网格 EG-分布式消息服务RocketMQ版:创建RocketMQ事件源

创建RocketMQ事件源登录事件网格控制台。在左侧导航栏选择“事件源”，进入“事件源”页面。单击“自定义事件源”，弹出“创建自定义事件源”对话框。参考表1，填写自定义事件源的配置信息。表1 RocketMQ事件源参数说明参数名称说明配置类型支持以下两种类型：选择：选择一个已创建的自定义事件通道。新建：创建一个新的自定义事件通道。通道 “配置类型”为“选择”时，在下拉列表中选择一个已创建的自定义事件通道。 “配置类型”为“新建”时，输入事件通道名称和描述信息。事件源创建成功后，事件通道不支持修改。事件源名称您自定义的事件源名称，用于识别不同的事件源。事件源创建成功后，事件源名称不支持修改。描述（可选）事件源的描述信息。事件源类型事件源类型选择“分布式消息服务RocketMQ版”。说明：如之前未创建授权委托，事件源类型首次选择“分布式消息服务RocketMQ版”时，系统会自动弹出创建委托授权界面，需要您创建授权委托，详情请查看授权委托。 RocketMQ实例选择消息队列RocketMQ版中的实例名称。若选择“无”，表示添加用户自建的消息队列RocketMQ版实例。 Topic RocketMQ实例的Topic。消费组 RocketMQ实例的消费组。用户名 RocketMQ实例开启ACl访问控制的时候需要填写实例的用户名。密钥 RocketMQ实例开启ACl访问控制的时候需要填写实例的密钥。虚拟私有云当“RocketMQ实例”选择“无”时参数可见，选择虚拟私有云。子网当“RocketMQ实例”选择“无”时参数可见，选择子网。连接地址当“RocketMQ实例”选择“无”时参数可见，输入自建RocketMQ版实例的连接地址。 SSL 当“RocketMQ实例”选择“无”时参数可见，配置是否开启SSL。说明：自建RocketMQ事件源处于“运行中”时，不支持修改SSL。如果涉及SSL变化，建议该事件源删除重建。 ACL访问控制当“RocketMQ实例”选择“无”时参数可见，配置是否开启ACL访问控制。单击“确定”，完成自定义事件源的创建。创建成功后，在“自定义事件源”页签，查看创建的事件源。如果需要修改自定义事件源的描述信息，单击待修改事件源后的“编辑”，在弹出的对话框中编辑描述及相关参数信息。如果需要查看自定义事件源的信息，单击待查看信息的事件源名称，在弹出的对话框中查看自定义事件源信息。

事件网格 EG 创建自定义事件源

事件网格 EG-分布式消息服务RocketMQ版:创建分布式消息服务RocketMQ版事件源

创建分布式消息服务RocketMQ版事件源登录事件网格控制台。在左侧导航栏选择“事件流”，进入“事件流”页面。单击“创建事件流”，进入“创建事件流”页面。图1 创建事件流单击“事件源”，弹出“配置事件源”对话框。图2 配置事件源参考表1，填写事件源的配置信息。表1 分布式消息服务RocketMQ版参数说明参数名称说明事件提供方选择分布式消息服务 RocketMQ版。实例请选择实例。 Group 请输入消费组。 Topic 请输入Topic。 SSL 请选择是否开启SSL。 ACL访问控制请选择是否开启ACL访问控制。说明：当开启ACL访问控制时，需要配置用户名及密钥。 tag 请输入tag。消费超时时间（毫秒）请输入1000到900000之间的整数。消费方式请选择“并发消费”或“顺序消费”。消费线程数请输入20到64之间的整数。批量消费最大消息数请输入1到32之间的整数。最大重试次数请输入最大重试次数。说明：设置-1表示无限重试，0表示不重试。如果RockrtMQ版本为4.x版本，则默认允许每条消息最多重试16次，每次重试的时间间隔如表2所示。重试间隔（毫秒）请输入1000到30000之间的整数。表2 RockrtMQ 4.x版本重试时间间隔第几次重试与上次重试的间隔时间第几次重试与上次重试的间隔时间 1 10秒 9 7分钟 2 30秒 10 8分钟 3 1分钟 11 9分钟 4 2分钟 12 10分钟 5 3分钟 13 20分钟 6 4分钟 14 30分钟 7 5分钟 15 1小时 8 6分钟 16 2小时表3 生产顺序性和消费顺序性组合生产顺序消费顺序顺序性效果设置消息组，保证消息顺序发送。顺序消费按照消息组粒度，严格保证消息顺序。同一消息组内的消息的消费顺序和发送顺序完全一致。设置消息组，保证消息顺序发送。并发消费并发消费，尽可能按时间顺序处理。未设置消息组，消息乱序发送。顺序消费按队列存储粒度，严格顺序。基于 Apache RocketMQ 本身队列的属性，消费顺序和队列存储的顺序一致，但不保证和发送顺序一致。未设置消息组，消息乱序发送。并发消费并发消费，尽可能按照时间顺序处理。单击“下一步”，进入规则配置页面，规则配置可参考过滤规则参数说明。图3 规则配置单击“下一步”完成规则配置，您可以参考路由到函数工作流，继续配置事件流的事件目标。事件源配置为分布式消息服务RocketMQ版时，配置事件目标为FunctionGraph（函数计算）时，执行方式可选择为“同步”或“异步”。当事件源和事件目标都配置完成后，单击“保存”，完成事件流的创建。 MQ采集函数首次启动分钟级后生效。广播模式下不支持失败重试，即消费失败后，失败消息不再重试，消费者继续消费新的消息。发送到目标端失败时，将利用RocketMQ本身的重试能力进行重试，目标端需支持处理重复事件，达到重试上限时，源端消息进入RocketMQ对应topic的死信队列，EG事件不再投递。

事件网格 EG 事件源

事件网格 EG-更新自定义事件源:请求示例

请求示例 { "channel_id" : "635d6fc4-8b3e-4c3a-9604-5e4e9c98ea2e", "description" : null, "name" : "test", "type" : "RABBITMQ", "detail" : { "instance_id" : "ac14144e-9v3c-43d6-acfd-bf09b52c98uy", "user_name" : "user_name", "password" : "password", "vhost_name" : "vhost_name", "queue_name" : "queue_name" } }

事件网格 EG 事件源管理

事件网格 EG-更新自定义事件源:响应示例

响应示例状态码： 400 { "error_code" : "EG.00014000", "error_msg" : "Bad request" } 状态码： 401 { "error_code" : "EG.00014010", "error_msg" : "Incorrect token or token resolution failed" } 状态码： 403 { "error_code" : "EG.00014030", "error_msg" : "No permissions to request this method" } 状态码： 404 { "error_code" : "EG.00014040", "error_msg" : "Not request resource found" } 状态码： 500 { "error_code" : "EG.00015000", "error_msg" : "Internal Server Error" }

事件网格 EG 事件源管理

事件网格 EG-更新自定义事件源:响应参数

响应参数状态码： 200 表5 响应Header参数参数参数类型描述 X-Request-Id String This field is the request ID number for task tracking. Format is request_uuid-timestamp-hostname. 表6 响应Body参数参数参数类型描述 id String 事件源ID name String 事件源名称 label String 事件源名称展示 description String 事件源描述 provider_type String 事件源提供方类型，OFFICIAL：官方云服务事件源；CUSTOM：用户创建的自定义事件源；PARTNER：伙伴事件源枚举值： OFFICIAL CUSTOM PARTNER event_types Array of event_types objects 事件源提供的事件类型列表，只有官方云服务事件源提供事件类型 created_time String 创建UTC时间 updated_time String 更新UTC时间 channel_id String 事件源归属的事件通道ID channel_name String 事件源归属的事件通道名称 type String 事件源类型 detail Object json格式封装消息实例链接信息：如RabbitMQ实例的instance_id字段、虚拟主机 vhost字段、队列queue字段、用户名、密码等 status String 自定义事件源状态枚举值： CREATE_FAILED RUNNING ERROR error_info ErrorInfo object 表7 event_types 参数参数类型描述 name String 事件类型名称 description String 事件类型描述表8 ErrorInfo 参数参数类型描述 error_code String 错误码最小长度：1 最大长度：128 error_detail String 错误详情最小长度：1 最大长度：128 error_msg String 错误信息最小长度：1 最大长度：128 状态码： 400 表9 响应Body参数参数参数类型描述 error_code String 错误码最小长度：1 最大长度：128 error_msg String 错误消息最小长度：1 最大长度：512 error_details String 具体错误消息最小长度：1 最大长度：1024 request_id String 请求处理ID 最小长度：1 最大长度：128 状态码： 401 表10 响应Body参数参数参数类型描述 error_code String 错误码最小长度：1 最大长度：128 error_msg String 错误消息最小长度：1 最大长度：512 error_details String 具体错误消息最小长度：1 最大长度：1024 request_id String 请求处理ID 最小长度：1 最大长度：128 状态码： 403 表11 响应Body参数参数参数类型描述 error_code String 错误码最小长度：1 最大长度：128 error_msg String 错误消息最小长度：1 最大长度：512 error_details String 具体错误消息最小长度：1 最大长度：1024 request_id String 请求处理ID 最小长度：1 最大长度：128 状态码： 404 表12 响应Body参数参数参数类型描述 error_code String 错误码最小长度：1 最大长度：128 error_msg String 错误消息最小长度：1 最大长度：512 error_details String 具体错误消息最小长度：1 最大长度：1024 request_id String 请求处理ID 最小长度：1 最大长度：128 状态码： 500 表13 响应Body参数参数参数类型描述 error_code String 错误码最小长度：1 最大长度：128 error_msg String 错误消息最小长度：1 最大长度：512 error_details String 具体错误消息最小长度：1 最大长度：1024 request_id String 请求处理ID 最小长度：1 最大长度：128

事件网格 EG 事件源管理

事件网格 EG-更新自定义事件源:请求参数

请求参数表2 请求Header参数参数是否必选参数类型描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。最小长度：1 最大长度：16384 表3 请求Body参数参数是否必选参数类型描述 description 否 String 事件源描述最大长度：255 detail 否 RocketMqDetail object json格式封装消息实例更新信息表4 RocketMqDetail 参数是否必选参数类型描述 instance_id 否 String RocketMQ实例ID group 是 String 消费组 topic 是 String Topic access_key 是 String 用户名 secret_key 是 String 密钥 vpc_id 否 String 虚拟私有云 subnet_id 否 String 子网 namesrv_address 否 String 连接地址 ssl_enable 否 Boolean SSL enable_acl 否 Boolean ACL访问控制

事件网格 EG 事件源管理

事件网格 EG-自定义应用事件源:创建自定义应用事件源

创建自定义应用事件源登录事件网格控制台。在左侧导航栏选择“事件源”，进入“事件源”页面。单击“自定义事件源”，弹出“创建自定义事件源”对话框。参考表1，填写自定义事件源的配置信息。表1 自定义应用事件源参数说明参数名称说明事件源名称您自定义的事件源名称，用于识别不同的事件源。事件源创建成功后，事件源名称不支持修改。描述（可选）事件源的描述信息。事件源类型事件源类型，选择“自定义应用”。单击“确定”，完成自定义应用事件源的创建。创建成功后，在“自定义事件源”页签，查看创建的事件源。如果需要修改自定义事件源的描述信息，单击待修改事件源后的“编辑”，在弹出的对话框中编辑描述及相关参数信息。如果需要查看自定义事件源的信息，单击待查看信息的事件源名称，在弹出的对话框中查看自定义事件源信息。如果发送事件界面配置的事件源为新事件源（事件源列表查询不到），发送事件后，无法在 CES 服务监控里查询到监控信息。

事件网格 EG 创建自定义事件源

云服务器内容精选

事件源

7*24

备案

专业服务

退订

建议反馈

售前咨询热线