检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
登录函数工作流控制台，在左侧导航栏选择“函数 > 函数列表”，进入函数列表界面。 单击“创建函数”，进入创建函数流程。 填写函数配置信息。输入基础配置信息，完成后单击“创建函数”，具体详情请参见创建函数。 进入新建的函数详情页。 在“代码”页签，代码选择“上传自ZIP文件”，上传样例代码中的程序包。
的实例。 解决方式：返回配置专享版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为源端实例。 原因二：目标端Kafka实例版本不支持，请选择符合要求的实例。 解决方式：返回配置专享版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为目标端实例。
事件规则概述 事件规则用于过滤和转换事件。 过滤：事件网格在事件订阅中通过配置过滤规则过滤事件，并将过滤后的事件路由到事件目标。关于过滤规则的更多信息，请参考过滤规则参数说明和过滤规则示例。 转换：事件网格在事件订阅中通过配置类型对事件内容进行转换，将CloudEvents标准事件转换成事
资源和成本规划 本实践涉及到的资源和成本规划，如下表所示。 表1 资源和成本规划 资源 资源说明 数量 费用（元） 虚拟私有云VPC 创建一个虚拟私有云VPC。 1 00.00 虚拟私有云子网 创建一个虚拟私有云子网。 1 00.00 安全组 创建一个安全组。 1 00.00 对象存储服务OBS
String 事件源类型 detail Object json格式封装消息实例链接信息：如RabbitMQ实例的instance_id字段、虚拟主机vhost字段、队列queue字段、用户名、密码等 status String 自定义事件源状态 枚举值： CREATE_FAILED RUNNING
更新订阅场景时，指定ID的订阅目标存在时则进行更新，否则进行创建； 创建订阅目标场景时，指定ID作为待创建的订阅目标对象ID，未指定时由系统自动生成。 更新订阅目标时，此字段忽略； 最小长度：32 最大长度：64 name 是 String 订阅的事件目标名称 最大长度：128
更新订阅场景时，指定ID的订阅目标存在时则进行更新，否则进行创建； 创建订阅目标场景时，指定ID作为待创建的订阅目标对象ID，未指定时由系统自动生成。 更新订阅目标时，此字段忽略； 最小长度：32 最大长度：64 name 是 String 订阅的事件目标名称 最大长度：128
事件规则 事件流支持配置规则，默认会将消息透传至目标。 事件规则是指事件流转到事件目标之前，将CloudEvents标准事件转换成事件目标可以接受的事件类型。 事件流支持事件过滤和转换，具体规则请参考事件规则。 父主题： 事件流
单击“创建Serverless版事件流”，然后单击左上角图标，输入事件流名称和描述，完成后单击“确定”。 请参考配置分布式消息服务 Kafka版，配置事件源。 配置事件目标。 单击“事件目标”，右侧弹出“事件目标”弹窗。 目标服务选择“FunctionGraph（函数计算）”。
”，回到订阅详情页。 配置事件源。 单击“事件源”，参考图4，设置事件源参数。 选择提供方：选择“自定义” 通道配置 > 配置类型：选择“选择” 通道配置 > 通道：选择步骤一创建的“channel”通道 事件源配置 > 配置类型：选择“选择” 事件源配置 > 事件源：选择步骤二创建的“egsdk-source”
单击“创建事件订阅”。 单击“事件源”，在配置弹窗进行配置，配置完成单击“确定”。 提供方选择“自定义”。 通道：选择账号B创建的通道。 事件源：输入账号A创建的事件源（与账号A的订阅的事件源保持一致）。 图5 事件源配置 单击“事件目标”，在配置弹窗进行配置，配置完成单击“确定”（此处目标以函数为例）。
完成事件流名称和描述信息输入。 配置事件源。 单击“事件源”，右侧弹出“事件源”弹窗。 选择事件源提供方。 设置事件源参数。 完成后单击“下一步”。 配置规则。 单击“规则”，右侧弹出“规则”弹窗。 配置规则模式内容。 完成后单击“下一步”。 配置事件目标。 单击“事件目标”，右侧弹出“事件目标”弹窗。
单击“创建Serverless版事件流”，然后单击左上角图标，输入事件流名称和描述，完成后单击“确定”。 请参考配置分布式消息服务 Kafka版，配置事件源。 配置事件目标。 单击“事件目标”，右侧弹出“事件目标”弹窗。 目标服务选择“分布式消息服务 Kafka版”。 设置事件目标参数。
启用Kafka触发器 编写死信数据的处理逻辑。 图5 死信数据处理逻辑编写 配置测试事件。 单击“配置测试事件”，下拉框中单击“配置测试事件”。 选择“分布式消息Kafka版”，单击“创建”。 图6 配置测试事件 创建成功后在下拉框选择刚创建的测试事件。 单击“测试”，完成后可查看“执行结果”。
根据默认值配置，无需修改。配置过滤规则请参考过滤规则参数说明。 对象名前缀、对象名后缀填写时，对象文件格式必须都符合才能触发事件，当前后缀为空时，任意对象文件都符合。 创建事件订阅时，如果选择的OBS桶有被其他事件订阅调用，请确保当前桶的对象名前缀和后缀与其他事件订阅中配置的对象名
单击“创建Serverless版事件流”，然后单击左上角图标，输入事件流名称和描述，完成后单击“确定”。 请参考配置分布式消息服务 Kafka版，配置事件源。 配置事件目标。 单击“事件目标”，右侧弹出“事件目标”弹窗。 目标服务选择“对象存储服务OBS”。 设置事件目标参数。
自定义事件源参数说明 参数名称 说明 通道配置 配置类型 支持以下两种类型： 选择：选择一个已创建的自定义事件通道。 新建：创建一个新的自定义事件通道。 通道 “配置类型”为“选择”时，在下拉列表中选择一个已创建的自定义事件通道，例如：channel。 “配置类型”为“新建”时，输入事件通道名称。
最新动态 本文介绍了EG各特性版本的功能发布和对应的文档动态，欢迎体验。 2022年8月 序号 功能名称 功能描述 阶段 相关文档 1 目标连接 用户既可以通过default目标连接来连接公网webhook，也可以通过对应虚拟私有云和子网的目标连接来连接私网webhook。 公测
新建：创建一个新的自定义事件源。 事件源 “配置类型”为“选择”时，在下拉列表中选择一个已关联自定义事件通道的自定义事件源，此自定义事件通道为订阅绑定的自定义事件通道（即“通道配置”中“通道”的参数值）。 “配置类型”为“新建”时，输入自定义事件源名称。 描述 仅在“配置类型”为“新建”时，需要设置此参数。
实施及验证 源端配置操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”，右上角单击“创建Serverless版事件流”。 左上角单击，配置事件流名称和描述，完成后单击“确定”。 配置Kafka事件源。 单击“事件源”，右侧弹出“事件源”弹窗。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
