检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
used Array of SubscriptionUsedInfo objects 标签信息 sources Array of SubscriptionSourceInfo objects 订阅源列表 targets Array of SubscriptionTargetInfo objects
used Array of SubscriptionUsedInfo objects 标签信息 sources Array of SubscriptionSourceInfo objects 订阅源列表 targets Array of SubscriptionTargetInfo objects
Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/subscriptions/obsbuckets 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID 表2
获取项目ID的接口为“GET https://{Endpoint}/v3/projects”,其中{Endpoint}为IAM的终端节点,可以从地区和终端节点获取。接口的认证鉴权请参见认证鉴权。 响应示例如下,其中projects下的“id”即为项目ID。 { "projects":
items Array of SubscriptionInfo objects 对象列表 数组长度:0 - 100 表5 SubscriptionInfo 参数 参数类型 描述 id String 订阅ID name String 订阅名称 description String 订阅描述 type
items Array of SubscriptionInfo objects 对象列表 数组长度:0 - 100 表5 SubscriptionInfo 参数 参数类型 描述 id String 订阅ID name String 订阅名称 description String 订阅描述 type
SSL证书将会下载到本地电脑,名字为“kafka-certs.zip”的文件。 参考创建桶,创建一个OBS桶,桶的区域与Kafka实例区域保持一致,其“桶策略”需为“公共读”或“公共读写”。 最新版的事件流支持私有桶获取证书。 参考上传文件,在桶的根目录下上传“kafka-certs.zip”文件。 参考如下格式获取SASL证书地址:
访问端点管理 更新访问端点 删除访问端点 创建访问端点 查询访问端点 父主题: API
填写函数配置信息。输入基础配置信息,完成后单击“创建函数”,具体详情请参见创建函数。 进入新建的函数详情页。 在“代码”页签,代码选择“上传自ZIP文件”,上传样例代码中的程序包。 在“设置 > 环境变量”页签,输入环境信息,完成后单击“保存” 表1 参数说明 参数 说明 obs_endpoint
访问端点创建成功后,子网不支持修改。 描述 访问端点的描述信息。 单击“确定”,完成访问端点的创建。 创建访问端点会为您创建VPC终端节点,将产生VPC终端节点费用,当您不使用访问端点时请及时删除。 创建访问端点成功后,不支持修改虚拟私有云和子网。 编辑私网访问端点 访问端点创建成功后,支持修改访问端点的描述信息。
分布式消息服务Kafka版 本章节介绍在创建事件流时,如何配置分布式消息服务Kafka版实例为事件源。 前提条件 已在分布式消息服务Kafka版中购买Kafka实例,详情请参见购买Kafka实例。 Kafka实例中的安全组在“入方向规则”中放开Kafka实例的子网网段和端口,详情请参见查看子网网段、Kafka实例端口和添加安全组规则。
使用前必读 概述 调用说明 终端节点 约束与限制 基本概念
同步消费进度 是。 说明: 开启时表示将消息消费进度同步到目标Kafka。 启动偏移量 否。 压缩算法 是,可选择压缩算法为“none”、“gzip”、“snappy”、“lz4”或“zstd”。 单击“下一步:预检查”,进入“预检查”页面,完成后单击“完成配置”。 图4 预检查 父主题:
创建事件订阅 subscription CreateSubscription 更新事件订阅 subscription UpdateSubscription 删除事件订阅 subscription DeleteSubscription 操作事件订阅 subscription OperateSubscription
事件源的方法。 前提条件 (可选)创建自定义事件源前,需要先创建自定义事件通道。 已购买分布式消息服务RocketMQ版实例,实例中已创建Topic,且实例状态处于“运行中”。具体步骤,请参考购买实例。 已创建私网访问端点,其VPC及子网与RocketMQ实例相同。 已正确配置d
删除访问端点 功能介绍 删除访问端点。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI DELETE /v1/{project_id}/endpoints/{endpoint_id}
表示用于传输请求的协议,当前所有API均采用HTTPS协议。 Endpoint: 指定承载REST服务端点的服务器域名或IP,不同服务不同区域的Endpoint不同,您可以地区和终端节点获取。 例如IAM服务在“华北-北京一”区域的Endpoint为“iam.cn-north-1.myhuaweicloud
在事件订阅中配置事件目标时,检查选择的转换类型是否与预期相符。 自定义事件目标中,地址存在拼写错误、非法域名、无效IP等情况。 检查域名或IP地址是否正确配置。IP地址不能配置为保留IP地址,例如:全0地址/环回地址/ECS链路地址169.254/受限广播地址等。
自动创建的Topic副本数,不能超过目标端Kafka的Broker数量。 启动偏移量 请选择为“最早”或“最新”。 压缩算法 请选择压缩算法为“none”、“gzip”、“snappy”、“lz4”或“zstd”。 Topic映射 请输入要映射的源端Topic和目标端Topic名称,单击“保存”。 说明:
/v1/{project_id}/subscriptions/{subscription_id} eg:subscriptions:update √ x 删除事件订阅 DELETE /v1/{project_id}/subscriptions/{subscription_id} eg:subscriptions:delete