检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
构。 图1 事件网格总体架构示意图 事件源:将华为云服务、自定义应用、SaaS应用等应用程序产生的事件消息发布到事件订阅。 事件订阅:存储接收到的事件消息,并根据事件规则将事件消息路由到事件目标。 事件模型:定义事件的结构。云服务事件源产生的所有事件都可以关联到事件网格提供的相应
acks=0:表示producer不需要等待任何确认收到的信息,副本将立即加到socket buffer并认为已经发送。没有任何保障可以保证此种情况下server已经成功接收数据,同时重试配置不会发生作用(因为客户端不知道是否失败)回馈的offset会总是设置为-1。 acks=1:这意味着至少要等待leade
acks=0:表示producer不需要等待任何确认收到的信息,副本将立即加到socket buffer并认为已经发送。没有任何保障可以保证此种情况下server已经成功接收数据,同时重试配置不会发生作用(因为客户端不知道是否失败)回馈的offset会总是设置为-1。 acks=1:这意味着至少要等待leade
consumer_max_wait 否 Integer 批量消费最大等待时长,单位:秒 最小值:0 最大值:450 缺省值:5 vpc_id 否 String 虚拟私有云 subnet_id 否 String 子网 表7 SourceCommunityMQParameters 参数 是否必选 参数类型
RocketMQ。 地址 请输入连接地址。 Group 请输入Group。 Topic 请输入Topic。 虚拟私有云 请选择虚拟私有云。 说明: 事件流创建之后不允许修改虚拟私有云,编辑会有异常提示。 子网 请选择子网。 说明: 事件流创建之后不允许修改子网,编辑会有异常提示。 SSL
consumer_max_wait 否 Integer 批量消费最大等待时长,单位:秒 最小值:0 最大值:450 缺省值:5 vpc_id 否 String 虚拟私有云 subnet_id 否 String 子网 表7 SourceCommunityMQParameters 参数 是否必选 参数类型
事件ID eventSource String 事件源 eventType String 事件类型 receiveTime String 接收时间 channelId String 通道ID channelName String 通道名称 deliverList Array of
consumer_max_wait Integer 批量消费最大等待时长,单位:秒 最小值:0 最大值:450 缺省值:5 vpc_id String 虚拟私有云 subnet_id String 子网 表8 SourceCommunityMQParameters 参数 参数类型 描述 instance_name
2022年8月 序号 功能名称 功能描述 阶段 相关文档 1 目标连接 用户既可以通过default目标连接来连接公网webhook,也可以通过对应虚拟私有云和子网的目标连接来连接私网webhook。 公测 -- 2 访问端点 访问端点用于用户推送自定义事件,包括固定域名的公网访问端点和用户创建的私网访问端点。
String 事件源类型 detail Object json格式封装消息实例链接信息:如RabbitMQ实例的instance_id字段、虚拟主机vhost字段、队列queue字段、用户名、密码等 status String 自定义事件源状态 枚举值: CREATE_FAILED
请输入Kafka地址。 说明: 支持配置多个地址以逗号分隔,例如:192.168.0.1:111,192.168.0.2:222。 虚拟私有云 请选择虚拟私有云。 子网 请选择子网。 安全协议 请选择安全协议为“SASL_SSL”、“SASL_PLAINTEXT”或“PLAINTEXT”。
事件网格支持的云服务事件源列表如下: 表1 云服务事件源 云应用引擎 CAE 数据库和应用迁移 UGO Classroom 内容审核 Moderation 虚拟私有云 VPC 代码检查 CodeCheck 云数据库GaussDB NoSQL GaussDB API网关 APIG 数据仓库服务 DWS
RocketMQ实例开启ACl访问控制的时候需要填写实例的用户名。 密钥 RocketMQ实例开启ACl访问控制的时候需要填写实例的密钥。 虚拟私有云 当“RocketMQ实例”选择“无”时参数可见,选择虚拟私有云。 子网 当“RocketMQ实例”选择“无”时参数可见,选择子网。 连接地址 当“RocketMQ
代理规格:kafka.2u4g.cluster.small 代理数量:配置为“3” 存储空间:高I/O,100GB 磁盘加密:关闭 容量阈值策略:自动删除 虚拟私有云:vpc-default/subnet-default,此处选择前提条件中已准备好的vpc-default 安全组:default,
创建自定义事件通道 功能介绍 创建自定义事件通道。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI POST /v1/{project_id}/channels 表1
查询事件追踪列表 功能介绍 查询事件追踪列表。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/traced-events 表1
创建自定义事件模型 功能介绍 创建自定义事件模型 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI POST /v1/{project_id}/schemas 表1 路径参数
查询访问端点 功能介绍 查询访问端点。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/endpoints 表1 路径参数 参数
创建访问端点 功能介绍 创建访问端点。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI POST /v1/{project_id}/endpoints 表1 路径参数
创建事件订阅 功能介绍 创建事件订阅。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI POST /v1/{project_id}/subscriptions 表1 路径参数