正在生成
详细信息:
检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
项目ID,获取方式请参见API参考的“附录 > 获取项目ID”章节。 表2 Query参数 参数 是否必选 参数类型 描述 type 否 String 导入资产文件的模式。 AddNew:全量新增导入。 Merge:合并导入。 默认为AddNew模式。 prefix 否 String App应用的前缀。
持。 不支持zstd压缩类型 Kafka在2.1.0版本新增了zstd压缩类型,而1.1.0版本的Kafka不支持zstd压缩类型。 配置文件: src/main/resources/application.yml 配置项: spring: kafka: producer:
wer没有成功备份数据,而此时leader又无法提供服务,则消息会丢失。 acks=all:这意味着leader需要等待所有备份都成功写入日志,只要任何一个备份存活,数据都不会丢失。 retries 0 结合实际业务调整 客户端发送消息的重试次数。值大于0时,这些数据发送失败后,客户端会重新发送。
找到原来已下载的AK/SK文件,文件名一般为:credentials.csv。 如下图所示,文件包含了租户名(User Name),AK(Access Key Id),SK(Secret Access Key)。 图1 credential.csv文件内容 AK/SK生成步骤: 注册并登录管理控制台。
以文本方式打开待添加证书里的PEM格式证书文件(后缀名为“.pem”),将证书内容复制到“证书”中即可。 私钥 仅当“配置类型”选择“证书”时可配置。 填写pem编码格式的证书私钥。 以文本方式打开待上传证书里的KEY格式或PEM格式的私钥文件(后缀名为“.pem”或“.key”),将私钥复制到“私钥”中即可。
plugin_type String 插件类型 cors:跨域资源共享 set_resp_headers:HTTP响应头管理 kafka_log:Kafka日志推送 breaker:断路器 rate_limit: 流量控制 third_auth: 第三方认证 plugin_scope String
快速识别和查找。 编码格式 默认“utf-8”格式。 集成应用 选择数据源所归属的集成应用。 描述 填写数据源的描述信息。 URL 填写服务器的IP地址和端口,格式为:ldap://ip:port。 ip为数据库的访问地址。 port为数据库的访问端口。 安全认证类型 数据库的安
选择region、ROMA实例、分组。 选择API路径或者API名称。 勾选需要导入的API,单击“确定”。 外部上传 单击“添加文件”,从本地导入所需的swagger文件,单击“确定”。 父主题: 我的资产
ath的值不能以斜杠(/)结尾。 文件名前缀 填写文件名前缀,与“时间格式”配合使用,用于筛选要集成的数据文件。 时间格式 选择文件名中的时间格式,与“文件名前缀”配合使用,用于筛选要集成的数据文件。 文件类型 选择从OBS数据源获取的数据文件格式,可选择“txt”,“csv”和“zip”。
生产的消息被依次存储在ROMA Connect的存储介质中。消费时依次获取ROMA Connect中存储的消息。消费者获取消息后,进行消费并记录消费成功或失败的状态,并将消费状态提交到ROMA Connect,由ROMA Connect决定消费下一批消息或回滚重新消费消息。 在消费
Demo包括两个文件,DeviceConnectDemo.java用于连接设备,DeviceControlDemo.java用于调用控制设备的API。 配置设备连接信息 解压Demo压缩包,在“src”目录的底层路径下找到DeviceConnectDemo.java文件。 使用Jav
在每次任务执行过程中,如果源端的某些数据符合集成条件,但因为网络抖动或数据转换异常等原因,无法顺利集成到目标端数据源,则ROMA Connect可以将这些数据以文本文件的形式存储在OBS中。 如果需要配置“异常数据存储”,请展开“异常数据存储”模块参照表1进行配置,如果不需要配置,请将“异常数据存储”模块折叠,否则影响任务保存。
修改配置信息 为了方便,下文分生产与消费两个配置文件介绍。如果ROMA Connect实例开启了SASL认证,在Java客户端的配置文件中必须配置涉及SASL认证的相关信息,否则无法连接。如果没有使用SASL认证,请注释掉相关配置。 生产消息配置文件(对应生产消息代码中的mqs.sdk.producer
状态码: 200 表4 响应Body参数 参数 参数类型 描述 size Integer 本次返回的列表长度 total Long 满足条件的记录数 throttles Array of ThrottlesInfo objects 本次查询到的流控策略列表 表5 ThrottlesInfo
用户创建的FDI任务,同一账号的其他用户可见吗? FDI通过公网对接其他租户的MRS HIVE如何配置? 从OBS解析文件到RDS数据库,采集过一次后,后面采集会进行更新吗? OBS源端的CSV文件解析到关系型数据库时,列的值不对怎么办? MRS Hive目标字段和源端字段数据类型不匹配时,数据是否能集成到目标端?
命令下发 说明: 仅设备所属产品的协议类型为MQTT时,支持命令下发。 能有效地对设备进行管理,设备的产品物模型中定义了可向设备下发的命令,应用服务器可通过LINK直接向单个设备下发命令,以实现对设备的远程控制。命令下发具体配置如下: 选择物模型服务:物模型服务来源于设备所属产品的物模型
间格式外,还会校验该时间值与收到请求的时间差,如果时间差超过15分钟,ROMA Connect将拒绝请求。因此,客户端须注意本地与NTP服务器的时间同步,避免请求消息头X-Sdk-Date的值出现较大误差。 自定义后端开发要求 函数后端开发要求: 仅支持使用JavaScript编
"error_code": "APIC.0301", "request_id": "******" } 通过打印日志或调试中断的方式得到客户端计算的canonicalRequest,每种语言SDK中计算canonicalRequest的位置如下: 表1
curl_global_cleanup(); return 0; } 运行make命令编译,得到可执行文件main,执行main文件,查看结果。 父主题: API调用认证开发(APP认证)
test_date String 测试时间 ld_api_id String 后端API编号 debug_log Array of strings 本次测试日志列表 状态码: 400 表6 响应Body参数 参数 参数类型 描述 error_code String 错误码 error_msg String