华为云用户手册

方法列表 返回类型 方法和说明 void produceWithDirectExchange(String routingKey, String props, String message) 用direct交换器生产消息，把消息路由到bindingKey与routingKey完全匹配的Queue中。 void produceWithTopicExchange(String bindingKey, String routingKey, String props, String message) 用topic交换器生产消息，把消息路由到bindingKey与routingKey模糊匹配的Queue中。 void produceWithFanoutExchange(String props, String message) 用fanout交换器生产消息，把所有发送到该Exchange的消息路由到所有与它绑定的Queue中。

方法详情 public void produceWithDirectExchange(String routingKey, String props, String message) 用direct交换器生产消息，把消息路由到bindingKey与routingKey完全匹配的Queue中。 输入参数 routingKey：消息路由键 props：消息持久化设置，非必填 message：消息内容 public void produceWithTopicExchange(String bindingKey, String routingKey, String props, String message) 用topic交换器生产消息，把消息路由到bindingKey与routingKey模糊匹配的Queue中。 输入参数 bindingKey：队列绑定键 routingKey：消息路由键 props：消息持久化设置，非必填 message：消息内容 produceWithFanoutExchange(String props, String message) 用fanout交换器生产消息，把所有发送到该Exchange的消息路由到所有与它绑定的Queue中。 输入参数 props：消息持久化设置，非必填 message：消息内容

方法列表 返回类型 方法和说明 static java.lang.String decrypt(java.lang.String encryptText, java.lang.String secretKey) 使用密钥对密文进行AES解密。 static java.lang.String encrypt(java.lang.String plainText, java.lang.String secretKey) 使用密钥对明文进行AES加密。 static java.lang.String decrypt(java.lang.String encryptText, java.lang.String secretKey, java.lang.String initialVector, AesUtils.KEYLENGTH length, AesUtils.MODE mode, AesUtils.PAD pad) 使用指定模式和长度的密钥对密文进行AES解密。 static java.lang.String encrypt(java.lang.String plainText, java.lang.String secretKey, java.lang.String initialVector, AesUtils.KEYLENGTH length, AesUtils.MODE mode, AesUtils.PAD pad) 使用指定模式和长度的密钥对明文进行AES加密。

使用示例 用direct交换器生产消息，把消息路由到bindingKey与routingKey完全匹配的Queue中。 importClass(com.roma.apic.livedata.client.v1.RabbitMqProducer);importClass(com.roma.apic.livedata.config.v1.RabbitMqConfig);importClass(com.roma.apic.livedata.config.v1.QueueConfig);importClass(com.roma.apic.livedata.config.v1.ExchangeConfig);importClass(com.roma.apic.livedata.config.v1.ConnectionConfig); function execute(data) { var connectionConfig = new ConnectionConfig("10.10.10.10", 5672, "admin", "123456"); var queueConfig = new QueueConfig("directQueue", false, false, false, null); var exchangeConfig = new ExchangeConfig("directExchange", "direct", true, false, false, null); var config = new RabbitMqConfig(connectionConfig, queueConfig, exchangeConfig); var producer = new RabbitMqProducer(config); producer.produceWithDirectExchange("direct.exchange", "PERSISTENT_TEXT_PLAIN", "direct exchange message"); return "produce successful.";} 用topic交换器生产消息，把消息路由到bindingKey与routingKey模糊匹配的Queue中。 importClass(com.roma.apic.livedata.client.v1.RabbitMqProducer);importClass(com.roma.apic.livedata.config.v1.RabbitMqConfig);importClass(com.roma.apic.livedata.config.v1.QueueConfig);importClass(com.roma.apic.livedata.config.v1.ExchangeConfig);importClass(com.roma.apic.livedata.config.v1.ConnectionConfig); function execute(data) { var connectionConfig = new ConnectionConfig("10.10.10.10", 5672, "admin", "123456"); var queueConfig = new QueueConfig(“topicQueue”, false, false, false, null); var exchangeConfig = new ExchangeConfig("topicExchange", "topic", true, false, false, null); var config = new RabbitMqConfig(connectionConfig, queueConfig, exchangeConfig); var producer = new RabbitMqProducer(config); producer.produceWithTopicExchange("topic.#", “topic.A”, null, “message”); return "produce successful.";} 用fanout交换器生产消息，把所有发送到该Exchange的消息路由到所有与它绑定的Queue中。 importClass(com.roma.apic.livedata.client.v1.RabbitMqProducer);importClass(com.roma.apic.livedata.config.v1.RabbitMqConfig);importClass(com.roma.apic.livedata.config.v1.QueueConfig);importClass(com.roma.apic.livedata.config.v1.ExchangeConfig);importClass(com.roma.apic.livedata.config.v1.ConnectionConfig); function execute(data) { var connectionConfig = new ConnectionConfig("10.10.10.10", 5672, "admin", "123456"); var queueConfig = new QueueConfig(“fanoutQueue”, false, false, false, null); var exchangeConfig = new ExchangeConfig(“fanoutExchange”, "fanout", true, false, null); var config = new RabbitMqConfig(connectionConfig, queueConfig, exchangeConfig); var producer = new RabbitMqProducer(config); producer.produceWithFanoutExchange( null, “message”); return "produce successfull"}

