检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
事件提供方选择“分布式消息服务 Kafka版”。 设置事件源参数。 图1 事件源-Kafka 表1 配置参数说明 参数名称 说明 实例 选择Kafka实例。 Topic 选择Topic。 消费组 输入消费组。 并发数 输入并发数,输入值范围1~1000。 建议并发数与选择的Topic的分区数保持一致,
过滤规则参数说明 事件源产生的事件与过滤规则进行匹配,匹配成功后事件才会被路由到与过滤规则关联的事件目标。过滤规则必须和匹配的事件具有相同的结构。 本章节介绍过滤规则和事件匹配时的规则,以及构成过滤规则的参数:运算操作符、条件表达式和匹配字段。 匹配规则 过滤规则和事件匹配时,需要遵循以下规则:
并发消费,尽可能按照时间顺序处理。 单击“下一步”,进入规则配置页面,规则配置可参考过滤规则参数说明。 图2 规则配置 单击“下一步”完成规则配置,您可以参考路由到函数工作流,继续配置事件流的事件目标。 事件源配置为分布式消息服务RocketMQ版时,配置事件目标为FunctionGraph(函数
可,详情请参见创建Kafka消费组。 并发数 输入并发数,输入值范围1~1000。 建议并发数与选择的Topic的分区数保持一致,如果不一致可能会影响消息消费速率。当您选择Topic时,如果并发数为空会读取您选择的Topic的分区数作为并发数。 消费点位 选择消费点位。 最新点位:将会从消息队列的最新消息开始消费。
表1 FunctionGraph(函数计算)参数说明 参数名称 说明 函数 选择需要触发的函数。如果还未创建函数,请先创建函数。 版本/别名 配置版本/别名,当选择其一时,则另外一个参数无需配置。 版本 选择函数的版本。当前默认选择“latest”。 别名 选择函数别名。 执行方式
后单击“确定”。 请参考配置分布式消息服务 Kafka版,配置事件源。 配置事件目标。 单击“事件目标”,右侧弹出“事件目标”弹窗。 目标服务选择“对象存储服务OBS”。 设置事件目标参数。 图1 对象存储服务OBS 表1 对象存储服务OBS参数说明 参数名称 说明 AK 请输入AK。
请参考配置分布式消息服务 Kafka版,配置事件源。 配置事件目标。 单击“事件目标”,右侧弹出“事件目标”弹窗。 目标服务选择“分布式消息服务 Kafka版”。 设置事件目标参数。 图1 分布式消息服务 Kafka版 表1 分布式消息服务 Kafka版参数说明 参数名称 说明
创建事件订阅时,如果选择的OBS桶有被其他事件订阅调用,请确保当前桶的对象名前缀和后缀与其他事件订阅中配置的对象名前缀和后缀不一致。否则,保存事件订阅时,会报“OBS桶对象名前缀或后缀冲突”错误。 配置事件目标。 配置如下事件目标参数: 选择提供方:华为云 事件目标:分布式消息服务 Kafka版 目标连接:选择“kafka-connect”
/v1/{project_id}/eventstreamings 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID 表2 Query参数 参数 是否必选 参数类型 描述 offset 否 Integer 偏移量,表示从此偏移量开始查询,偏移量不能小于0
eaming_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID eventstreaming_id 是 String 事件流ID 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token
/v1/{project_id}/eventstreamings 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Tok
eaming_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID eventstreaming_id 是 String 事件流ID 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token
完成事件流名称和描述信息输入。 配置事件源。 单击“事件源”,右侧弹出“事件源”弹窗。 选择事件源提供方。 设置事件源参数。 完成后单击“下一步”。 配置规则。 单击“规则”,右侧弹出“规则”弹窗。 配置规则模式内容。 完成后单击“下一步”。 配置事件目标。 单击“事件目标”,右侧弹出“事件目标”弹窗。
事件目标未被触发的原因? 事件目标未被触发,可能是以下原因导致: 目标函数参数填写错误。 在事件订阅中使用函数工作流中的函数作为事件目标时,检查选择的源、package、函数名是否与预期相符。 事件目标的规则配置错误。 在事件订阅中配置事件目标时,检查选择的转换类型是否与预期相符。 自定义事件目
GET /v1/{project_id}/connections 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID 表2 Query参数 参数 是否必选 参数类型 描述 offset 否 Integer 偏移量,表示从此偏移量开始查询,偏移量不能小于0
配置监控告警 本章节主要介绍部分监控指标的告警策略,以及配置操作。在实际业务中,建议按照以下告警策略,配置监控指标的告警规则。 表1 事件流监控告警配置参数说明 参数 参数说明 名称 系统会随机产生一个名称,用户也可以进行修改。 描述 告警规则描述(此参数非必填项)。 告警类型 告警规则适用的告警类型,默认为指标。
配置监控告警 本章节主要介绍部分监控指标的告警策略,以及配置操作。在实际业务中,建议按照以下告警策略,配置监控指标的告警规则。 表1 事件订阅监控告警配置参数说明 参数 参数说明 名称 系统会随机产生一个名称,用户也可以进行修改。 描述 告警规则描述(此参数非必填项)。 告警类型
配置监控告警 本章节主要介绍部分监控指标的告警策略,以及配置操作。在实际业务中,建议按照以下告警策略,配置监控指标的告警规则。 表1 事件通道监控告警配置参数说明 参数 参数说明 名称 系统会随机产生一个名称,用户也可以进行修改。 描述 告警规则描述(此参数非必填项)。 告警类型
需要您创建授权委托,详情请查看授权委托。 创建目标连接成功后,不支持修改Kafka实例参数。 参考Kafka目标连接参数说明,填写目标连接的配置信息。 表2 Kafka目标连接参数说明 参数 说明 类型 选择“分布式消息服务 Kafka版”。 名称 您自定义的目标连接名称。 目
解更多过滤规则的信息,请参考过滤规则参数说明和过滤规则示例。 图1 云服务事件源配置参数 当提供方为“自定义”时,设置如表2所示参数。 已创建的订阅,无法修改已绑定的自定义事件通道。 表2 自定义事件源参数说明 参数名称 说明 事件源配置 配置类型 支持以下两种类型: 选择:选择