检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
客户端连接指导，包括Kafka客户端安装，以及生产、消费消息。 前提条件 已获取MQS连接信息，具体请参见开发准备。 已安装开发工具和Python开发语言环境，具体请参见开发准备。 引入Kafka客户端 MQS基于Kafka社区版本1.1.0、2.7，您可以在ROMA Conne
要先获取SDK，然后新建工程，最后参考调用API示例调用API。 前提条件 已获取API的调用信息，具体请参见开发准备。 已安装开发工具和Go开发语言环境，具体请参见开发准备。 已在IntelliJ IDEA中安装Go插件，如果未安装，请按照图1所示安装。 图1 安装Go插件 获取SDK
自定义数据源开发示例（定时任务） 操作场景 FDI当前支持接入MySQL类型数据库，但因为MySQL是最常用的数据库类型，可以方便开发者参照理解，故本章节以MySQL类型自定义连接器为例进行开发，示例使用Java语言进行开发，Demo代码参考MysqlConnctor.rar。 前提条件
已在控制台创建签名密钥，并绑定API，具体请参见配置后端服务的签名校验。 已获取签名密钥的Key和Secret，具体请参见开发准备。 已安装开发工具和Python开发语言环境，具体请参见开发准备。 已在IntelliJ IDEA中安装Python插件，如果未安装，请按照图1所示安装。
前提条件 已在控制台创建签名密钥，并绑定API，具体请参见配置后端服务的签名校验。 已获取签名密钥的Key和Secret，具体请参见开发准备。 已安装C#开发语言环境，具体请参见开发准备。 获取SDK 旧版界面：登录ROMA Connect实例控制台，在“服务集成 APIC > AP
SDK仅支持hmac和basic类型的后端服务签名。 前提条件 已ROMA Connect控制台创建签名密钥，并绑定API，具体请参见配置后端服务的签名校验。 已获取签名密钥的Key和Secret，具体请参见开发准备。 已安装开发工具和Java开发语言环境，具体请参见开发准备。 获取SDK
自定义数据源开发示例（实时任务） 操作场景 对于实时数据源，当前自定义连接器不支持直接接入，只能通过消息中转的方式进行接入。本章节以MQS数据源类型为例进行开发，示例使用Java语言进行开发，Demo代码参考RealtimeConnector.rar。 前提条件 准备装有1.8及以上版本JDK的Linux服务器。
Consumer不能频繁加入和退出group，频繁加入和退出，会导致Consumer频繁做rebalance，阻塞消费。 Consumer数量不能超过Topic分区数，否则会有Consumer拉取不到消息。 Consumer需周期poll，维持和server的心跳，避免心跳超时
livedata.lambdaservice.util.JSONHelper 说明 提供Json与Xml、Map之间的相互转换。 方法列表 返回类型 方法和说明 static String json2Xml(String json) json转xml static String xml2Json(String
生成sha256签名 输入参数 appId：集成应用ID appKey：集成应用Key timestamp：时间戳 返回信息 返回sha256签名信息 父主题： 自定义后端开发（函数后端）
返回类型 方法和说明 static boolean putCache(String key, String value) 存入缓存信息 static boolean putCache(String key, String value, int time) 存入带超时时间缓存信息 static
创建发布环境和环境变量（可选） 概述 环境是指API的受限使用范围，API只有在发布到环境后，才能被调用。API可以被发布到不同的自定义环境中，如开发环境、测试环境等。RELEASE是系统默认的发布环境，也是正式发布环境。 环境变量是指在环境上创建的一种变量，该变量固定在环境上。
timeout：读取超时时间，最大值为30000毫秒，建议timeout设置值小于前端API的“后端超时”时间值 maxItems：读取消息的最大数量 返回信息 Kafka已消费的消息数组，消息数组即将多条消息的内容组成一个数组 父主题： 自定义后端开发（函数后端）
创建发布环境和环境变量（可选） 环境是指API的受限使用范围，API只有在发布到环境后，才能被调用。API可以被发布到不同的自定义环境中，如开发环境、测试环境等。RELEASE是系统默认的发布环境，也是正式发布环境。 环境变量是指在环境上创建的一种变量，该变量固定在环境上。如果A
下载JavaScript SDK生成curl命令，然后将curl命令复制到命令行调用API。 前提条件 已获取API的调用信息，具体请参见开发准备。 浏览器版本为Chrome 89.0或以上版本。 获取SDK 旧版界面：登录ROMA Connect实例控制台，在“服务集成 APIC
设置jedis的读取超时时间，默认600秒 输入参数 soTimeout：读取超时时间 public void setTimeout(int timeout) 设置jedis的超时时间 输入参数 timeout：超时时间，单位秒 父主题： 自定义后端开发（函数后端）
获取HTTP请求编码格式 返回信息 返回HTTP请求编码格式 public int getConnectTimeout() 获取连接超时时间 返回信息 返回连接超时时间 public Object getContent() 获取请求内容 返回信息 返回请求内容 public String getContentType()
getRequestTimeout() 获取请求超时时间 返回信息 返回请求超时时间 public long getRollingTimeout() 获取rolling超时时间 返回信息 返回rolling超时时间 public long getScaleTimeout() 获取scale超时时间 返回信息 返回scale超时时间
方法列表 返回类型 方法和说明 String get(String key) 返回redis缓存中key对应的value值 String put(String key, int expireTime, String value) 更新redis缓存内容、过期时间，返回执行结果 String
只支持结构化数据。 MRS Hive数据源类型 Hive读写文件格式只支持rcfile和textfile类型。 MRS Hive作为源端最大只支持100万数据量表的同步。 API数据源类型 超时时间为60秒，服务端响应时间若超过60秒会触发任务执行报错。 API作为源端，单次请求最大支持读取的
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
