检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
事件流名称,租户下唯一,由字母、数字、点、下划线和中划线组成,必须字母或数字开头 最小长度:1 最大长度:128 description 否 String 事件流描述 最大长度:255 source 是 EventStreamingSource object 事件源,一个事件流中事件源只有一个 sink 是 EventStreamingSink
事件源产生的事件与过滤规则进行匹配,匹配成功后事件才会被路由到与过滤规则关联的事件目标。过滤规则必须和匹配的事件具有相同的结构。 本章节介绍过滤规则和事件匹配时的规则,以及构成过滤规则的参数:运算操作符、条件表达式和匹配字段。 匹配规则 过滤规则和事件匹配时,需要遵循以下规则: 顶级匹配字段只支持source、type、subject、data。
集群名称:用户自定义,集群名称由大小英文字母、数字、点、中划线和下划线组成,必须以大小英文字母或数字开头,最多128个字符。 描述:用户自定义。 源库和目标库配置。 源库类型:“Kafka”、“RocketMQ”和“DCS”。 目标库类型:“Kafka”、“RocketMQ”和“DCS”。 集群节点规格:默认“10
事件流名称,租户下唯一,由字母、数字、点、下划线和中划线组成,必须字母或数字开头 最小长度:1 最大长度:128 description String 事件流描述 最大长度:255 source EventStreamingSource object 事件源,一个事件流中事件源只有一个 sink EventStreamingSink
事件流名称,租户下唯一,由字母、数字、点、下划线和中划线组成,必须字母或数字开头 最小长度:1 最大长度:128 description String 事件流描述 最大长度:255 source EventStreamingSource object 事件源,一个事件流中事件源只有一个 sink EventStreamingSink
事件流名称,租户下唯一,由字母、数字、点、下划线和中划线组成,必须字母或数字开头 最小长度:1 最大长度:128 description 否 String 事件流描述 最大长度:255 source 是 EventStreamingSource object 事件源,一个事件流中事件源只有一个 sink 是 EventStreamingSink
”。 在桶列表单击已创建的桶“eg-obs”,进入“对象”页面。 进入待上传的文件夹,单击“上传对象”,系统弹出“上传对象”对话框。 上传一个本地已准备好的文件,单击“上传”。 更多上传对象文件的方法请参考上传对象。 图1 上传对象 父主题: 实施步骤
端增加授权配置,以提高安全性。 当请求头和值校验不通过时,是否加密选项置灰无法选择。 key(请求头):由大小写英文字母和中划线组成,且必须以大小写字母开头和结尾,最大长度256个字符。 value:由大小写英文字符、中划线、下划线、空格和特殊字符“~!@#$%^&*()=+|[{}];:'"
Serverless版事件流”,进入“Serverless版事件流”页面。 单击“创建Serverless版事件流”,然后单击左上角图标,输入事件流名称和描述,完成后单击“确定”。 请参考配置分布式消息服务 Kafka版,配置事件源。 配置事件目标。 单击“事件目标”,右侧弹出“事件目标”弹窗。
使用AK/SK认证时,签名SDK只提供签名功能,与服务提供的SDK不同,使用时请注意。 Token认证 Token的有效期为24小时,需要使用一个Token鉴权时,可以先缓存起来,避免频繁调用。 Token在计算机系统中代表令牌(临时)的意思,拥有Token就代表拥有某种权限。Tok
选择目标连接。 目前只能选择与队列类型匹配的目标连接。 Topic 选择Topic。 如果事件目标与死信队列使用同一个Topic,EG将无法区分事件成功与失败,不推荐您配置同一个Topic。 单击“确定”,完成死信配置。 处理死信队列数据 当数据发送到死信队列后,您可以参考以下方法,来处理死信数据。
cn/op-help-center/doc/article/67668 请下载1.4.0版本的 Java SDK 将jar包打包成zip文件 参考创建桶,创建一个OBS桶,桶的区域与EG服务的区域保持一致,其“桶策略”需为“公共读”或“公共读写”。 参考上传文件,在桶的根目录下上传打包的ZIP文件。
fka实例,详情请参见购买Kafka实例。 Kafka实例中的安全组在“入方向规则”中放开Kafka实例的子网网段和端口,详情请参见查看子网网段、Kafka实例端口和添加安全组规则。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”,进
CloudEvents 参数 是否必选 参数类型 描述 id 是 String 事件唯一标识串,同一个事件来源里必须唯一 source 是 String 事件来源上下文标识串,source+id可以唯一确定一个事件。采用URI-Reference格式,参考https://tools.ietf.
最大长度:16384 表3 请求Body参数 参数 是否必选 参数类型 描述 name 是 String 目标连接名称,租户下唯一,由字母、数字、点、下划线和中划线组成,必须以字母或数字开头,不能为default 最小长度:1 最大长度:128 description 否 String 目标连接描述
CloudEvents 参数 是否必选 参数类型 描述 id 是 String 事件唯一标识串,同一个事件来源里必须唯一 source 是 String 事件来源上下文标识串,source+id可以唯一确定一个事件。采用URI-Reference格式,参考https://tools.ietf.
SubscriptionSource objects 订阅的事件源列表, 当前仅支持订阅一个事件源 数组长度:1 - 1 targets 是 Array of SubscriptionTarget objects 事件目标列表,至少订阅一个事件目标 表4 SubscriptionSource 参数 是否必选
响应Body参数 参数 参数类型 描述 id String 事件源ID name String 目标连接名称,租户下唯一,由小写字母、数字、点、下划线和中划线组成,必须以字母或数字开头,不能为default description String 目标连接描述 status String 目标连接状态
响应Body参数 参数 参数类型 描述 id String 事件源ID name String 目标连接名称,租户下唯一,由小写字母、数字、点、下划线和中划线组成,必须以字母或数字开头,不能为default description String 目标连接描述 status String 目标连接状态
ConnectionInfo 参数 参数类型 描述 id String 事件源ID name String 目标连接名称,租户下唯一,由小写字母、数字、点、下划线和中划线组成,必须以字母或数字开头,不能为default description String 目标连接描述 status String 目标连接状态