方法详情 public static java.lang.String decrypt(java.lang.String encryptText, java.lang.String secretKey) 使用密钥对密文进行AES解密 输入参数 encryptText：待解密的密文，长度不超过8192 secretKey：密钥 返回信息 返回解密后的数据 public static java.lang.String encrypt(java.lang.String plainText, java.lang.String secretKey) 使用密钥对明文进行AES加密 输入参数 plainText：待加密的明文，长度不超过4096 secretKey：密钥 返回信息 返回加密后的数据 public static java.lang.String decrypt(java.lang.String encryptText, java.lang.String secretKey, java.lang.String initialVector, AesUtils.KEYLENGTH length, AesUtils.MODE mode, AesUtils.PAD pad) 使用指定模式和长度的密钥对密文进行AES解密 输入参数 encryptText：待解密的密文，长度不超过8192 secretKey：密钥 initialVector：初始向量 length：密钥的长度，取值范围：AesUtils.KEYLENGTH.KL_0、AesUtils.KEYLENGTH.KL_128、AesUtils.KEYLENGTH.KL_192、AesUtils.KEYLENGTH.KL_256 mode：工作模式，取值范围：AesUtils.MODE.GCM、AesUtils.MODE.CTR pad：填充模式，取值范围：AesUtils.PAD.PK CS 5PADDING，AesUtils.PAD.NOPADDING 返回信息 返回解密后的数据 public static java.lang.String encrypt(java.lang.String plainText, java.lang.String secretKey, java.lang.String initialVector, AesUtils.KEYLENGTH length, AesUtils.MODE mode, AesUtils.PAD pad) 使用指定模式和长度的密钥对明文进行AES加密 输入参数 plainText：待加密的明文，长度不超过4096 secretKey：密钥 initialVector：初始向量 length：密钥的长度，取值范围：AesUtils.KEYLENGTH.KL_0、AesUtils.KEYLENGTH.KL_128、AesUtils.KEYLENGTH.KL_192、AesUtils.KEYLENGTH.KL_256 mode：工作模式，取值范围：AesUtils.MODE.GCM、AesUtils.MODE.CTR pad：填充模式，取值范围：AesUtils.PAD.PKCS5PADDING，AesUtils.PAD.NOPADDING 返回信息 返回加密后的数据

请求消息 请求参数 参数 类型 必选 说明 messages Array 是 消息列表，数组大小不能超过10，且不能为空数组。 表2 messages参数 参数 类型 必选 说明 content Object 是 消息内容。 id String 是 消息序号，序列号不能重复。 请求示例 { "messages": [ { "content": "hello roma-1", "id": "1" }, { "content": "hello roma-2", "id": "2" }, { "content": "hello roma-3", "id": "3" } ]}

生成AK、SK 如果已生成过AK/SK，则可跳过此步骤，找到原来已下载的AK/SK文件，文件名一般为：credentials.csv。 如下图所示，文件包含了租户名（User Name），AK（Access Key Id），SK（Secret Access Key）。 图1 credential.csv文件内容 AK/SK生成步骤： 注册并登录管理控制台。 单击右上角的用户名，在下拉列表中单击“我的凭证”。 单击“访问密钥”。 单击“新增访问密钥”，进入“新增访问密钥”页面。 输入登录密码和验证码，单击“确定”，下载密钥，请妥善保管。 图2 访问密钥获取页面示意

响应消息 响应参数 参数 类型 说明 state String 结果状态。成功为success，失败为fail。 id String 消息序号。 响应示例 [ { "state": "success", "id": "1" }, { "state": "success", "id": "2" }, { "state": "success", "id": "3" }]

