检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
最小值:0 最大值:100 items Array of CustomizeSchemaVersionItemInfo objects 对象列表 数组长度:0 - 100 表5 CustomizeSchemaVersionItemInfo 参数 参数类型 描述 id String 事件模型版本ID
Integer 总数 最小值:0 最大值:100 result Array of EventPubMetricsItem objects 指标列表 数组长度:0 - 100 表5 EventPubMetricsItem 参数 参数类型 描述 event_size Long 事件大小 timestamp
未满足前提条件,服务器未满足请求者在请求中设置的其中一个前提条件。 413 Request Entity Too Large 由于请求的实体过大,服务器无法处理,因此拒绝请求。为防止客户端的连续请求,服务器可能会关闭连接。如果只是服务器暂时无法处理,则会包含一个Retry-After的响应信息。 414
Integer 总数 最小值:0 最大值:100 result Array of EventSubMetricsItem objects 指标数据列表 数组长度:0 - 100 表5 EventSubMetricsItem 参数 参数类型 描述 fail_num Long 失败数 retry_success_num
”。 在桶列表单击已创建的桶“eg-obs”,进入“对象”页面。 进入待上传的文件夹,单击“上传对象”,系统弹出“上传对象”对话框。 上传一个本地已准备好的文件,单击“上传”。 更多上传对象文件的方法请参考上传对象。 图1 上传对象 父主题: 实施步骤
String 事件模型兼容性 枚举值: NONE provider_type String 提供方类型,OFFICIAL:官方事件源;CUSTOM:自定义事件源 枚举值: OFFICIAL CUSTOM format String 事件模型格式 number_of_versions Integer
Integer 本页数量 最小值:0 最大值:100 items Array of ObsBucketInfo objects 对象列表 数组长度:0 - 100 表5 ObsBucketInfo 参数 参数类型 描述 responseHeaders Object 响应头 originalHeaders
选择目标连接。 目前只能选择与队列类型匹配的目标连接。 Topic 选择Topic。 如果事件目标与死信队列使用同一个Topic,EG将无法区分事件成功与失败,不推荐您配置同一个Topic。 单击“确定”,完成死信配置。 处理死信队列数据 当数据发送到死信队列后,您可以参考以下方法,来处理死信数据。
String 事件源描述 provider_type String 事件源提供方类型,OFFICIAL:官方云服务事件源;CUSTOM:用户创建的自定义事件源;PARTNER:伙伴事件源 枚举值: OFFICIAL CUSTOM PARTNER event_types Array of event_types
默认为“Kafka实例”。 说明: 配置类型根据实例类型变更。 实例别名 请输入实例别名。 用于标识源端和目标端实例,建议同一个源端或目标端实例只设置一个别名。 区域 请选择资源所在区域。 项目 请选择项目。 Kafka实例 请选择Kafka实例。 接入方式 支持“明文接入”或“密文接入”。
size Integer 本页数量 最小值:0 最大值:100 items Array of EndpointInfo objects 对象列表 数组长度:0 - 100 表6 EndpointInfo 参数 参数类型 描述 id String 访问端点ID name String 用户指定的访问端点名称
在实例“基本信息>连接信息”页面,单击SSL证书旁的“下载”。 SSL证书将会下载到本地电脑,名字为“kafka-certs.zip”的文件。 参考创建桶,创建一个OBS桶,桶的区域与Kafka实例区域保持一致,其“桶策略”需为“公共读”或“公共读写”。 最新版的事件流支持私有桶获取证书。 参考上传文
subscription status 启动中的订阅不能编辑 请稍后重试 400 EG.00513003 invalid target address 自定义事件目标url参数错误 请检查事件目标url参数 400 EG.00513004 invalid filter parameters 事件源过滤规则配置参数错误
FunctionGraph(函数计算)参数说明 参数名称 说明 函数 选择需要触发的函数。如果还未创建函数,请先创建函数。 版本/别名 配置版本/别名,当选择其一时,则另外一个参数无需配置。 版本 选择函数的版本。当前默认选择“latest”。 别名 选择函数别名。 执行方式 默认“同步”。 委托 选择委托。如无
输入并发数,输入值范围1~1000。 建议并发数与选择的Topic的分区数保持一致,如果不一致可能会影响消息消费速率。当您选择Topic时,如果并发数为空会读取您选择的Topic的分区数作为并发数。 消费点位 选择消费点位。 最新点位:将会从消息队列的最新消息开始消费。 最早点位:将会从消息队列的最早消息开始消费。
description String 通道描述 provider_type String 通道提供方类型,OFFICIAL:官方事件通道;CUSTOM:自定义事件通道;PARTNER:伙伴事件通道 枚举值: OFFICIAL CUSTOM PARTNER created_time String 创建UTC时间
created_time String 创建时间 updated_time String 更新时间 definition String 事件模型内容定义 状态码: 400 表4 响应Body参数 参数 参数类型 描述 error_code String 错误码 最小长度:1 最大长度:128
使用AK/SK认证时,签名SDK只提供签名功能,与服务提供的SDK不同,使用时请注意。 Token认证 Token的有效期为24小时,需要使用一个Token鉴权时,可以先缓存起来,避免频繁调用。 Token在计算机系统中代表令牌(临时)的意思,拥有Token就代表拥有某种权限。Tok
而此时leader又无法提供服务,则消息会丢失。 acks=all:这意味着leader需要等待ISR中所有备份都成功写入日志,只有任何一个备份存活,数据都不会丢失。min.insync.replicas指定必须确认写入才能被认为成功的副本的最小数量。 缺省值:1 枚举值: 0
"test01", "state": "enable" } }] } 变量 从CloudEvents标准事件中获取变量值,将变量值按照模板定义的格式路由到事件目标。示例如下: 转换前的事件 转换类型 转换后的事件 { "events":[{ "id": "4b26115b-73e-cf74a******"