检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
String 订阅的事件目标使用的目标链接ID 最大长度:64 detail Object 订阅的事件目标参数列表 transform TransForm object 订阅的事件目标转换规则 dead_letter_queue DeadLetterQueue object 订阅的死信参数列表
事件网格根据自定义(包含云服务租户侧事件产生 )或第三方事件流入的事件数量进行计费,具体详情请参见价格计算器。 事件网格当前提供按需计费模式,这种购买方式比较灵活,按照实际使用量付费,没有最低消费。 华为云服务事件源自身产生发布的事件(任意事件状态变化 )免费,事件消费免费。
订阅目标ID name String 订阅的事件目标名称 provider_type String 订阅的事件目标的提供方类型 connection_id String 订阅的事件目标使用的目标链接ID 最大长度:64 detail Object 订阅的事件目标参数列表 transform
订阅目标ID name String 订阅的事件目标名称 provider_type String 订阅的事件目标的提供方类型 connection_id String 订阅的事件目标使用的目标链接ID 最大长度:64 detail Object 订阅的事件目标参数列表 transform
选择已创建的集群,如未创建,请参见专业版事件流集群。 作业名称 请输入作业名称。 场景类型 可选“同步”或“迁移”。 同步:实现数据源之间的数据实时同步,支持正向和反向的长期单向数据同步。 迁移:适用于业务割接期数据的整体搬迁上云,只支持短期单向同步。 描述 请输入对本作业的描述。
订阅目标ID name String 订阅的事件目标名称 provider_type String 订阅的事件目标的提供方类型 connection_id String 订阅的事件目标使用的目标链接ID 最大长度:64 detail Object 订阅的事件目标参数列表 transform
DCS同步DCS 约束与限制 当前创建DCS的专业版事件流作业仅支持华南-广州且需开通白名单,使用前请提交工单申请。 “迁移”场景类型仅支持白名单用户。 前提条件 业务有自己的源DCS和目标DCS。 确保vpc、子网、DCS等资源充足。 DCS实例仅支持5.0的版本的单机,主备和Cluster集群。
事件通道负责接收来自事件源的事件。 事件网格支持的事件通道如下: 云服务事件通道:由事件网格自动创建、且不可修改的一条默认的云服务事件通道,用于接收云服务事件源产生的事件。云服务事件源产生的事件只能发布到云服务事件通道。 自定义事件通道:您自行创建的事件通道,用于接收自定义事件源产生的事件。 父主题:
本章节介绍华为云服务事件发送的整个流程。 华为云对象存储服务(Object Storage Service,简称OBS)作为云服务事件源将产生的云服务事件发送到事件网格,事件规则对云服务事件进行过滤和转换,通过转换后的事件触发事件目标(即函数工作流服务中的函数)。 前提条件 已开通事件网格服务并授权。
事件源概述 事件源是事件的来源,负责将华为云服务、自定义应用、SaaS应用等应用程序生产的事件发布到事件网格。 事件网格支持的事件源如下: 云服务事件源:华为云服务作为事件源,通过预定义的事件类型和事件通道发布事件到事件网格,事件规则对事件进行过滤,然后将过滤后的事件路由到事件目标。
事件目标 事件目标是事件的处理终端,负责消费事件。 事件网格支持的事件目标如下: 云服务事件目标:已对接事件网格的华为云服务。 自定义事件目标:您自定义的处理事件的服务。
创建自定义事件模型 事件模型(Schema)用于定义事件的结构。事件网格支持的事件模型如下: 云服务事件模型:事件网格为华为云服务事件源产生的事件提供Schema。每个华为云服务事件源的事件类型对应一个云服务事件模型。 自定义事件模型:针对发送到自定义通道的事件,您可以自定义Schema,也可以通
是否必选 参数类型 描述 instance_name 否 String 实例名称,仅dms的rockectMq需要该字段 最大长度:128 instance_id 否 String 实例ID,仅dms的rockectMq需要该字段 最大长度:128 addr 是 String rockectMq连接地址
s 参数 参数类型 描述 instance_name String 实例名称,仅dms的rockectMq需要该字段 最大长度:128 instance_id String 实例ID,仅dms的rockectMq需要该字段 最大长度:128 addr String rockectMq连接地址
s 参数 参数类型 描述 instance_name String 实例名称,仅dms的rockectMq需要该字段 最大长度:128 instance_id String 实例ID,仅dms的rockectMq需要该字段 最大长度:128 addr String rockectMq连接地址
是否必选 参数类型 描述 instance_name 否 String 实例名称,仅dms的rockectMq需要该字段 最大长度:128 instance_id 否 String 实例ID,仅dms的rockectMq需要该字段 最大长度:128 addr 是 String rockectMq连接地址
订阅创建成功后,支持修改订阅的描述信息、状态、事件源和事件目标。 约束与限制 已创建的订阅,无法修改事件源提供方。 已创建的订阅,无法修改已绑定的自定义事件通道。 修改订阅的描述信息 登录事件网格控制台。 在左侧导航栏选择“事件订阅”,进入“事件订阅”页面。 在待修改描述信息的订阅所在行,单击“配置”,进入订阅详情页。
事件源:将华为云服务、自定义应用、SaaS应用等应用程序产生的事件消息发布到事件订阅。 事件订阅:存储接收到的事件消息,并根据事件规则将事件消息路由到事件目标。 事件模型:定义事件的结构。云服务事件源产生的所有事件都可以关联到事件网格提供的相应的云服务事件模型。对于自定义事件源产生的事件,您可以自定义事件模型。
单击“创建事件订阅”。 单击“事件源”,在配置弹窗进行配置,配置完成单击“确定”。 提供方选择“自定义”。 通道:选择账号B创建的通道。 事件源:输入账号A创建的事件源(与账号A的订阅的事件源保持一致)。 图5 事件源配置 单击“事件目标”,在配置弹窗进行配置,配置完成单击“确定”(此处目标以函数为例)。
触发器类型:选择“分布式消息服务(Kafka)”。 实例:选择与死信队列相同的Kafka实例。 主题:选择与死信队列相同的Topic。 批处理大小:每次从Topic消费的消息数量,建议设置为10。 用户名:Kafka实例开启SSL时需要填写。连接Kafka专享版实例的用户名。 密码:Kafka实例开启SSL时需