客户端参数配置建议 Kafka客户端的配置参数很多，以下提供Producer和Consumer几个常用参数配置。 表1 Producer参数 参数 默认值 推荐值 说明 acks 1 高可靠：all 高吞吐：1 收到Server端确认信号个数，表示procuder需要收到多少个这样的确认信号，算消息发送成功。acks参数代表了数据备份的可用性。常用选项： acks=0：表示producer不需要等待任何确认收到的信息，副本将立即加到socket buffer并认为已经发送。没有任何保障可以保证此种情况下server已经成功接收数据，同时重试配置不会发生作用（因为客户端不知道是否失败），回馈的offset会总是设置为-1。 acks=1：这意味着至少要等待leader已经成功将数据写入本地log，但是并没有等待所有follower是否成功写入。如果follower没有成功备份数据，而此时leader又无法提供服务，则消息会丢失。 acks=all：这意味着leader需要等待所有备份都成功写入日志，只要任何一个备份存活，数据都不会丢失。 retries 0 结合实际业务调整 客户端发送消息的重试次数。值大于0时，这些数据发送失败后，客户端会重新发送。 注意，这些重试与客户端接收到发送错误时的重试没有什么不同。允许重试将潜在的改变数据的顺序，如果这两个消息记录都是发送到同一个partition，则第一个消息失败第二个发送成功，则第二条消息会比第一条消息出现要早。 request.timeout.ms 30000 结合实际业务调整 设置一个请求最大等待时间，超过这个时间则会抛Timeout异常。 超时时间如果设置大一些，如120000（120秒），高并发的场景中，能减少发送失败的情况。 block.on.buffer.full TRUE TRUE TRUE表示当内存用尽时，停止接收新消息记录或者抛出错误。 默认情况下，这个设置为TRUE。然而某些阻塞可能不值得期待，因此立即抛出错误更好。如果设置为false，则producer抛出一个异常错误：BufferExhaustedException batch.size 16384 262144 默认的批量处理消息字节数上限。producer将试图批处理消息记录，以减少请求次数。这将改善client与server之间的性能。不会试图处理大于这个字节数的消息字节数。 发送到brokers的请求将包含多个批量处理，其中会包含对每个partition的一个请求。 较小的批量处理数值比较少用，并且可能降低吞吐量（0则会仅用批量处理）。较大的批量处理数值将会浪费更多内存空间，这样就需要分配特定批量处理数值的内存大小。 buffer.memory 33554432 67108864 producer可以用来缓存数据的内存大小。如果数据产生速度大于向broker发送的速度，producer会阻塞或者抛出异常，以“block.on.buffer.full”来表明。 这项设置将和producer能够使用的总内存相关，但并不是一个硬性的限制，因为不是producer使用的所有内存都是用于缓存。一些额外的内存会用于压缩（如果引入压缩机制），同样还有一些用于维护请求。 max.request.size 1048576 5242880 生产者给服务端单次发送的最大消息字节数，该参数影响单次生产的消息记录数量。 表2 Consumer参数 参数 默认值 推荐值 说明 auto.commit.enable TRUE FALSE 如果为TRUE，consumer所fetch的消息的offset将会自动的同步到zookeeper。这项提交的offset将在进程无法提供服务时，由新的consumer使用。 约束： 设置为FALSE后，需要先成功消费再提交，这样可以避免消息丢失。 auto.offset.reset latest earliest 没有初始化offset或者offset被删除时，可以设置以下值： earliest：自动复位offset为最早 latest：自动复位offset为最新 none：如果没有发现offset则向消费者抛出异常 anything else：向消费者抛出异常。 connections.max.idle.ms 600000 30000 空连接的超时时间，设置为30000可以在网络异常场景下减少请求卡顿的时间。 父主题： 开发说明

场景说明 ROMA Connect的服务集成主要涉及以下几个开发场景： API调用认证开发：业务系统在调用服务集成APIC开放的API时，若API的认证方式为APP认证或 IAM 认证，则需要在业务系统侧进行调用认证的开发，为API请求添加认证信息。 APP认证（签名认证）：调用侧集成ROMA Connect提供的SDK，对API请求进行签名处理。 IAM认证（Token认证）：调用侧先获取云服务平台的认证Token，然后把认证Token携带到API请求中。 IAM认证（AK/SK认证）：调用侧集成ROMA Connect提供的SDK，对API请求进行签名处理。 自定义后端开发：用户在使用服务集成APIC的自定义后端创建函数后端和数据后端时，涉及函数脚本或数据库执行语句的编写开发。 函数后端：创建函数后端时需要编写函数脚本，进行函数功能开发，ROMA Connect提供了部分Java类函数供用户直接使用。 数据后端：创建数据后端时需要编写执行语句，用于对数据源进行操作。 后端服务签名校验开发：若API在ROMA Connect上绑定了签名密钥，则ROMA Connect向该API的后端服务发送请求时会携带相应的签名信息。该API的后端服务需要集成ROMA Connect提供的SDK，并对请求中的签名信息进行校验。

