检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
台。 在左侧的导航栏选择“数据源管理”，单击页面右上角的“接入数据源”。 在接入数据源页面的“默认数据源”页签下，选择“MRS Hive”类型的数据源，然后单击“下一步”。 在页面中配置数据源的连接信息。 表1 数据源连接信息 参数 配置说明 数据源名称 填写数据源的名称，根据规
prepareValue) 执行SQL语句、存储过程或NOSQL查询语句 输入参数 prepareValue：仅在SQL语句中生效，用于替换SQL语句中的"?"参数，可以防止SQL注入。 返回信息 返回语句执行结果 父主题： 自定义后端开发（函数后端）
“脚本处理”组件用于处理数据。用户可使用指定的编程语言编写脚本，对传入“脚本处理”组件的数据进行处理，生成新的数据供后续步骤使用。 配置参数 参数 说明 语言 选择编写脚本使用的编程语言，当前支持ES6版本的JavaScript语言。 内容 编写脚本内容。 可通过变量的形式引用前序步骤中的数据，请参考引用变量。
当“类型”为“指定循环条件”时，可配置执行条件，满足执行条件时，最大循环次数为100，超出后运行报错。 遍历数组 当“类型”为“指定循环数组”时，可配置遍历数组，遍历数组的数据可以从上一节点获取，请参考引用变量。 数组最大长度为100，超出后运行报错。 并行遍历 当“类型”为“指定循环数组”时，可配置并行遍历，支持最大并行数为10。
非对称加解密 “非对称加解密”处理器用于使用指定的非对称加密算法对明文进行加密、对密文进行解密操作。 配置参数 参数 说明 私钥 解密时必填，base64编码。 公钥 加密时必填，base64编码。 操作 当前支持非对称加密、非对称解密。 加密算法 加密算法，当前支持RSA。 明文
message_offset 否 Integer 重置消费进度到指定偏移量。 如果传入offset小于当前最小的offset，则重置到最小的offset。 如果大于最大的offset，则重置到最大的offset。 message_offset、timestamp二者必选其一。 timestamp
业务使用介绍 功能简介 应用业务模型ABM是ROMA Connect的模型集成组件，ABM为客户提供统一的业务模型管理平台，可以提供通用的业务/技术模型定义管理，业务/技术模型对应元数据的自动/手动采集，提供模型查询、维护、业务与技术模型关联、数据关联分析等功能，同时提供数据访问管控、开放共享等能力，使用ROMA
通过在ROMA Connect中创建数据集成任务，您可以实现不同数据源之间的数据集成转换。ROMA Connect根据您在数据集成任务中的配置，决定如何将指定的源端的一个数据表中的数据集成到目标端的一个数据表中。 数据集成任务的配置分为任务基本信息、制定计划（可选）、源端信息、目标端信息、M
username, String password) 访问MQS提供的kafka（开启sasl_ssl）。 输入参数 servers：kafkaConfig中的bootstrap.servers信息 groupId：kafkaConfig中的group.id信息 username：用户名 password：密码
public SoapClient(SoapConfig soapCfg) 构造一个包含SoapConfig配置信息的SOAP请求。 参数：soapCfg表示传入SoapClient的配置信息。 方法列表 返回类型 方法和说明 APIConnectResponse execute() 用于发送SOAP请求
timeout：读取超时时间，最大值为30000毫秒，建议timeout设置值小于前端API的“后端超时”时间值 maxItems：读取消息的最大数量 返回信息 Kafka已消费的消息数组，消息数组即将多条消息的内容组成一个数组 父主题： 自定义后端开发（函数后端）
构造器详情 public KafkaProducer(Map configs) 构造一个Kafka消息生产者 参数：configs表示Kafka的配置信息 方法列表 返回类型 方法和说明 org.apache.kafka.clients.producer.RecordMetadata produce(String
app：集成应用可见 env_id String 绑定API的环境编码。 env_name String API授权绑定的环境名称 api_id String 绑定的API编码。 api_name String API的名称 attached_time String 绑定时间。 状态码：
满足当前条件时，表示传入“分支判断”节点的数据满足指定的表达式时，将执行该分支上的步骤。 不满足其他条件时，表示传入“分支判断”节点的数据不满足其他所有分支的条件时，将执行该分支上的步骤。 表达式 当前条件分支的表达式。 如图1所示，1号标记位置的"且或"逻辑表示外层逻辑组的关联关系，单击5号标记位置的“添加组”添加外层逻辑组。
app：集成应用可见 env_id String 绑定API的环境编码。 env_name String API授权绑定的环境名称 api_id String 绑定的API编码。 api_name String API的名称 attached_time String 绑定时间。 状态码：
对称加解密 “对称加解密”处理器用于使用指定的对称加密算法对明文进行加密、对密文进行解密操作。 配置参数 参数 说明 操作 当前支持对称加密、对称解密、HMAC签名、HMAC验签。 加密算法 对称加/解密当前支持AES算法。 HMAC签名/验签当前支持HMAC算法。 加密模式 仅
更新redis缓存内容 输入参数 key：待更新缓存的key值 value：待更新缓存的value值 返回信息 返回执行结果 public Long remove(String key) 删除指定key值的缓存消息 输入参数 key：待删除缓存的key值 返回信息 返回执行结果 父主题： 自定义后端开发（函数后端）
配合DataSourceClient使用，对数据源进行配置。 构造器详情 public DataSourceConfig() 构造一个无参数的DataSourceConfig public DataSourceConfig(String type, String url, String
limit 否 Integer 当次查询返回的最大消费组ID个数，默认值为10，取值范围为1~50。 group 否 String 消费组名过滤查询，过滤方式为字段包含过滤。 topic 否 String 若指定Topic，则只查询该Topic的消费组。 最大长度：200 请求参数 无
dy体，base64Encoded表示传入的body是否已经base64编码 方法列表 返回类型 方法和说明 Object getBody() 获取响应的返回体 Map<String,String> getHeaders() 获取响应的返回头 Integer getStatusCode()
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
