检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
查询事件流列表 功能介绍 查询事件流列表。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/eventstreamings 表1
布式消息服务RocketMQ版自定义事件源之前,需要正确配置安全组规则。 分布式消息服务所属的安全组“入方向规则”配置错误,会导致事件目标函数工作流无法消费事件; 用户default安全组“出方向规则”配置错误,事件源会创建失败。 配置安全组规则如下: 配置分布式消息服务Rabb
ECS 目前只支持写事件,不支持读事件。 查看事件类型 登录事件网格控制台。 在左侧导航栏选择“事件源”,进入“事件源”页面。 在“云服务事件源”页签,单击待查看事件类型的事件源名称,弹出“查看云服务事件源”对话框。 在“事件类型”区域,查看事件类型和对应的描述信息,如图2所示。 图1
触发器管理 包括查询单个函数的EG触发器、查询单个函数流的EG触发器。 访问端点管理 包括更新访问端点、删除访问端点、创建访问端点、查询访问端点。 obs桶管理 包括获取obs桶列表。 监控指标管理 包括查询事件通道监控指标数据、查询事件订阅监控指标数据。 事件流管理 包括创建事件流
错误码 当您调用API时,如果遇到“APIGW”开头的错误码,请参见API网关错误码进行处理。 状态码 错误码 错误信息 描述 处理措施 400 EG.00513000 invalid parameters 参数错误 请检查参数是否正确 400 EG.00513001 name duplicated
最大长度:64 detail 否 Detail object 订阅的事件目标参数列表,该字段序列化后总长度不超过1024字节,函数、函数流、webhook订阅目标必填,其中函数、函数流委托名称必填 kafka_detail 否 KafkaTargetDetail object 订阅的事件kaf
最大长度:64 detail 否 Detail object 订阅的事件目标参数列表,该字段序列化后总长度不超过1024字节,函数、函数流、webhook订阅目标必填,其中函数、函数流委托名称必填 kafka_detail 否 KafkaTargetDetail object 订阅的事件kaf
本章节介绍如何通过事件网格服务的事件订阅和函数工作流服务实现OBS桶的数据同步。 基于Serverless版事件流实现RocketMQ推送事件至函数工作流服务 本章节介绍如何通过事件网格服务的事件流功能将RocketMQ产生的事件推送至函数工作流服务。
您可以根据业务需要创建一个自定义事件源。 API调用方法请参考如何调用API。 前提条件 已获取IAM的Endpoint,具体请参见地区和终端节点。 已获取事件网格的Endpoint,具体请参见地区和终端节点。 创建自定义事件源 调用创建自定义事件通道接口,创建一个自定义通道。 POST
最大长度:64 detail 否 Detail object 订阅的事件目标参数列表,该字段序列化后总长度不超过1024字节,函数、函数流、webhook订阅目标必填,其中函数、函数流委托名称必填 kafka_detail 否 KafkaTargetDetail object 订阅的事件kaf
最大长度:64 detail 否 Detail object 订阅的事件目标参数列表,该字段序列化后总长度不超过1024字节,函数、函数流、webhook订阅目标必填,其中函数、函数流委托名称必填 kafka_detail 否 KafkaTargetDetail object 订阅的事件kaf
该指标用于统计事件接入的调用数量。 单位:个 ≥ 0 counts 事件通道 1分钟 success_num 成功数量 该指标用于统计事件接入的调用成功数量。 单位:个 ≥ 0 counts 事件通道 1分钟 fail_num 失败数量 该指标用于统计事件接入的调用失败数量。 单位:个
创建成功后,在“自定义事件源”页签,查看创建的事件源。 如果需要修改自定义事件源的描述信息,单击待修改事件源后的“编辑”,在弹出的对话框中编辑描述及相关参数信息。 如果需要查看自定义事件源的信息,单击待查看信息的事件源名称,在弹出的对话框中查看自定义事件源信息。 事件格式查看 前提条件: 创建rocketmq实例。
Long 事件大小 timestamp Long 时间戳 num Long 调用数 success_num Long 调用成功数 process_time Long 处理时间 invoke_time Long 调用时间 状态码: 400 表6 响应Body参数 参数 参数类型 描述 error_code
Integer 重试数 timestamp Long 时间戳 num Long 调用数 success_num Long 调用成功数 process_time Long 处理时间 invoke_time Long 调用时间 状态码: 400 表6 响应Body参数 参数 参数类型 描述 error_code
${name} 说明: 当事件目标为“FunctionGraph(函数计算)”,模板需为JSON格式,示例如下: {"name":"${name}"} My name is test01 说明: 当事件目标为“FunctionGraph(函数计算)”,转换后的事件结果如下: {"name": "test01"}
事件目标 路由到函数工作流 路由到分布式消息服务Kafka版 路由到对象存储服务OBS 父主题: 事件流
本节介绍如何在云审计服务管理控制台查看或导出最近7天的操作记录: 在新版事件列表查看审计事件 在旧版事件列表查看审计事件 使用限制 单账号跟踪的事件可以通过云审计控制台查询。多账号的事件只能在账号自己的事件列表页面去查看,或者到组织追踪器配置的OBS桶中查看,也可以到组织追踪器配置的CTS/system日志流下面去查看。
管理Serverless版事件流 创建事件流 编辑事件流 删除事件流 RocketMQ采集函数错误码 父主题: 事件流
删除自定义事件源 √ × × √ 查看事件源 √ × √ √ 创建事件通道 √ × × √ 更新事件通道 √ × × √ 删除事件通道 √ × × √ 查看事件通道 √ √ √ √ 创建目标连接 √ × × × 更新目标连接 √ × × √ 删除目标连接 √ × × √ 查看目标连接 √ × √