调用API示例 使用JavaScript SDK生成curl命令。 解压SDK，在浏览器中打开demo.html，页面如下图所示。 输入API所授权凭据的Key和Secret，并指定方法名、请求url，可参考获取API的调用信息获取。例如： // Directly writing AK/SK in code is risky. For security, encrypt your AK/SK and store them in the configuration file or environment variables. // In this example, the AK/SK are stored in environment variables for identity authentication. Before running this example, set environment variables HUAWEICLOUD_SDK_AK and HUAWEICLOUD_SDK_SK. Key=4f5f626b-073f-402f-a1e0-e52171c6100cSecret=******Method=POSTUrl=https://c967a237-cd6c-470e-906f-a8655461897e.apigw.exampleRegion.com/app1 输入json格式的Query和Headers，填入Body。 单击“Send request”，生成curl命令。将curl命令复制到命令行，访问API。 //若使用系统分配的子 域名 访问https请求的API时，需要忽略证书校验，在-d后添加“ -k”$ curl -X POST "https://c967a237-cd6c-470e-906f-a8655461897e.apigw.exampleRegion.com/app1" -H "X-Sdk-Date: 20180530T115847Z" -H "Authorization: SDK-HMAC-SHA256 Access=071fe245-9cf6-4d75-822d-c29945a1e06a, SignedHeaders=host;x-sdk-date, Signature=9e5314bd156d517******dd3e5765fdde4" -d ""Congratulations, sdk demo is running SDK生成的curl命令不符合Window下cmd终端格式，请在git bash下执行生成的curl命令。

可选参数的使用 数据API中使用中括号[]标记可选参数，例如以下SQL执行语句： select * from table01 where id=${id} [or sex='${sex}'] 用[]括起来的那部分语句，表示当后端服务请求中携带参数${sex}时候，才会生效；不带参数${sex}的时候，[]括起来的语句在执行时将被忽略。 后端服务请求携带了参数id=88，可选参数sex没有携带，则执行SQL语句： select * from table01 where id=88; 后端服务请求携带了参数id=88和sex=female，则执行SQL语句： select * from table01 where id=88 or sex='female'; 父主题： 自定义后端开发（数据后端）

配置设备连接信息 解压Demo压缩包，在“src”目录的底层路径下找到DeviceConnectDemo.java文件。 使用Java编辑工具打开这个文件，编辑设备连接的信息。运行成功后，在“设备管理”页面可以看到在线设备状态。 Demo工程中依赖的软件包在lib目录下，使用Demo时需要将demo的lib目录设置为当前工程的lib目录。 // 设备连接地址，格式为：tcp://ip:port final String host = ""; // 设备客户端ID final String clientId = ""; // 示例仅用作测试或示意，设备认证的用户名为敏感信息，请勿硬编码使用 final String userName = ""; // 示例仅用作测试或示意，设备认证的密码为敏感信息，请勿硬编码使用 final String password = ""; // 设备Publish权限的Topic final String pubTopic = ""; // 设备Subscribe权限的Topic final String subTopic = ""; // 设备发送的消息内容 final String payload = "hello world.";

自定义后端开发要求 函数后端开发要求： 仅支持使用JavaScript编写函数，JavaScript的运行采用Java Nashorn的运行标准，支持ECMAScript Edition 5.1规范。 函数后端支持的脚本大小最大为32KB。 数据后端开发要求： 若数据后端执行语句查询获取的数据量较大，建议携带offset和limit参数进行分页，避免因响应数据太大导致响应超时。使用方式如下： select * from table01 limit '${limit}' offset ${offset} 其中offset和limit参数key在后端服务请求的Headers、Parameters或Body中传递。 不建议开启结果分页选项，结果分页当前仅支持2000条以内数据的分页。 数据后端支持的执行语句大小最大为32KB。

示例 { "msgType": "cloudReq", "mid": 54132, "cmd": "command1", "paras": { "temperature": 123 }, "serviceId": "service1", "deviceId": "D23pigXo"}

