-
KafkaConsumer类说明 - 应用与数据集成平台 ROMA Connect
KafkaConsumer(config) var records = consumer.consume(topic, 5000, 10); var res = [] var iter = records.iterator() while (iter.hasNext())
-
接入ArtemisMQ数据源 - 应用与数据集成平台 ROMA Connect
在左侧的导航栏选择“数据源管理”,单击页面右上角的“接入数据源”。 在接入数据源页面的“默认数据源”页签下,选择“ArtemisMQ”类型的数据源,然后单击“下一步”。 在页面中配置数据源的连接信息。 表1 数据源连接信息 参数 配置说明 数据源名称 填写数据源的名称,根据规划自
-
接入ActiveMQ数据源 - 应用与数据集成平台 ROMA Connect
在左侧的导航栏选择“数据源管理”,单击页面右上角的“接入数据源”。 在接入数据源页面的“默认数据源”页签下,选择“ActiveMQ”类型的数据源,然后单击“下一步”。 在页面中配置数据源的连接信息。 表1 数据源连接信息 参数 配置说明 数据源名称 填写数据源的名称,根据规划自定
-
自定义后端开发(数据后端) - 应用与数据集成平台 ROMA Connect
自定义后端开发(数据后端) SQL语法 存储过程调用 多个数据源编排 可选参数的使用 父主题: 服务集成开发指导
-
修改规则 - 应用与数据集成平台 ROMA Connect
data_parsing_status 否 Integer 数据解析状态,0-启用,1-停用,不填写时默认为1-禁用。 最小值:0 最大值:10 sql_field 否 String SQL查询字段。 最小长度:0 最大长度:2000 sql_where 否 String SQL查询条件。 最小长度:0 最大长度:2000
-
接入IBM MQ数据源 - 应用与数据集成平台 ROMA Connect
在左侧的导航栏选择“数据源管理”,单击页面右上角的“接入数据源”。 在接入数据源页面的“默认数据源”页签下,选择“IBM MQ”类型的数据源,然后单击“下一步”。 在页面中配置数据源的连接信息。 表1 数据源连接信息 参数 配置说明 数据源名称 填写数据源的名称,根据规划自定义
-
接入RabbitMQ数据源 - 应用与数据集成平台 ROMA Connect
在左侧的导航栏选择“数据源管理”,单击页面右上角的“接入数据源”。 在接入数据源页面的“默认数据源”页签下,选择“RabbitMQ”类型的数据源,然后单击“下一步”。 在页面中配置数据源的连接信息。 表1 数据源连接信息 参数 配置说明 数据源名称 填写数据源的名称,根据规划自定
-
查询产品列表 - 应用与数据集成平台 ROMA Connect
instance_id string 是 租户使用ROMA Connect的实例ID。 请求消息 请求参数 无 请求示例 https://example.cloud.com/v1/80e2b******f4a398d6409a50932d917/link/instances/fb3b24ab-5d8
-
查询规则 - 应用与数据集成平台 ROMA Connect
data_parsing_status Integer 数据解析状态,ENABLE时data_parsing必填,0-启用,1-停用。 最小值:0 最大值:10 sql_field String SQL查询字段。 最小长度:0 最大长度:2000 sql_where String SQL查询条件。 最小长度:0
-
创建设备自定义Topic - 应用与数据集成平台 ROMA Connect
自定义Topic的权限,只支持pub或sub两种权限。 remark string 否 描述信息,不能超过200个字符。 请求示例 https://example.cloud.com/v1/80e2b******f4a398d6409a50932d917/link/instances/fb3b24ab-5d8
-
查询设备列表 - 应用与数据集成平台 ROMA Connect
instance_id string 是 租户使用ROMA Connect的实例ID。 请求消息 请求参数 无 请求示例 https://example.cloud.com/v1/80e2b******f4a398d6409a50932d917/link/instances/fb3b24ab-5d8
-
查询设备Topic列表 - 应用与数据集成平台 ROMA Connect
product_name string 是 根据输入的产品名称查询。 请求消息 请求参数 无 请求示例 https://example.cloud.com/v1/80e2b******f4a398d6409a50932d917/link/instances/fb3b24ab-5d8
-
创建设备 - 应用与数据集成平台 ROMA Connect
integer 否 设备状态,默认值为0,只能输入0或1。 0表示启用设备。 1表示停用设备。 请求示例 https://example.cloud.com/v1/80e2b******f4a398d6409a50932d917/link/instances/fb3b24ab-5d8
-
导入导出规则 - 应用与数据集成平台 ROMA Connect
DataParsingStatus 数据解析状态。 必填,启用:0,禁用:1。 SqlField 查询字段。 选填,建议通过页面创建。 SqlWhere 查询条件。 选填,建议通过页面创建。 AppName 应用名称。 必填,应用名称应已存在。 Sources 数据源端配置。 选填,建议通过页面创建。
-
企业微信 - 应用与数据集成平台 ROMA Connect
需成员自行修改(此情况下该参数被忽略,但不会报错)。 邮箱 邮箱。长度不超过64个字节,且为有效的email格式。企业内必须唯一。若是绑定了腾讯企业邮箱的企业微信,则需要在腾讯企业邮箱中修改邮箱(此情况下该参数被忽略,但不会报错)。 企业邮箱 企业邮箱。仅对开通企业邮箱的企业有效
-
查询规则详情 - 应用与数据集成平台 ROMA Connect
data_parsing_status Integer 数据解析状态,ENABLE时data_parsing必填,0-启用,1-停用。 最小值:0 最大值:10 sql_field String SQL查询字段。 最小长度:0 最大长度:2000 sql_where String SQL查询条件。 最小长度:0
-
创建规则引擎目的端 - 应用与数据集成平台 ROMA Connect
string 否 MQS启用SSL时,需要传入MQS的密码,未启用SSL不需要传入该参数。 请求示例 https://example.cloud.com/v1/80e2b******f4a398d6409a50932d917/link/instances/fb3b24ab-5d8
-
MQS消息堆积最佳实践 - 应用与数据集成平台 ROMA Connect
消费者数量和分区数保持一致。 提高消费者的消费速度,通过优化消费者处理逻辑(减少复杂计算、第三方接口调用和读库操作),减少消费时间。 增加消费者每次拉取消息的数量:拉取数据/处理时间 >= 生产速度。 生产者端 生产消息时,给消息Key加随机后缀,使消息均衡分布到不同分区上。 在
-
调试规则 - 应用与数据集成平台 ROMA Connect
最小长度:1 最大长度:100000 表3 请求Body参数 参数 是否必选 参数类型 描述 test_data 否 String 测试的被规则执行的数据。 最小长度:0 最大长度:2000 test_rule_express 否 String 测试的规则。 最小长度:0 最大长度:2000