检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
发布事件 本章节介绍在事件网格控制台如何发布事件。 您可以通过发布事件功能,调试事件订阅中事件源、事件通道、事件目标是否已是连通状态,已配置的事件规则是否生效,事件是否成功发送到事件目标。 前提条件 已创建自定义事件通道 已创建自定义应用事件源 已设置事件目标,并基于上述内容创建事件订阅
网络配置。 虚拟私有云:选择已创建的虚拟私有云,如何创建请参见创建虚拟私有云和子网。 子网:选择已创建的子网,如何创建请参见为虚拟私有云创建新的子网。 请确保事件流集群配置的虚拟私有云、子网与Kafka或RocketMQ的源端实例、目标端实例配置的虚拟私有云、子网的网络互通,否则连通性测试不通过。
登录分布式消息服务Kafka版控制台,选择Kafka实例所在的区域。 在“Kafka专享版”页面,单击已创建的Kafka实例的名称,进入实例详情页面。 在“Topic管理”页签,单击“创建Topic”,弹出“创建Topic”对话框。 参考图1配置Topic参数,Topic名称配置为“topic-eg”,其他参
用户名 请输入用户名。 说明: 当接入方式选择“密文接入”时需配置。 密码 请输入密码。 说明: 当接入方式选择“密文接入”时需配置。 单击“下一步:高级配置”,进入“高级配置”页面。 图2 高级配置 表3 作业对象配置参数说明 参数 说明 Topic匹配类型 选择“正则匹配”或“精确匹配”。
启用死信队列后EG会把处理失败的事件发送到配置的队列中,若不启用则处理失败的事件将被丢弃。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件订阅”,进入“事件订阅”页面。 单击“创建事件订阅”。 单击“事件目标”。 在弹窗中选择“事件目标”。 启用“死信队列”,并配置参数。 图1 配置死信队列 表1
事件规则 事件流支持配置规则,默认会将消息透传至目标。 事件规则是指事件流转到事件目标之前,将CloudEvents标准事件转换成事件目标可以接受的事件类型。 事件流支持事件过滤和转换,具体规则请参考事件规则。 父主题: 事件流
单击“创建事件路由任务”,进入创建详情页。 配置“任务基本配置”。 图2 任务基本配置 表1 任务基本配置参数说明 参数 说明 任务名称 请输入任务名称 描述 请输入对本任务的描述。 配置“源端和目标端配置”。 当源端和目标端均为Kafka时: 图3 源端和目标端配置 源端类型:Kafka 目标端类型:Kafka
密钥 请输入密钥。 单击“下一步:高级配置”,进入“高级配置”页面。 图2 高级配置 RocketMQ同步事件流当前仅支持同步普通消息和顺序消息。若您配置Topic的消息类型是其它类型时,则该消息类型的Topic消息将不会被同步。 表3 作业对象配置参数说明 参数 说明 Topic匹配类型
单击“创建事件订阅”。 单击“事件源”,在配置弹窗进行配置,配置完成单击“确定”。 提供方选择“自定义”。 通道:选择账号B创建的通道。 事件源:输入账号A创建的事件源(与账号A的订阅的事件源保持一致)。 图5 事件源配置 单击“事件目标”,在配置弹窗进行配置,配置完成单击“确定”(此处目标以函数为例)。
根据默认值配置,无需修改。配置过滤规则请参考过滤规则参数说明。 对象名前缀、对象名后缀填写时,对象文件格式必须都符合才能触发事件,当前后缀为空时,任意对象文件都符合。 创建事件订阅时,如果选择的OBS桶有被其他事件订阅调用,请确保当前桶的对象名前缀和后缀与其他事件订阅中配置的对象名前
如何过滤最终传输到事件目标的事件? 您可以在事件订阅中通过配置事件过滤规则来筛选最终路由到事件目标的事件。 事件源产生的事件与过滤规则进行匹配,匹配成功后事件才会被路由到与过滤规则关联的事件目标。过滤规则必须和匹配的事件具有相同的结构。 关于事件过滤规则的更多信息,请参见过滤规则参数说明。
请确保您选择的委托已被授权的权限包含“smn:topic:publish”。 消息标题配置:“类型”配置为“常量”或“变量”。 类型:消息标题的类型。支持以下两种类型。 常量:将指定的常量作为消息标题。若选择常量,所有消息的消息标题都是相同的。 变量:从CloudEvents标准事件中
查询配额 功能介绍 查询当前租户的配额,未特殊配置过的会返回默认配额。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/quotas
事件网格通过事件内容转换将CloudEvents标准事件转换成事件目标可以处理的类型。 事件网格支持的转换类型如下:透传、变量、常量。 透传 事件网格不对事件进行转换,将CloudEvents标准事件直接路由到事件目标。示例如下: 转换前的事件 转换类型 转换后的事件 { "events":[{ "id":
件权限将事件发布到目标账号的通道中。 委托场景 首次创建目标连接时,系统会自动弹出创建委托授权界面,同意授权后,EG将在统一身份认证服务为您创建名为EG_DELEGATE_FG_AGENCY的委托。授权成功后,您可以在IAM控制台的委托列表中查看已创建的委托。 表2 EG_DEL
事件流创建成功后,支持修改事件流的名称、描述、状态、事件源和事件目标。 修改事件流的名称和描述 登录事件网格控制台。 在左侧导航栏选择“事件流”,进入“事件流”页面。 在待修改描述信息的事件流所在行,单击“配置”,进入事件流详情页。 单击事件流名称旁的编辑图标,弹出“配置名称和描述”弹窗。
如果需要修改自定义事件源的描述信息,单击待修改事件源后的“编辑”,在弹出的对话框中编辑描述及相关参数信息。 如果需要查看自定义事件源的信息,单击待查看信息的事件源名称,在弹出的对话框中查看自定义事件源信息。 如果发送事件界面配置的事件源为新事件源(事件源列表查询不到),发送事件后,无法在CES服务监控里查询到监控信息。
函数 选择需要触发的函数。如果还未创建函数,请先创建函数。 版本/别名 配置版本/别名,当选择其一时,则另外一个参数无需配置。 版本 选择函数的版本。当前默认选择“latest”。 别名 选择函数别名。 执行方式 默认“同步”。 委托 选择委托。如无委托,可单击旁边的“快速创建委托”
输入并发数,输入值范围1~1000。 建议并发数与选择的Topic的分区数保持一致,如果不一致可能会影响消息消费速率。当您选择Topic时,如果并发数为空会读取您选择的Topic的分区数作为并发数。 消费点位 选择消费点位。 最新点位:将会从消息队列的最新消息开始消费。 最早点位:将会从消息队列的最早消息开始消费。
请确保您选择的委托已被授权的权限包含“smn:topic:publish”。 消息标题配置:“类型”配置为“常量”或“变量”。 类型:消息标题的类型。支持以下两种类型。 常量:将指定的常量作为消息标题。若选择常量,所有消息的消息标题都是相同的。 变量:从CloudEvents标准事件中