API调用认证开发要求 开发工具版本要求： IntelliJ IDEA：2018.3.5或以上版本。 Eclipse：3.6.0或以上版本。 Visual Studio：2019 version 16.8.4或以上版本。 开发语言环境版本要求： Java：1.8.111或以上版本的Java Development Kit。 Go：1.14及以上版本的Go安装包。 Python：2.7或3.X版本的Python安装包。 JavaScript：15.10.0及以上版本的Nodejs安装包。 PHP：8.0.3及以上版本的PHP安装包。 Android：4.1.2及以上版本的Android Studio。 浏览器版本要求：Chrome 89.0或以上版本。 SDK签名限制： 使用SDK对API请求签名时，仅支持对Body体为12M及以下的请求进行签名。 发送API请求时，SDK会将当前时间置于HTTP的X-Sdk-Date头，将签名信息置于Authorization头。签名只在一个有限的时间内是有效的，超时即无效。 ROMA Connect除了校验X-Sdk-Date的时间格式外，还会校验该时间值与收到请求的时间差，如果时间差超过15分钟，ROMA Connect将拒绝请求。因此，客户端须注意本地与NTP服务器的时间同步，避免请求消息头X-Sdk-Date的值出现较大误差。

后端服务签名校验开发要求 开发工具版本要求： IntelliJ IDEA：2018.3.5或以上版本。 Eclipse：3.6.0或以上版本。 Visual Studio：2019 version 16.8.4或以上版本。 开发语言环境版本要求： Java：1.8.111或以上版本的Java Development Kit。 Python：2.7或3.X版本的Python安装包。 SDK使用限制： Java SDK仅支持hmac和basic类型的后端服务签名。 Python SDK仅支持hmac类型的后端服务签名。 C# SDK仅支持hmac类型的后端服务签名。

参数说明 参数 必选/可选 类型 参数描述 clientId 必选 String(256) 一机一密的设备clientId由4个部分组成：deviceId/nodeId、鉴权类型、密码签名类型、时间戳，通过下划线“_”分隔。 鉴权类型：长度1字节，当前支持2个类型： “0”，表示使用一机一密设备的deviceId接入。 “2”，表示使用一机一密设备的nodeId接入。 密码签名类型：长度1字节，当前支持2种类型。 “0”代表HMACSHA256不校验时间戳。 “1”代表HMACSHA256校验时间戳。 时间戳：为设备连接平台时的UTC时间，格式为YYYYMMDDHH，如UTC 时间2018/7/24 17:56:20，则应表示为2018072417。 以deviceId为例的clientId示例为：D39564861q3gDa_0_0_2018072417 Username 必选 String(256) 一机一密的设备“Username”。 使用deviceId接入时填写为设备注册成功后返回的“deviceId”值。 使用nodeId接入时填写为设备注册成功时的“nodeId”值。 Password 必选 String(256) Password的值为使用“HMACSHA256”算法以时间戳为密钥，对secret进行加密后的值。 secret为注册设备时平台返回的secret，或者是设备自身的secret。

生产消息 SASL认证方式 注意，加粗内容需要替换为实例自有信息。 from kafka import KafkaProducerimport ssl##连接信息conf = { 'bootstrap_servers': ["ip1:port1","ip2:port2","ip3:port3"], 'topic_name': 'topic_name', 'sasl_plain_username': 'username', 'sasl_plain_password': 'password'}context = ssl.create_default_context()context = ssl.SSLContext(ssl.PROTOCOL_SSLv23)context.verify_mode = ssl.CERT_REQUIRED##证书文件context.load_verify_locations("phy_ca.crt")print('start producer')producer = KafkaProducer(bootstrap_servers=conf['bootstrap_servers'], sasl_mechanism="PLAIN", ssl_context=context, security_protocol='SASL_SSL', sasl_plain_username=conf['sasl_plain_username'], sasl_plain_password=conf['sasl_plain_password'])data = bytes("hello kafka!", encoding="utf-8")producer.send(conf['topic_name'], data)producer.close()print('end producer') 示例代码中的参数说明，可参考获取MQS连接信息获取参数值。 bootstrap_servers：MQS连接地址和端口。 topic_name：要生产消息的Topic名称。 sasl_plain_username和sasl_plain_password：开启SASL_SSL认证时所使用的用户名和密码。 context.load_verify_locations：开启SASL_SSL认证时所使用的客户端证书。 非SASL认证方式 注意，加粗内容需要替换为实例自有信息。 from kafka import KafkaProducerconf = { 'bootstrap_servers': ["ip1:port1","ip2:port2","ip3:port3"], 'topic_name': 'topic_name',}print('start producer')producer = KafkaProducer(bootstrap_servers=conf['bootstrap_servers'])data = bytes("hello kafka!", encoding="utf-8")producer.send(conf['topic_name'], data)producer.close()print('end producer') 示例代码中的参数说明，可参考获取MQS连接信息获取参数值。 bootstrap_servers：MQS连接地址和端口。 topic_name：要生产消息的Topic名称。

