检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
基于Serverless版事件流实现RocketMQ推送事件至函数工作流服务 本文介绍如何通过事件网格服务的事件流功能将RocketMQ产生的事件推送至函数工作流服务。 当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。
SASL证书地址 当Kafka实例开启SASL SSL时可见,输入SASL证书地址。获取地址请参考如何获取分布式消息服务Kafka实例的SASL证书地址。 说明: 必须使用zip压缩包,压缩包内的文件数量不超过两个,压缩包和文件大小均不可超过1M; 压缩包里证书的名称必须是固定的:client
在事件追踪中查看事件投递信息 在EG控制台界面,单击“事件通道”中对应的事件通道的“事件轨迹”可以看到该事件的投递详情和事件详情: 界面入口: 图1 界面入口 事件详情: 图2 事件详情 事件轨迹: 图3 事件轨迹 父主题: 实施步骤
JSON Array 否 运算符为范围比较时,操作条件范围 匹配字段 过滤规则和事件匹配时,使用的匹配字段如表3所示。 表3 匹配字段列表 字段名 条件值类型 示例说明 source JSON对象数组 事件源,条件值位于JSON数组中,source字段只支持“StringIn” 示例:
删除自定义事件通道 本章节介绍在事件网格控制台如何删除自定义事件通道。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件通道”,进入“事件通道”页面。 在待删除的自定义事件通道后,单击“删除”,弹出“删除事件通道”对话框。 已关联自定义事件源,或事件订阅的事件通道,无法删除
参考https://tools.ietf.org/html/rfc3339 subject 否 String 事件发生的主题或对象,用以标识哪个具体对象发生了当前事件 响应参数 状态码: 200 表5 响应Header参数 参数 参数类型 描述 X-Request-Id String
当通知方式选择通知组时,需要在此选择您的通知组,如您还未创建通知组,创建方式可参考创建通知对象/通知组。 通知对象 当通知方式选择主题订阅时,需要在此选择您的联系人和主题,若没有您想要选择的主题,创建方式可参考创建通知对象/通知组。 生效时间 该告警仅在生效时间段发送通知消息,非生效时段则在隔日生效时段发送通知消息。
路由到函数工作流 本章节介绍在创建事件流时如何配置函数工作流 FunctionGraph为事件目标。 前提条件 已开通FunctionGraph并创建函数作为事件目标。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”,进入“Serverless版事件流”页面。
解决方式:返回配置专享版事件流作业的第二步,即“源和目标对象配置”页面,重新选择符合实例版本要求的实例作为源端实例。 原因二:目标端RocketMQ实例版本不支持,请选择符合要求的实例。 解决方式:返回配置专享版事件流作业的第二步,即“源和目标对象配置”页面,重新选择符合实例版本要求的实例作为目标端实例。
当通知方式选择通知组时,需要在此选择您的通知组,如您还未创建通知组,创建方式可参考创建通知对象/通知组。 通知对象 当通知方式选择主题订阅时,需要在此选择您的联系人和主题,若没有您想要选择的主题,创建方式可参考创建通知对象/通知组。 生效时间 该告警仅在生效时间段发送通知消息,非生效时段则在隔日生效时段发送通知消息。
解决方式:返回配置专享版事件流作业的第二步,即“源和目标对象配置”页面,重新选择符合实例版本要求的实例作为源端实例。 原因二:目标端Kafka实例版本不支持,请选择符合要求的实例。 解决方式:返回配置专享版事件流作业的第二步,即“源和目标对象配置”页面,重新选择符合实例版本要求的实例作为目标端实例。
当通知方式选择通知组时,需要在此选择您的通知组,如您还未创建通知组,创建方式可参考创建通知对象/通知组。 通知对象 当通知方式选择主题订阅时,需要在此选择您的联系人和主题,若没有您想要选择的主题,创建方式可参考创建通知对象/通知组。 生效时间 该告警仅在生效时间段发送通知消息,非生效时段则在隔日生效时段发送通知消息。
购买RCU时套餐包,当月未使用完的RCU时下个月是否可以继续使用? 不可以,上个生效月RCU时余量不可以转结到下个生效月。 父主题: 计费FAQ
约束与限制 您能创建的事件网格资源的数量与配额有关系,如果您需要扩大配额,请参见关于配额。 更详细的限制请参见具体API的说明。 父主题: 使用前必读
方案概述 本文介绍如何通过事件网格服务的事件订阅功能将OBS应用事件源产生的事件路由至分布式消息服务Kafka版。 方案架构 本实践事件订阅架构图如下所示: 当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。
SASL证书地址 当Kafka实例开启SASL SSL时可见,输入SASL证书地址。获取地址请参考如何获取分布式消息服务Kafka实例的SASL证书地址。 说明: 必须使用zip压缩包,压缩包内的文件数量不超过两个,压缩包和文件大小均不可超过1M; 压缩包里证书的名称必须是固定的:client
终端节点 终端节点即调用API的请求地址,不同服务不同区域的终端节点不同,您可以从地区和终端节点中查询服务的终端节点。 父主题: 使用前必读
选择已创建的集群,如未创建,请参见专享版事件流集群。 作业名称 请输入作业名称。 场景类型 当前默认为同步。 描述 请输入对本作业的描述。 单击“下一步:源和目标对象配置”,进入“源和目标对象配置”页面。 图3 源数据和目标数据配置 表2 源数据和目标数据配置参数说明 参数 说明 配置类型 默认为“Rocketmq实例”。
已创建私网访问端点,其VPC及子网与RocketMQ实例相同。 已正确配置default安全组和RocketMQ实例所属的安全组规则,具体规则请参考创建事件源如何配置安全组。 创建RocketMQ事件源 登录事件网格控制台。 在左侧导航栏选择“事件源”,进入“事件源”页面。 单击“自定义事件源”,弹出“创建自定义事件源”对话框。
快速入门 场景描述 您可以根据业务需要创建一个自定义事件源。 API调用方法请参考如何调用API。 前提条件 已获取IAM的Endpoint,具体请参见地区和终端节点。 已获取事件网格的Endpoint,具体请参见地区和终端节点。 创建自定义事件源 调用创建自定义事件通道接口,创建一个自定义通道。