检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
启用Kafka触发器 编写死信数据的处理逻辑。 图5 死信数据处理逻辑编写 配置测试事件。 单击“配置测试事件”，下拉框中单击“配置测试事件”。 选择“分布式消息Kafka版”，单击“创建”。 图6 配置测试事件 创建成功后在下拉框选择刚创建的测试事件。 单击“测试”，完成后可查看“执行结果”。
实施及验证 源端配置操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”，右上角单击“创建Serverless版事件流”。 左上角单击，配置事件流名称和描述，完成后单击“确定”。 配置Kafka事件源。 单击“事件源”，右侧弹出“事件源”弹窗。
用户密码 当Kafka实例开启SASL SSL时可见，输入实例用户密码。 单击“保存”，完成配置事件源。 完成配置事件源后，您可以参考路由到函数工作流，继续配置事件流的事件目标。 当事件源和事件目标都配置完成后，单击右上角“保存”，完成事件流的创建。 发送到目标端失败时，将重试整批事件，
未创建私网访问端点。 检查是否创建所需私网访问端点，其VPC及子网需要与RabbitMQ或RocketMQ实例配置相同，具体步骤，请参考创建私网访问端点。 用户default安全组规则配置不正确。 default安全组“出方向规则”需放通ICMP协议全部端口，具体步骤，请参考添加安全组规则。
参考表1，填写自定义事件源的配置信息。 表1 RocketMQ事件源参数说明 参数名称 说明 配置类型 支持以下两种类型： 选择：选择一个已创建的自定义事件通道。 新建：创建一个新的自定义事件通道。 通道 “配置类型”为“选择”时，在下拉列表中选择一个已创建的自定义事件通道。 “配置类型”为“新建”时，输入事件通道名称和描述信息。
如何将自定义的事件内容传输到事件目标？ 您可以在事件订阅中通过配置事件目标的转换规则来实现将自定义的事件内容传输到事件目标。 EventGrid事件转换目前支持透传、变量、常量三种转换类型。 透传：事件网格不对事件进行转换，将CloudEvents标准事件直接路由到事件目标。 变
”，回到订阅详情页。 配置事件源。 单击“事件源”，参考图4，设置事件源参数。 选择提供方：选择“自定义” 通道配置 > 配置类型：选择“选择” 通道配置 > 通道：选择步骤一创建的“channel”通道 事件源配置 > 配置类型：选择“选择” 事件源配置 > 事件源：选择步骤二创建的“egsdk-source”
查看监控数据 事件网格实现了对事件订阅和事件通道的监控，用户无需任何配置，即可查询事件投递和事件接入的监控信息。 操作步骤 登录管理控制台。 在管理控制台左上角单击，选择区域。 在管理控制台左上角单击，选择“应用中间件 > 事件网格”，进入事件网格页面。 在“事件订阅”页面，单击
最大长度：255 eps_id 否 String 企业项目id cross_account 否 Boolean 跨账号 policy 否 Object 策略，JSON格式示例 {"Sid":"allow_account_to_put_events","Effect":"Allow","Prin
右上角单击“创建作业”，进入“基础配置”。 配置“基本配置”信息。 图2 基本配置 表1 作业基本配置参数说明 参数 说明 集群 选择已创建的集群，如未创建，请参见专享版事件流集群。 作业名称 请输入作业名称。 场景类型 当前默认为同步。 描述 请输入对本作业的描述。 单击“下一步：源和目标对象配置”，进入“源和目标对象配置”页面。
右上角单击“创建作业”，进入“基础配置”。 配置“基本配置”信息。 图2 基本配置 表1 作业基本配置参数说明 参数 说明 集群 选择已创建的集群，如未创建，请参见专享版事件流集群。 作业名称 请输入作业名称。 场景类型 当前默认为同步。 描述 请输入对本作业的描述。 单击“下一步：源和目标对象配置”，进入“源和目标对象配置”页面。
单击“创建事件路由任务”，进入创建详情页。 配置“任务基本配置”。 图2 任务基本配置 表1 任务基本配置参数说明 参数 说明 任务名称 请输入任务名称 描述 请输入对本任务的描述。 配置“源端和目标端配置”。 当源端和目标端均为Kafka时： 图3 源端和目标端配置 源端类型：Kafka 目标端类型：Kafka
单击“创建事件订阅”。 单击“事件源”，在配置弹窗进行配置，配置完成单击“确定”。 提供方选择“自定义”。 通道：选择账号B创建的通道。 事件源：输入账号A创建的事件源（与账号A的订阅的事件源保持一致）。 图5 事件源配置 单击“事件目标”，在配置弹窗进行配置，配置完成单击“确定”（此处目标以函数为例）。
建 Serverless版事件流”。 左上角单击，配置事件流名称和描述，完成后单击“确定”。 配置RocketMQ事件源。 配置事件规则，本案例使用默认配置，如需其他规则请根据实际情况配置。 配置函数计算事件目标。 其中“规则配置”中的“类型”参数选择“变量”，“参数”及“模板”示例如下：
自定义事件源参数说明 参数名称 说明 通道配置 配置类型 支持以下两种类型： 选择：选择一个已创建的自定义事件通道。 新建：创建一个新的自定义事件通道。 通道 “配置类型”为“选择”时，在下拉列表中选择一个已创建的自定义事件通道，例如：channel。 “配置类型”为“新建”时，输入事件通道名称。
新建：创建一个新的自定义事件源。 事件源 “配置类型”为“选择”时，在下拉列表中选择一个已关联自定义事件通道的自定义事件源，此自定义事件通道为订阅绑定的自定义事件通道（即“通道配置”中“通道”的参数值）。 “配置类型”为“新建”时，输入自定义事件源名称。 描述 仅在“配置类型”为“新建”时，需要设置此参数。
模板 My name is ${name} My name is test01 在创建事件订阅-配置事件目标，事件目标配置为“FunctionGraph（函数计算）”时，若内容转换规则配置为“透传”，无法将事件内容作为输入值传递至事件目标。如需将事件内容作为函数流输入值，可以通过“
登录事件网格控制台。 在左侧导航栏选择“事件流”，进入“事件流”页面。 在待修改描述信息的事件流所在行，单击“配置”，进入事件流详情页。 单击事件流名称旁的编辑图标，弹出“配置名称和描述”弹窗。 修改名称和描述，单击“确定”，完成修改。 修改事件流的状态 登录事件网格控制台。 在左侧
目标连接功能需要使用函数工作流服务打通用户VPC网络，需要用户必须为函数工作流服务配置具备VPC管理权限的委托。 DNS ReadOnlyAccess 目标连接功能需要使用函数工作流服务打通用户VPC网络，需要用户必须为函数工作流服务配置具备读取云解析服务资源权限的委托。 首次创建自定义事件源“事件
参考表1，填写自定义事件源的配置信息。 表1 RabbitMQ事件源参数说明 参数名称 说明 配置类型 支持以下两种类型： 选择：选择一个已创建的自定义事件通道。 新建：创建一个新的自定义事件通道。 通道 “配置类型”为“选择”时，在下拉列表中选择一个已创建的自定义事件通道。 “配置类型”为“新建”时，输入事件通道名称和描述信息。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