消费消息 SASL认证方式 注意，加粗内容需要替换为实例自有信息。 from kafka import KafkaConsumerimport ssl##连接信息conf = { 'bootstrap_servers': ["ip1:port1","ip2:port2","ip3:port3"], 'topic_name': 'topic_name', 'sasl_plain_username': 'username', 'sasl_plain_password': 'password', 'consumer_id': 'consumer_id'}context = ssl.create_default_context()context = ssl.SSLContext(ssl.PROTOCOL_SSLv23)context.verify_mode = ssl.CERT_REQUIRED##证书文件context.load_verify_locations("phy_ca.crt")print('start consumer')consumer = KafkaConsumer(conf['topic_name'], bootstrap_servers=conf['bootstrap_servers'], group_id=conf['consumer_id'], sasl_mechanism="PLAIN", ssl_context=context, security_protocol='SASL_SSL', sasl_plain_username=conf['sasl_plain_username'], sasl_plain_password=conf['sasl_plain_password'])for message in consumer: print("%s:%d:%d: key=%s value=%s" % (message.topic, message.partition,message.offset, message.key,message.value))print('end consumer') 示例代码中的参数说明，可参考获取MQS连接信息获取参数值。 bootstrap_servers：MQS连接地址和端口。 topic_name：要消费消息的Topic名称。 sasl_plain_username和sasl_plain_password：开启SASL_SSL认证时所使用的用户名和密码。 consumer_id：消费组名称。根据业务需要，自定义消费组名称，如果设置的消费组不存在，系统会自动创建。 context.load_verify_locations：开启SASL_SSL认证时所使用的客户端证书。 非SASL认证方式 注意，加粗内容需要替换为实例自有信息。 from kafka import KafkaConsumerconf = { 'bootstrap_servers': ["ip1:port1","ip2:port2","ip3:port3"], 'topic_name': 'topic_name', 'consumer_id': 'consumer_id'}print('start consumer')consumer = KafkaConsumer(conf['topic_name'], bootstrap_servers=conf['bootstrap_servers'], group_id=conf['consumer_id'])for message in consumer: print("%s:%d:%d: key=%s value=%s" % (message.topic, message.partition,message.offset, message.key,message.value))print('end consumer') 示例代码中的参数说明，可参考获取MQS连接信息获取参数值。 bootstrap_servers：MQS连接地址和端口。 topic_name：要消费消息的Topic名称。 consumer_id：消费组名称。根据业务需要，自定义消费组名称，如果设置的消费组不存在，系统会自动创建。

参数说明 字段名 必选/可选 类型 参数描述 id 必选 Integer 删除子设备命令ID。 deviceId 必选 String 平台生成的设备唯一标识，对应设备客户端ID。 requestTime 必选 Timestamp 请求时间戳。 request 必选 JsonObject 子设备信息。 JsonObject结构体说明 字段名 必选/可选 类型 参数描述 manufacturerName 必选 String 厂商名称。 支持长度2-64。 manufacturerId 必选 String 厂商ID。 支持英文大小写，数字，中划线和下划线，长度2-50。 model 必选 String 产品型号。 支持英文大小写，数字，中划线和下划线，长度2-50。

方法详情 public String getType() 获取数据源的类型 返回信息 返回数据源类型 public String getUrl() 获取连接字符串。 返回信息 返回连接字符串 public String getUser() 获取用户名 返回信息 返回用户名 public String getPassword() 获取密码 返回信息 返回密码 public void setType(String type) 设置数据源类型，可以为"mysql","mssql","oracle","postgresql","hive","redis","mongodb" 输入参数 type：类型 public void setUrl(String url) 设置数据源连接字符串。 如果数据源类型为"mysql","mssql","oracle","postgresql","hive"，则填写jdbc连接字符串。例如："jdbc:mysql://127.0.0.1:8888/db?useUnicode=true&characterEncoding=utf8"。 如果为数据源类型为"redis"，则格式为"127.0.0.1:6379@0"，其中，"@0"可省略，为redis数据库编号。 如果为数据源类型为"mongodb"，则格式为"127.0.0.1:27017@db"，其中，db为数据库名称。 输入参数 url：连接字符串 public void setUser(String user) 设置数据源用户名。如果为数据源类型为"redis"，则不需要填写。 输入参数 user：用户名 public void setPassword(String password) 设置数据源密码。 输入参数 password：密码

