URI PUT /v1/{project_id}/eventrouter/clusters/{cluster_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户资源空间ID cluster_id 是 String 集群ID 请求参数
" : "fac59513-6c18-4266-bc81-5d412dfc1925", "name" : "cluster-ifpcv5u4", "description" : "", "source_type" : "KAFKA", "sink_type" : "
URI GET /v1/{project_id}/eventrouter/clusters/{cluster_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户资源空间ID cluster_id 是 String 集群ID 请求参数
URI DELETE /v1/{project_id}/eventrouter/clusters/{cluster_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户资源空间ID cluster_id 是 String 集群ID 请求参数
AK/SK认证:通过AK(Access Key ID)/SK(Secret Access Key)加密调用请求。推荐使用AK/SK认证,其安全性比Token认证要高。 约束与限制 AK/SK签名认证方式仅支持消息体大小12M以内,12M以上的请求请使用Token认证。
管理Serverless版事件流 创建事件流 编辑事件流 删除事件流 RocketMQ采集函数错误码 父主题: 事件流
Serverless版事件流概述 事件流对事件源产生的事件实时拉取、过滤及转换,并路由至事件目标,是一种更为实时、轻量和高效的端到端的流式数据处理场景。 图1 事件流示意图 EG事件流目前处于公测阶段,欢迎您试用和体验相关的功能。 父主题: 事件流
表2 常用操作与系统策略的关系 操作 EG FullAccess EG Publisher EG ReadOnlyAccess EG CommonAccess 创建事件订阅 说明: 如果创建函数、事件网格EG或SMN为事件目标时,需要获取对应操作的权限,具体可参考表3。
计费模式:按需计费 区域:与事件网格所在区域保持一致 项目:选择默认项目 可用区:根据默认项配置 实例名称:输入“eg-kafka” 企业项目:选择“default” 规格类型:默认 版本:3.x CPU架构:x86计算 代理规格:kafka.2u4g.cluster.small
权限策略和授权项 如果您需要对您所拥有的事件网格服务进行精细的权限管理,您可以使用统一身份认证服务(Identity and Access Management,简称IAM),如果华为云账号已经能满足您的要求,不需要创建独立的IAM用户,您可以跳过本章节,不影响您使用事件网格服务的其它功能
DCS实例仅支持5.0的版本的单机,主备和Cluster集群。 确保源DCS和目标DCS实例的规格、实例类型、存储空间需保持一致,否则不支持同步事件流。 DCS实例需要打开eventLog配置、关闭appendonly(DCS单机实例无该参数)配置。
否 String AccessKey secret_key 否 String SecretKey message_model 是 String 订阅方式 addr_type 是 String 接入点类型 addr 是 String 地址 sdk_url 是 String 依赖SDK
表3 请求Body参数 参数 是否必选 参数类型 描述 cluster_id 是 String 专业版事件流集群ID name 是 String 作业名称。约束:作业名称由大小英文字母、数字、点、中划线和下划线组成,必须以大小英文字母或数字开头,最多128个字符。
表3 请求Body参数 参数 是否必选 参数类型 描述 cluster_id 是 String 专业版事件流集群ID name 是 String 作业名称。约束:作业名称由大小英文字母、数字、点、中划线和下划线组成,必须以大小英文字母或数字开头,最多128个字符。
"results" : [ { "check_item_name" : "SOURCE_NETWORK", "name" : "源端连通性", "content" : "检查数据传输服务器是否能够连通源端服务", "status" : "SUCCESS
投递详情 表6 DeliverTarget 参数 参数类型 描述 deliverTargetId String 投递目标ID,即事件目标ID deliverTargetName String 投递目标名称,及事件目标名称 deliverStatus String 投递状态 SUCCESS
否 String AccessKey secret_key 否 String SecretKey message_model 是 String 订阅方式 addr_type 是 String 接入点类型 addr 是 String 地址 sdk_url 是 String 依赖SDK
limit=1000&offset=0 响应示例 状态码:200 请求成功 { "size" : 1, "total" : 1, "items" : [ { "cluster_id" : "fac59513-6c18-4266-bc81-5d412dfc1925
编辑事件流 事件流创建成功后,支持修改事件流的名称、描述、状态、事件源和事件目标。 修改事件流的名称和描述 登录事件网格控制台。 在左侧导航栏选择“事件流”,进入“事件流”页面。 在待修改描述信息的事件流所在行,单击“配置”,进入事件流详情页。 单击事件流名称旁的编辑图标,弹出“配置名称和描述
cluster_id=abc&limit=1000&offset=0 响应示例 状态码:200 请求成功 { "size" : 1, "total" : 1, "items" : [ { "cluster_id" : "fac59513-6c18-4266-bc81
您即将访问非华为云网站,请注意账号财产安全