检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
量。 配置参数 参数 说明 变量名 填写变量的名称。 变量类型 选择变量的类型，目前支持字符串、整数、长整数、小数、布尔和对象。 变量值 填写变量的值。变量值可以是一个常量，如“hello world”，也可以使用表达式引用前序步骤的变量，例如 ${a}、${payload}。 父主题：
ROMA Connect不能保证消费重复的消息，业务侧需保证消息处理的幂等性。 消费线程退出要调用Consumer的close方法，避免同一个组的其他消费者阻塞sesstion.timeout.ms的时间。 Producer使用建议 同步复制客户端需要配合使用：acks=-1 配置发送失败重试：retries=3
String 作用的APP名称 app_id String 作用的APP编号 object_id String 特殊对象的身份标识 object_type String 特殊对象类型：APP、USER object_name String 作用的APP或租户的名称 throttle_id
步实时数据的场景。实现一个源端多个数据表到一个目标端多个数据表的实时同步及增量同步，提高了数据的集成同步效率。 组合任务支持数据表之间字段（列）级别的灵活映射，例如源端一个数据表中的多个字段可分别映射到目标端的不同数据表中，或者源端多个数据表中的字段可以映射到目标端的一个数据表中。
说明 后端名称 填写后端的名称，根据规划自定义。建议您按照一定的命名规则填写后端名称，方便您快速识别和查找。 集成应用 选择后端所属的集成应用。若没有可用的集成应用，可单击右侧的“新建集成应用”，创建一个集成应用。 后端请求方法 选择后端的请求方法，可选择“GET”、“POST”、“PUT”和“DELETE”。
“脚本处理”组件用于处理数据。用户可使用指定的编程语言编写脚本，对传入“脚本处理”组件的数据进行处理，生成新的数据供后续步骤使用。 配置参数 参数 说明 语言 选择编写脚本使用的编程语言，当前只支持ES5版本的JavaScript语言。 内容 编写脚本内容。 可通过变量的形式引用前序步骤中的数据，请参考引用变量。
单击“Next”。 图2 New Project 单击“...”，在弹出的对话框中选择解压后的SDK路径，单击“Finish”。 图3 选择解压后的SDK路径 完成工程创建后，目录结构如下。 图4 新建工程的目录结构 “signer.php”为示例代码，请根据实际情况修改参数后使用。具体代码说明请参考调用API示例。
Connect控制台，在“实例”页面单击实例上的“查看控制台”，进入实例控制台。 在左侧的导航栏选择“数据源管理”，单击页面右上角的“接入数据源”。 在接入数据源页面的“默认数据源”页签下，选择“MRS Kafka”类型的数据源，然后单击“下一步”。 在页面中配置数据源的连接信息。 表1 数据源连接信息
rchestration的时候必填，并且生成的参数所在的位置必须在api绑定的编排规则中存在 id String 编号 req_param_id String 关联的请求参数对象编号 req_param_location String 关联的请求参数对象位置 表23 BackendParam
响应Body参数 参数 参数类型 描述 total Integer Topic的总数。 size Integer 当前查询的Topic数量。 permissions Array of strings 允许操作的权限。 topics Array of topics objects Topic列表。
后端请求路径 填写后端的请求路径，格式如：/getUserInfo/userId。 请求路径中的内容区分大小写。 后端安全认证 选择后端的安全认证方式。 签名密钥：表示使用签名密钥的方式，对请求发送方进行认证。若使用签名密钥进行认证，调用该后端服务的API，也需要绑定相同的签名密钥。 无认证：表示不对调用请求进行认证。
类型 说明 content 是 String 脚本语句，格式为经base64编码的字符串，实际脚本需经过base64解码后获取。 result 是 String 返回对象，执行语句的执行结果将封装在该对象中返回。 该参数仅对数据后端生效，函数后端不使用。 type 是 String
rchestration的时候必填，并且生成的参数所在的位置必须在API绑定的编排规则中存在 id String 编号 req_param_id String 关联的请求参数对象编号 req_param_location String 关联的请求参数对象位置 表28 BackendParam
实时：实时将源端产生的数据集成到目标端。 两种集成模式分别所支持的数据源类型请参见接入数据源。 支持自定义数据映射规则 在进行源端到目标端的数据字段转换时，您可以自定义映射规则，例如将源数据的一个数据列复制出相同的多列数据，再集成到目标端。 支持不同网络环境间的数据集成 源端数据与
Integer Topic分区数，设置消费的并发数。 取值范围：1-100。 默认值：3。 replication 否 Integer 副本数，配置数据的可靠性。 取值范围：1-3。 默认值：3。 说明： 消息集成轻量化版的副本数只能为1。 基础版的取值范围： 1-3。 专业版/高性能设备接入版（一百万）取值范围：
(白名单类型) DENY (黑名单类型) entity_type 否 String 作用的对象类型： IP DOMAIN precise_search 否 String 指定需要精确匹配查找的参数名称，多个参数需要支持精确匹配时参数之间使用“,”隔开。 目前仅支持name。 请求参数
如下为实例中单个任务运行时各数据源的读写性能，仅供参考。实际单个任务运行的性能还受网络带宽、数据源服务端性能等因素影响。在实例中有多个任务并发运行的情况下，受限于多个任务抢占CPU、内存等资源，任务的性能相比单个任务运行的性能会有不同程度的下降。 普通任务 ROMA Connect支持的数据集成普通任务中不同类型数据源的性能参考如下所示。
rchestration的时候必填，并且生成的参数所在的位置必须在api绑定的编排规则中存在 id String 编号 req_param_id String 关联的请求参数对象编号 req_param_location String 关联的请求参数对象位置 表23 BackendParam
分支名”获取该分支的执行结果。 失败时停止 并行处理出现错误时的是否停止。 True：表示任一并行处理的分支出现错误时，整个任务便停止，并返回错误信息。 False：表示并行处理的分支出现错误后，整个任务会继续执行后续节点。 超时时间(ms) 并行处理过程的最长执行时间，如果超
rchestration的时候必填，并且生成的参数所在的位置必须在API绑定的编排规则中存在 id String 编号 req_param_id String 关联的请求参数对象编号 req_param_location String 关联的请求参数对象位置 表16 BackendParam
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