示例 { "requestTime": 1576639584536, "request": { "manufacturerName": "ATest_n", "manufacturerId": "Test_n", "model": "A_n" }, "id": 8, "deviceId": "n-device"}

方法列表 返回类型 方法和说明 String getType() 获取数据源的类型 String getUrl() 获取连接字符串。 String getUser() 获取用户名 String getPassword() 获取密码 void setType() 设置数据源类型，可以为"mysql","mssql","oracle","postgresql","hive","redis","mongodb" void setUrl() 设置数据源连接字符串。 void setUser() 设置数据源用户名 void setPassword() 设置数据源密码

使用示例 通过以下java代码生成公钥和私钥： import java.security.KeyPair;import java.security.KeyPairGenerator;import java.security.PrivateKey;import java.security.PublicKey;import java.util.Base64;public class Main { public static void main(String[] args) { try { KeyPairGenerator keyPairGenerator = KeyPairGenerator.getInstance("RSA"); keyPairGenerator.initialize(1024); KeyPair keyPair = keyPairGenerator.generateKeyPair(); PublicKey publicKey = keyPair.getPublic(); System.out.println("publicKey:" + new String(Base64.getEncoder().encode(publicKey.getEncoded()))); PrivateKey privateKey = keyPair.getPrivate(); System.out.println("privateKey:" + new String(Base64.getEncoder().encode(privateKey.getEncoded()))); } catch (Exception e) { e.printStackTrace(); return; } }} 将上述公钥和私钥填入到下面代码中： importClass(com.roma.apic.livedata.common.v1.RSAUtils);importClass(com.roma.apic.livedata.common.v1.Base64Utils);function execute(data) { var publicKeyString = "MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDd4CRRppmYVlFl3dX4iVGN+2Twy5gLeEPRbvhOko/xFipGF7XV0weTp4wCakgdnm+DR4gBBrQtfAuKwYIBPIr+C1FI5sKYA3NxazDWUcXR3xlPM5D0DWjacjcMjnaj2v21WZxGpwHZHQ9TLd4OBBq3fva1r/cE8s1Lji5QeFiklwIDAQAB"; var privateKeyString = "**********"; var publicKey = RSAUtils.getPublicKey(publicKeyString) var privateKey = RSAUtils.getPrivateKey(privateKeyString) var origin = "hello rsa" var encrypted = RSAUtils.encrypt(Base64Utils.encode(origin), publicKey) var decrypted = RSAUtils.decrypt(encrypted, privateKey) return decrypted}

方法列表 返回类型 方法和说明 int getDatabase() 获取jedis的database，默认为0 String[] getIp() 获取redis的IP地址列表 String getMaster() 获取jedis的master名称（当mode为"MASTER_SLAVE"时有效） int getMaxAttempts() 获取jedis的重试次数，默认10000 int getMaxIdel() 获取jedis连接池中空闲连接数的上限，默认5 int getMaxWait() 获取jedis连接池耗尽时等待时间上限，默认60秒 String getMode() 获取jedis的类型，可设置为“SINGLE”/“CLUSTER”/“MASTER_SLAVE” String getPassPhrase() 获取jedis的密码 String[] getPort() 获取所有端口号 int getSoTimeout() 获取jedis的读取超时时间，默认600 int getTimeout() 获取jedis的超时时间，默认1000 void setDatabase(int database) 设置jedis的database void setIp(String[] ip) 设置IP地址 void setMaster(String master) 设置jedis的master名称（当mode为“MASTER_SLAVE”时有效） void setMaxAttempts(int maxAttempts) 设置jedis的重试次数，默认10000 void setMaxIdel(int maxIdel) 设置jedis连接池中空闲连接数的上限，默认5 void setMaxWait(int maxWait) 设置jedis连接池耗尽时等待时间上限，默认60 void setMode(String mode) 设置jedis的类型，可设置为“SINGLE”/“CLUSTER”/“MASTER_SLAVE” void setPassPhrase(String passPhrase) 设置jedis的密码 void setPort(String[] port) 设置端口号 void setSoTimeout(int soTimeout) 设置jedis的读取超时时间 void setTimeout(int timeout) 设置jedis的超时时间

