检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
目标连接:用户通过目标连接来连接Webhook。 访问端点:用户通过访问端点推送自定义事件。 事件监控 事件网格实现了对事件订阅和事件通道的监控,可查询事件投递和事件接入的监控信息。
路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID source_id 是 String 指定查询的事件源ID 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Tok
”。 选择“分布式消息Kafka版”,单击“创建”。 图6 配置测试事件 创建成功后在下拉框选择刚创建的测试事件。 单击“测试”,完成后可查看“执行结果”。 图7 执行结果 父主题: 事件订阅
委托 选择委托。如无委托,可单击旁边的“快速创建委托”进行创建,将会创建名为“EG_INVOKE_FG_AGENCY”委托。 委托下拉框只会查询出被委托方是事件网格服务的委托。 请确保您选择的委托已被授权的权限包含“functiongraph:function:invoke*”。 配置规则
件网格不会立即停止服务,会进入宽限期。您需支付事件网格在宽限期内产生的费用,相关费用可在“管理控制台 > 费用中心 >总览”的“欠费金额”查看,华为云将在您充值时自动扣取欠费金额。 如果您在宽限期内仍未支付欠款,将会进入保留期,资源状态变为“已冻结”,您将无法对处于保留期的资源执行任何操作。
完成后单击“完成配置”。 图3 预检查 返回专业版事件流作业列表,单击刚才创建的事件流名称,进入“基本信息”页面,选择“作业管理”,可以查看“同步进展详情”。 图4 Rocketmq事件流同步进展详情 表4 参数说明 参数名称 说明 Topic名称 创建RocketMQ实例时的Topic。
调用完成才返回。 委托:选择委托。如无委托,可单击旁边的“创建委托”进行创建,将会创建名为“EG_TARGET_AGENCY”委托。 只会查询出被委托方是事件网格服务的委托。 请确保您选择的委托已被授权的权限包含functiongraph:function:invoke*。 当事件目标选择“分布式消息服务
路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID source_id 是 String 指定查询的事件源ID 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Tok
路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID schema_id 是 String 指定查询的事件模型ID 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户To
路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID channel_id 是 String 指定查询的事件通道ID 表2 Query参数 参数 是否必选 参数类型 描述 enterprise_project_id 否 String 企业项目id
路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID connection_id 是 String 指定查询的目标连接ID 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户To
/v1/{project_id}/endpoints/{endpoint_id} 表1 路径参数 参数 是否必选 参数类型 描述 endpoint_id 是 String 指定查询访问端点的id project_id 是 String 租户项目ID 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述
完成后单击“完成配置”。 图3 预检查 返回专业版事件流作业列表,单击刚才创建的事件流名称,进入“基本信息”页面,选择“作业管理”,可以查看“同步进展详情”。 图4 Kafka事件流同步进展详情 表4 参数说明 参数名称 说明 Topic名称 创建Kafka实例时的Topic。
单击订阅名称旁的,弹出“修改订阅”弹窗。 输入订阅名称和描述信息,单击“确定”,完成订阅名称和描述信息输入。 企业用户请选择“企业项目”,单击“查看企业项目”可查看企业项目清单。 图1 选择企业项目 配置事件源。 单击“事件源”,如图2所示,弹出“事件源”对话框。 图2 配置事件源 选择事件源提供方。
pic中的数据出现循环复制。 Topic映射的名称不能相同。 完成参数配置后单击“立即购买”,完成事件路由创建,创建成功后可在事件路由页面查看任务状态。 事件路由任务创建完成后默认为“未启用”状态,需要单击“启用”按钮,待状态显示为“运行中”时,任务正式启用。 图5 启用事件路由
路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID channel_id 是 String 指定查询的事件通道ID 表2 Query参数 参数 是否必选 参数类型 描述 enterprise_project_id 否 String 企业项目id
路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID schema_id 是 String 指定查询的事件模型ID 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户To
路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID schema_id 是 String 指定查询的事件模型ID 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户To
登录分布式消息服务Kafka版控制台,选择Kafka实例所在的区域。 在“Kafka专享版”页面,单击目标端所在Kafka实例的名称,进入实例详情页面。 选择“消息查询”,分别查看源端topic和目标端topic的“消息体”。 图3 目标端消息 图4 源端消息 如消息一致,则Kafka实例间的数据同步成功。 父主题:
路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID endpoint_id 是 String 指定查询访问端点的id 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户To