检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
当前仅支持华南-广州、华东-上海一。 功能简介 引导式同步 使用EG专业版事件流秒变同步专家。 场景化选择 预设使用场景,让数据同步更少配置、更简单。 网络与安全 支持SSL等加密和认证机制,让数据同步更安全。 多种同步模式 支持对象选择、全量+增量同步和多种压缩模式,满足不同同步诉求。
作业基本配置参数说明 参数 说明 集群 选择已创建的集群,如未创建,请参见专业版事件流集群。 作业名称 请输入作业名称。 场景类型 当前默认为同步。 描述 请输入对本作业的描述。 单击“下一步:源和目标对象配置”,进入“源和目标对象配置”页面。 图1 源数据和目标数据配置 表2 源数据和目标数据配置参数说明
IN”。 用户名 请输入用户名。 当接入方式选择“密文接入”时需配置。 密码 请输入密码。 当接入方式选择“密文接入”时需配置。 单击“下一步:高级配置”,进入“高级配置”页面。 图2 高级配置 表2 作业对象配置参数是否支持修改说明 参数 是否支持修改 Topic匹配类型 是,可选择“正则匹配”或“精确匹配”。
登录函数工作流控制台,在左侧导航栏选择“函数 > 函数列表”,进入函数列表界面。 单击“创建函数”,进入创建函数流程。 填写函数配置信息。输入基础配置信息,完成后单击“创建函数”,具体详情请参见创建函数。 进入新建的函数详情页。 在“代码”页签,代码选择“上传自ZIP文件”,上传样例代码中的程序包。
IN”。 用户名 请输入用户名。 当接入方式选择“密文接入”时需配置。 密码 请输入密码。 当接入方式选择“密文接入”时需配置。 单击“下一步:高级配置”,进入“高级配置”页面。 图2 高级配置 表3 作业对象配置参数说明 参数 说明 Topic匹配类型 选择“正则匹配”或“精确匹配”。
设置桶参数。关于桶参数的详细介绍,请参考创建桶。 表1 桶参数配置 参数 说明 区域 事件网格与所在区域保持一致。 桶名称 输入示例如“eg-test”。 默认存储类别 按需选择。 桶策略 按需选择。 默认加密 按需选择。 归档数据直读 按需选择。 企业项目 按需选择。 配置完成后,单击“立即创建”,根据提示信息完成桶的创建。
若填写,符合规范才能触发事件。 对象名后缀 若填写,符合规范才能触发事件。 对象名编码 选择“开启”。 过滤规则 根据默认值配置,无需修改。配置过滤规则请参考过滤规则参数说明。 配置事件目标。 表2 参数配置说明 参数 说明 选择提供方 请选择“华为云”。 事件目标 请选择“FunctionGraph(函数计算)”。
单击“创建事件路由任务”,进入创建详情页。 配置“任务基本配置”。 图2 任务基本配置 表1 任务基本配置参数说明 参数 说明 任务名称 请输入任务名称 描述 请输入对本任务的描述。 配置“源端和目标端配置”。 当源端和目标端均为Kafka时: 图3 源端和目标端配置 源端类型:Kafka 目标端类型:Kafka
建 Serverless版事件流”。 左上角单击,配置事件流名称和描述,完成后单击“确定”。 配置RocketMQ事件源。 配置事件规则,本案例使用默认配置,如需其他规则请根据实际情况配置。 配置函数计算事件目标。 其中“规则配置”中的“类型”参数选择“变量”,“参数”及“模板”示例如下:
模板 My name is ${name} My name is test01 在创建事件订阅-配置事件目标,事件目标配置为“FunctionGraph(函数计算)”时,若内容转换规则配置为“透传”,无法将事件内容作为输入值传递至事件目标。如需将事件内容作为函数流输入值,可以通过“
无 EG CommonAccess 事件网格通用使用权限。 系统策略 无 表 常用操作与系统策略的关系列出了EG常用操作与系统策略的授权关系,您可以参照该表选择合适的系统策略。 表2 常用操作与系统策略的关系 操作 EG FullAccess EG Publisher EG ReadOnlyAccess
目标连接功能需要使用函数工作流服务打通用户VPC网络,需要用户必须为函数工作流服务配置具备VPC管理权限的委托。 DNS ReadOnlyAccess 目标连接功能需要使用函数工作流服务打通用户VPC网络,需要用户必须为函数工作流服务配置具备读取云解析服务资源权限的委托。 首次创建自定义事件源“事件
产生的事件。云服务事件源产生的事件只能发布到云服务事件通道。 自定义事件通道:您自行创建的事件通道,用于接收自定义事件源产生的事件。 约束与限制 已关联自定义事件源,或事件订阅的事件通道,无法删除。您需要先解除关联,然后再进行删除操作。 创建自定义事件通道 登录事件网格控制台。
参考图1,设置桶参数。关于桶参数的详细介绍,请参考创建桶。 区域:与事件网格所在区域保持一致 桶名称:输入示例如“eg-obs” 默认存储类别:选择“标准存储” 桶策略:选择“私有” 默认加密:不勾选 归档数据直读:选择“关闭” 企业项目:选择“default” 图1 创建桶 配置完成后,单击“立即创建”,根据提示信息完成桶的创建。
请参考获取AK/SK。 请求鉴权失败。 检查发布事件的请求方法、请求地址和请求体与利用验签算法生成签名时的参数是否一致。 资源不存在。 请检查事件通道、事件源、事件订阅等是否创建成功并且正确配置。 事件体的格式不正确。 请检查事件是否符合CloudEvents协议标准格式,特别
事件网格如何收费? 事件网格根据自定义(包含云服务租户侧事件产生 )或第三方事件流入的事件数量进行计费,具体详情请参见价格计算器。 事件网格当前提供按需计费模式,这种购买方式比较灵活,按照实际使用量付费,没有最低消费。 华为云服务事件源自身产生发布的事件(任意事件状态变化 )免费,事件消费免费。
开通事件网格服务并授权 使用事件网格服务前,您需要: 已注册华为账号并开通华为云。 当前登录账号拥有使用事件网格的权限。账号权限授权与绑定,请参考创建用户并授权使用EG。 如果您的账号为IAM用户,请先联系华为云账号拥有者为IAM用户授权,然后才能使用事件网格服务。 登录事件网格控制台
请输入1到32之间的整数。 单击“下一步”,进入规则配置页面,规则配置可参考过滤规则参数说明。 图2 规则配置 单击“下一步”完成规则配置,您可以参考路由到函数工作流,继续配置事件流的事件目标。 事件源配置为社区版RocketMQ时,配置事件目标为FunctionGraph(函数计算)
登录事件网格控制台。 在左侧导航栏选择“事件源”,进入“事件源”页面。 单击“自定义事件源”,弹出“创建自定义事件源”对话框。 参考表1,填写自定义事件源的配置信息。 表1 自定义应用事件源参数说明 参数名称 说明 事件源名称 您自定义的事件源名称,用于识别不同的事件源。 事件源创建成功后,事件源名称不支持修改。
CloudEvents SDK 本章节介绍使用开源的CloudEvents Java SDK发布事件。 前提条件 获取并安装IntelliJ IDEA,如果未安装,请至IntelliJ IDEA官方网站下载。 在pom.xml中加入依赖。如何在Java环境中集成API请求签名的SDK请参考AK/SK签名认证操作指导。