方法详情 public int getDatabase() 获取redis的database，默认为0 返回信息 返回database public String[] getIp() 获取所有IP地址 返回信息 返回IP地址的String数组 public String getMaster() 获取redis的master名称（当mode为“MASTER_SLAVE”时有效） 返回信息 返回master名称 public int getMaxAttempts() 获取redis的重试次数，默认10000 返回信息 返回重试次数 public int getMaxIdel() 获取jedis连接池中空闲连接数的上限，默认5 返回信息 返回连接池中空闲连接数的上限 public int getMaxWait() 获取jedis连接池耗尽时等待时间上限，默认60秒 返回信息 返回连接池耗尽时等待时间上限 public String getMode() 获取redis的类型，可设置为“SINGLE”/“CLUSTER”/“MASTER_SLAVE” 返回信息 返回redis的类型 public String getPassPhrase() 获取redis的密码 返回信息 返回redis的密码 public String[] getPort() 获取所有端口号 返回信息 返回端口号的String数组 public int getSoTimeout() 获取jedis的读取超时时间，默认600秒 返回信息 返回soTimeout public int getTimeout() 获取jedis的超时时间，默认1000秒 返回信息 返回超时时间 public void setDatabase(int database) 设置redis的database 输入参数 database：database public void setIp(String[] ip) 设置ip地址 输入参数 ip：IP地址 public void setMaster(String master) 设置redis的master名称（当mode为“MASTER_SLAVE”时有效） 输入参数 master：redis的master名称 public void setMaxAttempts(int maxAttempts) 设置jedis的重试次数 输入参数 maxAttempts：重试次数 public void setMaxIdel(int maxIdel) 设置jedis的连接池中空闲连接数的上限，默认5 输入参数 maxIdel：连接池中空闲连接数的上限 public void setMaxWait(int maxWait) 设置jedis的连接池耗尽时等待时间上限，默认60秒 输入参数 maxWait：连接池耗尽时等待时间上限 public void setMode(String mode) 设置redis的类型，可设置为“SINGLE”/“CLUSTER”/“MASTER_SLAVE” 输入参数 mode：类型 public void setPassPhrase(String passPhrase) 设置redis的密码 输入参数 passPhrase：密码 public void setPort(String[] port) 设置端口号 输入参数 port：端口号 public void setSoTimeout(int soTimeout) 设置jedis的读取超时时间，默认600秒 输入参数 soTimeout：读取超时时间 public void setTimeout(int timeout) 设置jedis的超时时间 输入参数 timeout：超时时间，单位秒

使用示例 importClass(com.roma.apic.livedata.client.v1.RedisClient);importClass(com.roma.apic.livedata.config.v1.JedisConfig);function execute(data) { var config = new JedisConfig(); config.setIp(["1.1.1.1"]); config.setPort(["6379"]); config.setMode("SINGLE"); var redisClient = new RedisClient(config); var count = redisClient.get("visit_count") if (!count) { redisClient.put("visit_count", 1); }else { redisClient.put("visit_count", parseInt(count) + 1); } return redisClient.get("visit_count");}

使用示例 SQL数据源示例： importClass(com.roma.apic.livedata.client.v1.DataSourceClient);importClass(com.roma.apic.livedata.config.v1.DataSourceConfig);function execute(data){ var config = new DataSourceConfig() config.setType("mysql") config.setUrl("jdbc:mysql://127.0.0.1:3306/db?allowPublicKeyRetrieval=true") config.setUser("username") config.setPassword("password") var ds = new DataSourceClient(config) return ds.execute("SELECT * FROM person where name = ? and age = ?", "Tom", 20);}

方法详情 public Object put(String key, Object value) 设置配置参数 输入参数 key：配置信息key value：配置信息value 支持以下配置参数： jco.client.ashost：SAP服务器IP jco.client.sysnr：系统编号 jco.client.client：SAP集团 jco.client.user：SAP用户名 jco.client.passwd：密码 jco.client.lang：登录语言 jco.destination.pool_capacity：最大连接数 jco.destination.peak_limit：最大连接线程 apic.async：是否为异步调用。"true"表示异步调用，默认为同步调用 返回信息 返回value