检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
”，回到订阅详情页。 配置事件源。 单击“事件源”，参考图4，设置事件源参数。 选择提供方：选择“自定义” 通道配置 > 配置类型：选择“选择” 通道配置 > 通道：选择步骤一创建的“channel”通道 事件源配置 > 配置类型：选择“选择” 事件源配置 > 事件源：选择步骤二创建的“egsdk-source”
事件规则 事件流支持配置规则，默认会将消息透传至目标。 事件规则是指事件流转到事件目标之前，将CloudEvents标准事件转换成事件目标可以接受的事件类型。 事件流支持事件过滤和转换，具体规则请参考事件规则。 父主题： 事件流
单击“创建Serverless版事件流”，然后单击左上角图标，输入事件流名称和描述，完成后单击“确定”。 请参考配置分布式消息服务 Kafka版，配置事件源。 配置事件目标。 单击“事件目标”，右侧弹出“事件目标”弹窗。 目标服务选择“FunctionGraph（函数计算）”。
建 Serverless版事件流”。 左上角单击，配置事件流名称和描述，完成后单击“确定”。 配置RocketMQ事件源。 配置事件规则，本案例使用默认配置，如需其他规则请根据实际情况配置。 配置函数计算事件目标。 其中“规则配置”中的“类型”参数选择“变量”，“参数”及“模板”示例如下：
发布区域：华北-北京四、华东-上海一、华东-上海二 事件示例 事件规则 事件规则用于过滤和转换事件。 过滤：事件网格在事件订阅中通过配置过滤规则过滤事件，并将过滤后的事件路由到事件目标。 转换：事件网格在事件订阅中通过配置类型对事件内容进行转换，将CloudEvents标准事件转换成事件目标可以接受的事件类型。 发布
单击“创建事件订阅”。 单击“事件源”，在配置弹窗进行配置，配置完成单击“确定”。 提供方选择“自定义”。 通道：选择账号B创建的通道。 事件源：输入账号A创建的事件源（与账号A的订阅的事件源保持一致）。 图5 事件源配置 单击“事件目标”，在配置弹窗进行配置，配置完成单击“确定”（此处目标以函数为例）。
参考表1，填写自定义事件源的配置信息。 表1 RabbitMQ事件源参数说明 参数名称 说明 配置类型 支持以下两种类型： 选择：选择一个已创建的自定义事件通道。 新建：创建一个新的自定义事件通道。 通道 “配置类型”为“选择”时，在下拉列表中选择一个已创建的自定义事件通道。 “配置类型”为“新建”时，输入事件通道名称和描述信息。
如何过滤最终传输到事件目标的事件？ 您可以在事件订阅中通过配置事件过滤规则来筛选最终路由到事件目标的事件。 事件源产生的事件与过滤规则进行匹配，匹配成功后事件才会被路由到与过滤规则关联的事件目标。过滤规则必须和匹配的事件具有相同的结构。 关于事件过滤规则的更多信息，请参见过滤规则参数说明。
根据默认值配置，无需修改。配置过滤规则请参考过滤规则参数说明。 对象名前缀、对象名后缀填写时，对象文件格式必须都符合才能触发事件，当前后缀为空时，任意对象文件都符合。 创建事件订阅时，如果选择的OBS桶有被其他事件订阅调用，请确保当前桶的对象名前缀和后缀与其他事件订阅中配置的对象名
启用Kafka触发器 编写死信数据的处理逻辑。 图5 死信数据处理逻辑编写 配置测试事件。 单击“配置测试事件”，下拉框中单击“配置测试事件”。 选择“分布式消息Kafka版”，单击“创建”。 图6 配置测试事件 创建成功后在下拉框选择刚创建的测试事件。 单击“测试”，完成后可查看“执行结果”。
单击“创建Serverless版事件流”，然后单击左上角图标，输入事件流名称和描述，完成后单击“确定”。 请参考配置分布式消息服务 Kafka版，配置事件源。 配置事件目标。 单击“事件目标”，右侧弹出“事件目标”弹窗。 目标服务选择“分布式消息服务 Kafka版”。 设置事件目标参数。
如何将自定义的事件内容传输到事件目标？ 您可以在事件订阅中通过配置事件目标的转换规则来实现将自定义的事件内容传输到事件目标。 EventGrid事件转换目前支持透传、变量、常量三种转换类型。 透传：事件网格不对事件进行转换，将CloudEvents标准事件直接路由到事件目标。 变
未创建私网访问端点。 检查是否创建所需私网访问端点，其VPC及子网需要与RabbitMQ或RocketMQ实例配置相同，具体步骤，请参考创建私网访问端点。 用户default安全组规则配置不正确。 default安全组“出方向规则”需放通ICMP协议全部端口，具体步骤，请参考添加安全组规则。
实施及验证 源端配置操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”，右上角单击“创建Serverless版事件流”。 左上角单击，配置事件流名称和描述，完成后单击“确定”。 配置Kafka事件源。 单击“事件源”，右侧弹出“事件源”弹窗。
完成事件流名称和描述信息输入。 配置事件源。 单击“事件源”，右侧弹出“事件源”弹窗。 选择事件源提供方。 设置事件源参数。 完成后单击“下一步”。 配置规则。 单击“规则”，右侧弹出“规则”弹窗。 配置规则模式内容。 完成后单击“下一步”。 配置事件目标。 单击“事件目标”，右侧弹出“事件目标”弹窗。
单击“创建Serverless版事件流”，然后单击左上角图标，输入事件流名称和描述，完成后单击“确定”。 请参考配置分布式消息服务 Kafka版，配置事件源。 配置事件目标。 单击“事件目标”，右侧弹出“事件目标”弹窗。 目标服务选择“对象存储服务OBS”。 设置事件目标参数。
在左侧导航栏选择“网络管理>访问端点”，进入“访问端点”页面。 单击“创建访问端点”，弹出“创建访问端点”对话框。 参考表 访问端点参数说明，填写访问端点的配置信息。 表2 访问端点参数说明 参数 说明 名称 您自定义的访问端点名称。 访问端点创建成功后，访问端点名称不支持修改。 虚拟私有云 选择虚拟私有云，需提前创建。
参考表1，填写自定义事件源的配置信息。 表1 RocketMQ事件源参数说明 参数名称 说明 配置类型 支持以下两种类型： 选择：选择一个已创建的自定义事件通道。 新建：创建一个新的自定义事件通道。 通道 “配置类型”为“选择”时，在下拉列表中选择一个已创建的自定义事件通道。 “配置类型”为“新建”时，输入事件通道名称和描述信息。
ent”，单击“确定”，回到订阅详情页。 配置事件源。 单击“事件源”，参考图2，设置事件源参数。 选择提供方：选择“华为云” 事件源：选择“对象存储服务” 过滤规则：保存默认 图2 设置事件源参数 单击“确定”，完成事件源的配置。 配置事件目标。 单击“事件目标”，参考图3，设置事件目标参数。
用户密码 当Kafka实例开启SASL SSL时可见，输入实例用户密码。 单击“保存”，完成配置事件源。 完成配置事件源后，您可以参考路由到函数工作流，继续配置事件流的事件目标。 当事件源和事件目标都配置完成后，单击右上角“保存”，完成事件流的创建。 发送到目标端失败时，将重试整批事件，
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
