检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
查询专业版事件流作业列表 功能介绍 查询专业版事件流作业列表 URI GET /v1/{project_id}/eventrouter/jobs 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户资源空间ID 表2 Query参数 参数 是否必选
表4 请求Body参数 参数 是否必选 参数类型 描述 cluster_id 是 String 集群ID source_config 否 EventRouterJobSource object 专业版事件流作业源端配置 sink_config 否 EventRouterJobSink
scene_type 是 String 场景类型，DISASTER_BACKUP：同步任务 source_config 否 EventRouterJobSource object 专业版事件流作业源端配置 sink_config 否 EventRouterJobSink object
删除专业版事件流作业 功能介绍 删除专业版事件流作业 URI DELETE /v1/{project_id}/eventrouter/jobs/{job_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户资源空间ID job_id
scene_type 是 String 场景类型，DISASTER_BACKUP：同步任务 source_config 否 EventRouterJobSource object 专业版事件流作业源端配置 sink_config 否 EventRouterJobSink object
操作专业版事件流作业 功能介绍 操作专业版事件流作业 URI POST /v1/{project_id}/eventrouter/jobs/{job_id}/action 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户资源空间ID job_id
查询专业版事件流作业详情 功能介绍 查询专业版事件流作业详情 URI GET /v1/{project_id}/eventrouter/jobs/{job_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户资源空间ID job_id
查看专业版事件流作业同步情况 功能介绍 查看专业版事件流作业同步情况 URI POST /v1/{project_id}/eventrouter/jobs/{job_id}/syncDetail 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String
参考创建桶，创建一个OBS桶，桶的区域与Kafka实例区域保持一致，其“桶策略”需为“公共读”或“公共读写”。 参考上传文件，在桶的根目录下上传“kafka-certs.zip”文件。 参考如下格式获取SASL证书地址: https://{bucketname}.obs.
阶梯计费：例如对象存储，根据“使用量”单位价格“时长”计算出价格后，截取到“分”扣费。 在按需付费模式下，价格计算器上的金额如果遇小数点，则保留小数点后两位，第三位四舍五入。如遇四舍五入后不足￥0.01 ，则按￥0.01 展示。
如下表所示，过滤规则匹配“source”为“HC.OBS”的事件。
图3 云服务事件源配置参数 如果“事件源”选择“OBS应用事件源”，请参考表2。同时，需用户的华为云账号添加“Tenant Administrator”权限，如何授权请参见依赖角色的授权方法。 表2 OBS应用事件源参数说明 参数名称 说明 事件源 选择事件源。
", "eTag": "$.data.obs.object.eTag", "sequencer": "$.data.obs.object.sequencer", "key": "$.data.obs.object.key", "size": "$.data.obs.object.size
事件示例 事件源发布到事件网格的事件示例如下： { "events":[{ "id": "4b26115b-778e-11ec-833e-cf74******", "specversion": "1.0", "source": "HC.OBS", "type
表16 SinkObsParameters 参数 参数类型 描述 access_key String AK secret_key String SK obs_bucket String 桶 obs_path String 转储目录 time_format String 时间目录格式
表1 EG最佳实践一览表 最佳实践 说明 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版 本章节介绍如何通过事件网格服务的事件订阅功能将OBS应用事件源产生的事件路由至分布式消息服务Kafka版。
请检查证书下载地址 400 EGS.00516012 Download OBS file failed. 下载OBS文件失败。 请联系管理员 400 EGS.00516013 Upload file to OBS failed. 文件上传OBS失败。
表14 SinkObsParameters 参数 参数类型 描述 access_key String AK secret_key String SK obs_bucket String 桶 obs_path String 转储目录 time_format String 时间目录格式
表13 SinkObsParameters 参数 是否必选 参数类型 描述 access_key 是 String AK secret_key 是 String SK obs_bucket 是 String 桶 obs_path 否 String 转储目录 time_format
表13 SinkObsParameters 参数 是否必选 参数类型 描述 access_key 是 String AK secret_key 是 String SK obs_bucket 是 String 桶 obs_path 否 String 转储目录 time_format
