检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Connect支持收集服务集成下已开放API的调用日志信息。Kafka日志推送插件提供了把API的详细调用日志推送到Kafka的能力,方便用户获取API的调用日志信息。 使用限制 同一个API在同一个环境中只能绑定一个相同类型的插件策略,已被API绑定的插件策略无法删除。 同一个ROMA
Kit。 Python:2.7或3.X版本的Python。 Go:1.14及以上版本的Go。 C#:6.0及以上版本的.NET。 客户端版本使用建议: ROMA Connect的Kafka版本 Kafka客户端建议版本 1.1.0 Java:1.1.0及以上版本 Python:2.0
其他语言客户端使用说明 MQS完全兼容Kafka开源客户端。 如果您使用其他语言,也可以从Kafka官网获取客户端,按照Kafka官网提供的连接说明,与MQS对接。 获取客户端的地址请参考Kafka官网。 父主题: MQS连接开发(开源客户端)
password=dms@kafka ssl.endpoint.identification.algorithm= 示例代码中的参数说明,可参考获取MQS连接信息获取参数值。 bootstrap.servers:MQS连接地址和端口。 username和password:开启SASL_SSL认证时所使用的用户名和密码。
网关登录 平台支持MQTT协议的connect消息接口,获取鉴权信息“clientId”、“Username”、“Password”。 参数说明 参数 必选/可选 类型 参数描述 clientId 必选 String(256) 一机一密的设备clientId由4个部分组成:dev
C SDK使用说明 操作场景 使用C语言调用APP认证的API时,您需要先获取SDK,参考API调用示例调用API。 前提条件 已获取API的调用信息,具体请参见开发准备。 安装openssl库。 apt-get install libssl-dev 安装curl库。 apt-get
Connect支持通过插件策略的方式,为API提供灵活的扩展能力。Kafka日志推送策略提供了把API的详细调用日志推送到Kafka的能力,方便用户获取API的调用日志信息。 插件策略和API本身相互独立,只有为API绑定插件策略后,插件策略才对API生效。为API绑定插件策略时需指定发布
C++ SDK使用说明 操作场景 使用C++语言调用APP认证的API时,您需要先获取SDK,参考API调用示例调用API。 前提条件 已获取API的调用信息,具体请参见开发准备。 安装openssl库。 apt-get install libssl-dev 安装curl库。 apt-get
使用Android语言调用APP认证的API时,您需要先获取SDK,然后新建工程,最后参考API调用示例调用API。 前提条件 已获取API的调用信息,具体请参见开发准备。 已安装Android开发语言环境,具体请参见开发准备。 获取SDK 旧版界面:登录ROMA Connect实例控制台,在“服务集成
为project的ID,获取方法请参见获取项目ID。 scope参数定义了Token的作用域,下面示例中获取的Token仅能访问project下的资源。您还可以设置Token的作用域为某个账号下所有资源或账号的某个project下的资源,详细定义请参见获取用户Token接口。 POST
单击“访问密钥”。 单击“新增访问密钥”,进入“新增访问密钥”页面。 输入登录密码和验证码,单击“确定”,下载密钥,请妥善保管。 图2 访问密钥获取页面示意 生成签名 生成签名的方式和API调用认证开发(APP认证)相同,用AK代替APP认证中的AppKey,SK替换APP认证中的AppSecret,即可完成签名和请求。
操作场景 使用C#语言调用APP认证的API时,您需要先获取SDK,然后打开SDK包中的工程文件,最后参考API调用示例调用API。 前提条件 已获取API的调用信息,具体请参见开发准备。 已安装C#开发语言环境,具体请参见开发准备。 获取SDK 旧版界面:登录ROMA Connect实例控制台,在“服务集成
0:调用接口时提供请求的header中需携带Authorization信息,接口获取header中的secret信息,校验成功后才允许调用。 授权类型:Authorization中的Token信息需要通过Access Token Url获取,所以需要选择授权类型。 Access Token Url:输入OAuth2
th-config 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID,获取方式请参见API参考的“附录 > 获取项目ID”章节。 instance_id 是 String 实例ID vpc_channel_id 是 String VPC通道的编号
Go SDK使用说明 操作场景 使用Go语言调用APP认证的API时,您需要先获取SDK,然后新建工程,最后参考调用API示例调用API。 前提条件 已获取API的调用信息,具体请参见开发准备。 已安装开发工具和Go开发语言环境,具体请参见开发准备。 已在IntelliJ IDE
导入集成资产 概述 通过ROMA Connect的资产导入功能,把获取到的集成资产包快速导入ROMA Connect实例。 前提条件 已获取集成资产包。 在资产迁移场景,已修改实例配置参数。 操作步骤 在实例控制台的“实例信息”页面,单击右上角的“导入资产”。 在“导入资产”弹窗
后端服务签名校验开发 开发准备 Java SDK使用说明 Python SDK使用说明 C# SDK使用说明 父主题: 服务集成开发指导
使用Java语言进行后端服务签名时,您需要先获取SDK,然后导入工程,最后参考校验后端签名示例校验签名是否一致。 Java SDK仅支持hmac和basic类型的后端服务签名。 前提条件 已ROMA Connect控制台创建签名密钥,并绑定API,具体请参见配置后端服务的签名校验。 已获取签名密钥的Key和Secret,具体请参见开发准备。
MQS连接开发(开源客户端) Java客户端使用说明 Python客户端使用说明 Go客户端使用说明 C#客户端使用说明 其他语言客户端使用说明 附录:如何提高消息处理效率 附录:spring-kafka对接限制 父主题: 消息集成开发指导
参数类型 描述 instance_id 是 String 实例ID。 project_id 是 String 项目ID,获取方式请参见API参考的“附录 > 获取项目ID”章节。 archive_id 是 String 作业执行成功后,查询作业进度返回的entities.archive_id字段。