检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
创建自定义事件模型 功能介绍 创建自定义事件模型 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI POST /v1/{project_id}/schemas 表1 路径参数
查询事件通道列表 功能介绍 查询事件通道列表,包括系统通道和自定义通道。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/channels
创建事件订阅 功能介绍 创建事件订阅。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI POST /v1/{project_id}/subscriptions 表1 路径参数
查询配额 功能介绍 查询当前租户的配额,未特殊配置过的会返回默认配额。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/quotas
更新自定义事件模型 功能介绍 更新自定义事件模型定义 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI PUT /v1/{project_id}/schemas/{schema_id}
查询事件模型列表 功能介绍 查询事件模型列表,包括系统事件模型和自定义事件模型 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/schemas
601 未知致命异常 设置事件流状态为ERROR,上报告警,自动重启事件流。 建议联系华为工程师处理。 602 网络异常 502 消费者不存在 401 目标端投递认证失败 主动刷新token,设置事件流状态为ERROR,自动重启事件流。 等待自动恢复。 600 升级中 无动作。 采集函数正在升级,等待升级即可。
IAM中的项目用于将OpenStack的资源(计算资源、存储资源和网络资源)进行分组和隔离。用户拥有的资源必须挂载在项目下,项目可以是一个部门或者项目组。一个账户中可以创建多个项目。 企业项目 企业管理中的企业项目是对多个资源进行分组和管理,在目标区域中同一类型的资源可以划分到一个企业项目中,且
事件网格提供以下事件处理能力: 传输事件 过滤事件 路由事件 事件网格独立处理每个事件。这意味着事件的顺序没有保证,并且在某些情况下,事件可以多次传递。因此,事件处理程序应设计为幂等的。 网络管理 事件网格提供网络管理能力,包括目标连接和访问端点: 目标连接:用户通过目标连接来连接Webhook。 访问端点:用户通过访问端点推送自定义事件。
确保vpc、子网、kafka等资源充足。 确保源端和目标端实例与用户创建事件流集群时选择的VPC网络互通。 创建VPC和子网的操作指导请参考创建虚拟私有云和子网。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流>专业版事件流作业”,进入“专业版事件流作业”页面。 右上角单击“创建作业”,进入“基础配置”。
最早点位:将会从消息队列的最早消息开始消费。 SASL认证机制 当Kafka实例开启SASL SSL时可见,选择SASL认证机制。 PLAIN:一种简单的用户名密码校验机制。 SCRAM-SHA-512:采用哈希算法对用户名与密码生成凭证,进行身份校验的安全认证机制,比PLAIN机制安全性更高。 SASL证书地址
权限策略和授权项 如果您需要对您所拥有的事件网格服务进行精细的权限管理,您可以使用统一身份认证服务(Identity and Access Management,简称IAM),如果华为云账号已经能满足您的要求,不需要创建独立的IAM用户,您可以跳过本章节,不影响您使用事件网格服务的其它功能。
发布区域:华北-北京四、华东-上海一、华东-上海二 事件示例 事件规则 事件规则用于过滤和转换事件。 过滤:事件网格在事件订阅中通过配置过滤规则过滤事件,并将过滤后的事件路由到事件目标。 转换:事件网格在事件订阅中通过配置类型对事件内容进行转换,将CloudEvents标准事件转换成事件目标可以接受的事件类型。
事件网格将您设置的常量路由到事件目标。 如果需要了解更多转换类型的信息,请参考事件内容转换。 启用死信队列:默认不启用。启用死信队列后EG会把处理失败的事件发送到配置的队列中,若不启用则处理失败的事件将被丢弃。了解更多详情请参考死信队列。 图5 自定义事件目标配置参数 单击“确定”。
可用区间内网互通,不同区域间内网不互通。通过在不同地区创建云资源,可以将应用程序设计的更接近特定客户的要求,或满足不同地区的法律或其他要求。 可用区:一个可用区是一个或多个物理数据中心的集合,有独立的风火水电,AZ内逻辑上再将计算、网络、存储等资源划分成多个集群。一个Region
如果需要了解更多转换类型的信息,请参考事件内容转换。 消息推送 批量推送 配置是否开启批量推送,批量推送可帮您批量聚合多个事件。 批量推送条数 推送间隔 开启批量推送可见,每次批量推送的最大聚合条数,默认值100,输入值范围1~10000。 开启批量推送可见,输入批量推送间隔,默认值1,输入值范围0~15,单位:秒。
事件网格将您设置的常量路由到事件目标。 如果需要了解更多转换类型的信息,请参考事件内容转换。 启用死信队列:默认不启用。启用死信队列后EG会把处理失败的事件发送到配置的队列中,若不启用则处理失败的事件将被丢弃。了解更多详情请参考死信队列。 图8 自定义事件目标配置参数 单击“确定”,完成事件目标的配置。
https://{Endpoint}/v3/projects”,其中{Endpoint}为IAM的终端节点,可以从地区和终端节点获取。接口的认证鉴权请参见认证鉴权。 响应示例如下,其中projects下的“id”即为项目ID。 { "projects": [ {
对象名编码:开启 过滤规则:根据默认值配置,无需修改。配置过滤规则请参考过滤规则参数说明。 配置事件目标。 配置如下事件目标参数: 选择提供方:华为云 事件目标:分布式消息服务 Kafka版 目标连接:选择“kafka-connect” Topic:选择“topic-eg” 启用消息Key:关闭
请选择企业项目。(关联企业项目后,不支持修改。) 跨账号 选择是否开启跨账号。 说明: 启用跨账号后,允许指定账号向当前通道发布事件。 创建通道时需要开启跨账号开关,输入目标账号的ID。 同账号跨区域时目标通道也需要开启跨账号开关,输入本账号的ID。 账号ID 请输入被授权账号ID,