- 最新动态
- 功能总览
- 产品介绍
- 计费说明
- 快速入门
-
用户指南
- 开始使用ROMA Connect
- 实例管理
- 集成应用管理
-
数据源管理
- ROMA Connect支持的数据源
- 接入API数据源
- 接入ActiveMQ数据源
- 接入ArtemisMQ数据源
- 接入DB2数据源
- 接入DIS数据源
- 接入DWS数据源
- 接入DM数据源
- 接入Gauss100数据源
- 接入FTP数据源
- 接入HL7数据源
- 接入HANA数据源
- 接入HIVE数据源
- 接入LDAP数据源
- 接入IBM MQ数据源
- 接入Kafka数据源
- 接入MySQL数据源
- 接入MongoDB数据源
- 接入MQS数据源
- 接入MRS Hive数据源
- 接入MRS HDFS数据源
- 接入MRS HBase数据源
- 接入MRS Kafka数据源
- 接入OBS数据源
- 接入Oracle数据源
- 接入PostgreSQL数据源
- 接入Redis数据源
- 接入RabbitMQ数据源
- 接入RocketMQ数据源
- 接入SAP数据源
- 接入SNMP数据源
- 接入SQL Server数据源
- 接入GaussDB(for MySQL)数据源
- 接入WebSocket数据源
- 接入自定义数据源
- 数据集成指导
- 服务集成指导
- 服务集成指导(旧版界面)
- 消息集成指导
- 设备集成指导
- 应用业务模型使用指导
- 扩大资源配额
- 查看审计日志
- 查看监控指标
- 权限管理
- 用户指南(新版)
- 最佳实践
-
开发指南
- 数据集成开发指导
-
服务集成开发指导
- 开发说明
- API调用认证开发(APP认证)
- API调用认证开发(IAM认证)
-
自定义后端开发(函数后端)
- 函数后端脚本开发说明
- AesUtils类说明
- APIConnectResponse类说明
- Base64Utils类说明
- CacheUtils类说明
- CipherUtils类说明
- ConnectionConfig类说明
- DataSourceClient类说明
- DataSourceConfig类说明
- ExchangeConfig类说明
- HttpClient类说明
- HttpConfig类说明
- JedisConfig类说明
- JSON2XMLHelper类说明
- JSONHelper类说明
- JsonUtils类说明
- JWTUtils类说明
- KafkaConsumer类说明
- KafkaProducer类说明
- KafkaConfig类说明
- MD5Encoder类说明
- Md5Utils类说明
- QueueConfig类说明
- RabbitMqConfig类说明
- RabbitMqProducer类说明
- RedisClient类说明
- RomaWebConfig类说明
- RSAUtils类说明
- SapRfcClient类说明
- SapRfcConfig类说明
- SoapClient类说明
- SoapConfig类说明
- StringUtils类说明
- TextUtils类说明
- XmlUtils类说明
- 自定义后端开发(数据后端)
- 后端服务签名校验开发
- 消息集成开发指导
- 设备集成开发指导
-
API参考
- 使用前必读
- API概览
- 如何调用API
- 公共资源API
- 数据集成API
- 服务集成API
- 消息集成API
- 设备集成API
- 应用示例
- 权限和授权项
- 附录
- 历史API
- 修订记录
- SDK参考
-
常见问题
- 实例管理
-
数据集成
-
数据集成普通任务
- FDI各类数据库支持哪些数据类型?
- 跟踪号是什么,能跟踪到数据吗?
- FDI任务是否支持清空目标表?
- FDI任务只能采集单张表到单张表吗?
- 用户创建的FDI任务,同一账号的其他用户可见吗?
- FDI通过公网对接其他租户的MRS HIVE如何配置?
- 从OBS解析文件到RDS数据库,采集过一次后,后面采集会进行更新吗?
- OBS源端的CSV文件解析到关系型数据库时,列的值不对怎么办?
- MRS Hive目标字段和源端字段数据类型不匹配时,数据是否能集成到目标端?
- MRS Hive、MRS HBase和MongoDB的Mapping映射手动输入时,是否区分大小写?
- MRS Hive是否支持分区?
- 源端API类型数据源自定义周期如何设置?
- SAP是否支持分页读取视图?
- 数据集成组合任务
-
数据集成普通任务
- 服务集成
- 消息集成
- 设备集成
-
故障排除
-
数据集成任务
- MRS Hive目标端写入时出现数据乱码
- MRS Hive写入时数据全部写在第一个字段里
- 目标端任务报任务运行超时
- MySQL到MRS Hive时目标端报“could only be written to 0 of the 1 minReplication nodes. There are 2 datanode(s) running and 2 node(s) are excluded in this operation”错误
- Mysql到Mysql时源端报“Illegal mix of collations for operation 'UNION'”错误
- 源端Mysql增量采集每小时执行一次时部分数据丢失
- API到MySQL时源端报“401 unauthorized”错误
- Kafka集到Mysql目标端报“cannot find record mapping field”错误
- API到MySQL的定时任务时会出现源端报“connect timeout”错误
- Kafka到Mysql的实时任务时,MQS中的Topic下有数据,但是FDI任务没有采集到数据。
- Mysql到Mysql的定时任务,源端有类型为tinyint(1),值为2的字段,但是采集到目标端值就变成了1
- 目标端数据源为公网Kafka时,定时任务目标端报“The task executes failed.Writer data to kafka failed”错误
- 数据集成组合任务
- 数据源
- 服务集成
- 设备集成
-
数据集成任务
- 视频帮助
- 文档下载
- 通用参考
链接复制成功!
HttpClient类说明
路径
- com.roma.apic.livedata.client.v1.HttpClient
- com.huawei.livedata.lambdaservice.livedataprovider.HttpClient
说明
使用此类进行HTTP请求。
部分HTTP通用响应头不支持返回,如Location等。
使用示例
- com.roma.apic.livedata.client.v1.HttpClient
importClass(com.roma.apic.livedata.client.v1.HttpClient); importClass(com.roma.apic.livedata.provider.v1.APIConnectResponse); function execute(data) { var httpClient = new HttpClient(); var resp = httpClient.request('GET', 'http://apigdemo.exampleRegion.com/api/echo', {}, null, 'application/json'); myHeaders = resp.headers(); proxyHeaders = {}; for (var key in myHeaders) { proxyHeaders[key] = myHeaders.get(key); } return new APIConnectResponse(resp.code(), proxyHeaders, resp.body().string(), false); }
- com.huawei.livedata.lambdaservice.livedataprovider.HttpClient
importClass(com.huawei.livedata.lambdaservice.livedataprovider.HttpClient); function excute(data) { var httpExecutor = new HttpClient(); var obj = JSON.parse(data); var host = 'xx.xx.xxx.xx:xxxx'; var headers = { 'clientapp' : 'FunctionStage' }; var params = { 'employ_no' :'00xxxxxx' }; var result = httpExecutor.callGETAPI(host,'/livews/rest/apiservice/iData/personInfo/batch',JSON.stringify(params),JSON.stringify(headers)); return result; }
构造器详情
- com.roma.apic.livedata.client.v1.HttpClient
构造一个无参数的HttpClient。
public HttpClient(HttpConfig config)
构造一个包含HttpConfig配置信息的HttpClient。
参数:config表示传入HttpClient的配置信息。
- com.huawei.livedata.lambdaservice.livedataprovider.HttpClient
构造一个无参数的HttpClient。
方法列表
- com.roma.apic.livedata.client.v1.HttpClient
返回类型
方法和说明
okhttp3.Response
request(HttpConfig config)
用于发送rest请求
okhttp3.Response
request(String method, String url)
通过指定请求方法、请求路径的方式发送rest请求
okhttp3.Response
request(String method, String url, Map<String,String> headers)
通过指定请求方法、请求路径、请求消息头的方式发送rest请求
okhttp3.Response
request(String method, String url, Map<String,String> headers, String body)
通过指定请求方法、请求路径、请求消息头、请求body体的方式发送rest请求
okhttp3.Response
request(String method, String url, Map<String,String> headers, String body, String contentType)
通过指定请求方法、请求路径、请求消息头、请求body体、contentType的方式发送rest请求
- com.huawei.livedata.lambdaservice.livedataprovider.HttpClient
返回类型
方法和说明
String
callGETAPI(String url)
使用get方法调用http或https服务
String
callGETAPI(String host, String service, String params, String header)
使用get方法调用http或https服务
Response
get(String url, String header)
使用get方法调用http或https服务
String
callPostAPI(String host, String service, String content, String header, String contentType)
使用post方法调用http或https服务
String
callPostAPI(String url, String header, String requestBody, String type)
使用post方法调用http或https服务
Response
post(String url, String header, String content, String type)
使用post方法调用http或https服务
String
callFormPost(String url, String header, String/Map param)
formdata格式调用http或https服务
Response
callFormPost(String url, String header, String param, FormDataMultiPart form)
formdata格式调用http或https服务
String
callDelAPI(String url, String header, String content, String type)
使用delete方法请求http或https服务
String
callPUTAPI(String url, String header, String content, String type)
通过put方法调用http或https服务
String
callPatchAPI(String url, String header, String content, String type)
使用patch方法调用http或https服务
Response
put(String url, String header, String content, String type)
使用put方法调用http或https服务
方法详情
- com.roma.apic.livedata.client.v1.HttpClient
- public okhttp3.Response request(HttpConfig config)
用于发送rest请求
输入参数
config:传入HttpConfig的配置信息
返回信息
返回响应的消息体
- public okhttp3.Response request(String method, String url)
通过指定请求方法、请求路径的方式发送rest请求
输入参数
- method:请求方法
- url:请求路径
返回信息
返回响应的消息体
- public okhttp3.Response request(String method, String url, Map<String,String> headers)
通过指定请求方法、请求路径、请求消息头的方式发送rest请求
输入参数
- method:请求方法
- url:请求路径
- headers:Map类型,请求消息头信息
返回信息
返回响应的消息体
- public okhttp3.Response request(String method, String url, Map<String,String> headers, String body)
通过指定请求方法、请求路径、请求消息头、请求body体的方式发送rest请求
输入参数
- method:请求方法
- url:请求路径
- headers:Map类型,请求消息头信息
- body:请求body体信息
返回信息
返回响应的消息体
- public okhttp3.Response request(String method, String url, Map<String,String> headers, String body, String contentType)
通过指定请求方法、请求路径、请求消息头、请求body体、contentType的方式发送rest请求
输入参数
- method:请求方法
- url:请求路径
- headers:Map类型,请求消息头信息
- body:请求body体信息
- contentType:请求体的Content-type类型
返回信息
返回响应的消息体
- public okhttp3.Response request(HttpConfig config)
- com.huawei.livedata.lambdaservice.livedataprovider.HttpClient
- public String callGETAPI(String url)
使用get方法调用http或https服务
输入参数
url:服务地址
返回信息
返回响应的消息体
- public String callGETAPI(String host, String service, String params, String header)
使用get方法调用http或https服务
输入参数
- host:服务地址
- service:服务路径
- params:http参数信息
- header:http头部信息
返回信息
返回响应的消息体
- public Response get(String url, String header)
使用get方法调用http或https服务
输入参数
- url:服务地址
- header:请求头信息
返回信息
返回响应的消息体
- public String callPostAPI(String host, String service, String content, String header, String contentType)
使用post方法调用http或https服务
输入参数
- host:服务地址
- service:服务路径
- content:消息体
- header:请求头信息
- contentType:内容类型
返回信息
返回响应的消息体
- public String callPostAPI(String url, String header, String requestBody, String type)
使用post方法调用http或https服务
输入参数
- url:服务地址
- header:请求头信息
- requestBody:消息体
- type:MIME类型
返回信息
返回响应的消息体
- public Response post(String url, String header, String content, String type)
使用post方法调用http或https服务
输入参数
- url:服务地址
- header:请求头信息
- content:消息体
- type:MIME类型
返回信息
返回响应的消息体
- public String callFormPost(String url, String header, String/Map param)
formdata格式调用http或https服务
输入参数
- url:服务地址
- header:请求头信息
- param:参数信息
返回信息
返回响应的消息体
- public Response callFormPost(String url, String header, String param, FormDataMultiPart form)
formdata格式调用http或https服务
输入参数
- url:服务地址
- header:请求头信息
- param:参数信息
- form:Body参数
返回信息
返回响应的消息体
- public String callDelAPI(String url, String header, String content, String type)
使用delete方法请求http或https服务
输入参数
- url:服务地址
- header:请求头信息
- content:消息体
- type:MIME类型
返回信息
返回响应的消息体
- public String callPUTAPI(String url, String header, String content, String type)
使用put方法调用http或https服务
输入参数
- url:服务地址
- header:请求头信息
- content:消息体
- type:MIME类型
返回信息
返回响应的消息体
- public String callPatchAPI(String url, String header, String content, String type)
使用patch方法调用http或https服务
输入参数
- url:服务地址
- header:请求头信息
- content:消息体
- type:MIME类型
返回信息
返回响应的消息体
- public Response put(String url, String header, String content, String type)
使用put方法调用http或https服务
输入参数
- url:服务地址
- header:请求头信息
- content:消息体
- type:MIME类型
返回信息
返回响应的消息体
- public String callGETAPI(String url)