处理器-华为云

应用与数据集成平台 ROMA CONNECT-数据映射:目的端-数据格式为CSV样例

目的端-数据格式为 CS V样例是否跳过标题：CSV文件的表头，数值 true/false：输出数据是/否含有表头。分隔符：文件中每列数据通过单元格进行分隔，单元格可以为“制表符”、“空格”、“逗号”、“分号”。场景1：目的端数据源选择数据格式“CSV”，是否跳过标题：true，字段分隔符：逗号。导入文件时，当是否跳过标题选择“true”，默认解析csv第一行为字段名。源端MySQL数据库表 demo.statistics 中的数据： id city uuid1 suzhou uuid2 shanghai 数据映射输出数据为： ManufacturerId, ProductName uuid1, suzhou uuid2, shanghai 场景2：目的端数据源选择数据格式“CSV”，是否跳过标题：false，字段分隔符：逗号。导入文件时，当是否跳过标题选择“false”，不使用导入文件的头字段，系统默认设置字段filedN。源端MySQL数据库表 demo.statistics 中的数据： id city uuid1 suzhou uuid2 shanghai 数据映射输出数据为： uuid1, suzhou uuid2, shanghai

应用与数据集成平台 ROMA CONNECT 处理器

应用与数据集成平台 ROMA CONNECT-数据映射:配置参数

配置参数参数说明源端数据源设置源端数据源，数据库类型的数据源在选择完表之后会自动显示字段信息，其他格式的数据源需要通过导入文件或者手动增加的形式来添加字段。导入的文件目前主要支持json，xml和csv格式导入。目的端数据源设置目的端数据源，数据库类型的数据源在选择完表之后会自动显示字段信息，其他格式的数据源需要通过导入文件或者手动增加的形式来添加字段。导入的文件目前主要支持json，xml和csv格式导入。如果后续节点想要引用“数据映射”处理器的输出数据，可通过${节点id|payload.xxx}的形式来引用。节点id可通过单击“数据映射”处理器获取到。

应用与数据集成平台 ROMA CONNECT 处理器

应用与数据集成平台 ROMA CONNECT-数据映射:源端-数据格式为JSON样例

源端-数据格式为JSON样例当源端数据源的类型为“JSON”时，在使用数据映射时选择数据格式“JSON”，将源端数据源的输出作为源端数据源页签中“导入文件”的输入，根据文件的编码格式格式选择导入文件编码，可选项有GB2312、UTF-8和ASCII。此时源端数据源页签中会根据导入的文件内容自动生成相应的字段。目的端数据格式选择“MySQL”，在选择表名后，目的端数据源页签会自动生成数据库表中的字段。以下面的组合应用为例，该组合应用的主要功能是调用Open API获取OBS指定桶的对象列表，并将结果中的桶名称和对象名称通过数据映射，映射到MySql指定表中的相关字段，然后使用MySql添加记录的操作将桶名和对象名存储到MySql中。其中，对象存储服务 OBS产生的结果是数据映射的源端数据源，MySql是目的端数据源。可以通过使用Open API调用OBS连接器执行获取桶内对象列表的操作结果获得远端数据源的导入文件。也可以根据OBS连接器执行获取桶内对象列表的操作结果手动添加字段信息。源端导入的文件内容： { "responseHeaders": { "bucket-location": "cn-north-7", "connection": "keep-alive", "content-length": "504", "content-type": "application/xml", "date": "2024-04-24T07:07:43.000+00:00", "id-2": "32AAAQAAEAABAAAQAAEAABAAAQAAEAA BCS bOSbK ncLEgZnxffa8vFPuDgVIt7n9", "request-id": "0000018F0EEE84734012ACF15A46395E", "server": "OBS" }, "originalHeaders": { "connection": "keep-alive", "content-length": "504", "content-type": "application/xml", "date": "Wed, 24 Apr 2024 07:07:43 GMT", "server": "OBS", "x-obs-bucket-location": "cn-north-7", "x-obs-id-2": "32AAAQAAEAABAAAQAAEAABAAAQAAEAABCSbOSbK+ncLEgZnxffa8vFPuDgVIt7n9", "x-obs-request-id": "0000018F0EEE84734012ACF15A46395E" }, "statusCode": 200, "objectSummaries": [ { "bucketName": "test0223", "objectKey": "test0424.txt", "owner": { "displayName": null, "id": "0ab78f256080d2890feac0086234d7c0" }, "metadata": { "responseHeaders": {}, "originalHeaders": {}, "statusCode": 0, "lastModified": "2024-04-24T06:51:46.566+00:00", "contentLength": 19, "contentType": null, "contentEncoding": null, "contentDisposition": null, "cacheControl": null, "contentLanguage": null, "expires": null, "etag": "\"0b26e313ed4a7ca6904b0e9369e5b957\"", "contentMd5": null, "crc64": null, "storageClass": "STANDARD", "webSiteRedirectLocation": null, "nextPosition": -1, "appendable": false, "objectStorageClass": "STANDARD", "allMetadata": {}, "metadata": {}, "requestId": "" }, "objectContent": null } ], "commonPrefixes": [], "extendCommonPrefixes": [], "bucketName": "test0223", "truncated": false, "prefix": "", "marker": "", "maxKeys": 1000, "delimiter": null, "nextMarker": null, "location": "cn-north-7", "extenedCommonPrefixes": [], "objects": [ { "bucketName": "test0223", "objectKey": "test0424.txt", "owner": { "displayName": null, "id": "0ab78f256080d2890feac0086234d7c0" }, "metadata": { "responseHeaders": {}, "originalHeaders": {}, "statusCode": 0, "lastModified": "2024-04-24T06:51:46.566+00:00", "contentLength": 19, "contentType": null, "contentEncoding": null, "contentDisposition": null, "cacheControl": null, "contentLanguage": null, "expires": null, "etag": "\"0b26e313ed4a7ca6904b0e9369e5b957\"", "contentMd5": null, "crc64": null, "storageClass": "STANDARD", "webSiteRedirectLocation": null, "nextPosition": -1, "appendable": false, "objectStorageClass": "STANDARD", "allMetadata": {}, "metadata": {}, "requestId": "" }, "objectContent": null } ], "requestId": "0000018F0EEE84734012ACF15A46395E" } 数据映射输出结果为：

应用与数据集成平台 ROMA CONNECT 处理器

应用与数据集成平台 ROMA CONNECT-非对称加解密:配置参数

配置参数参数说明私钥解密时必填，base64编码。公钥加密时必填，base64编码。操作当前支持非对称加密、非对称解密。加密算法加密算法，当前支持RSA。明文仅当“操作”选择“非对称加密”时需要配置。待加密明文。密文仅当“操作”选择“非对称解密”时需要配置。待解密密文（base64编码）。填充模式明文填充模式，当前支持RSA_PKCS1_OAEP_PADDING。 OAEP哈希算法仅当填充模式为RSA_PKCS1_OAEP_PADDING时需要配置。 OAEP哈希算法，可选择SHA256、SHA384。

应用与数据集成平台 ROMA CONNECT 处理器

联接 CODEARTSLINK-脚本处理:配置参数

配置参数参数说明语言选择编写脚本使用的编程语言，当前只支持ES5版本的JavaScript语言。输出到变量脚本处理的结果将存入该变量，后续步骤可通过“${变量名}”的方式引用当前脚本处理结果。内容编写脚本内容。可通过变量的形式引用前序步骤中的数据，请参考引用变量。当需要解析JSON格式的内容数据时，可通过“JSON.parse('${body}')”的方式将内容数据转换为JSON对象，然后进行数据解析。脚本处理组件可以生成一个输出结果并传给后续步骤，用户需要在脚本的末尾指定要输出的变量名称，例如： function getUser(){ return {"id": ${property.id},"name":"${property.name}"}; } var user=getUser(); user; 说明：如果需要编写函数或者逻辑代码块，需使用“{”和“}”围绕代码块。图1 脚本处理

联接 CODEARTSLINK 处理器

应用与数据集成平台 ROMA Connect-并行处理:配置参数

配置参数参数说明输出格式合并结果的格式，当前仅支持“Json”，表示合并结果以JSON字符串的格式输出。可通过如下两种方法获取某一分支的结果：后续节点为“脚本处理”时，使用JSON.parse('${body}')方式将合并结果转换为JSON对象，然后通过分支名称获取分支的结果。如： var result=JSON.parse('${body}'); var branch_result=result.分支名称或者 var branch_result=result['分支名称'] 后续节点为“变量赋值”、“分支判断”和“数据转换”时，使用“$.分支名”获取该分支的执行结果。失败时停止并行处理出现错误时的是否停止。 True：表示任一并行处理的分支出现错误时，整个任务便停止，并返回错误信息。 False：表示并行处理的分支出现错误后，整个任务会继续执行后续节点。超时时间(ms) 并行处理过程的最长执行时间，如果超过该时间后，仍有未执行完成的分支任务，则该分支的任务将被丢弃，且最终的合并结果中不会包含该分支。超时时间为0时，表示不设置超时时间，将等待所有分支任务执行完成。 “并行处理”节点的分支名称，需在后续相邻节点的连线上配置。

应用与数据集成平台 ROMA Connect 处理器

云服务器内容精选

处理器

7*24

备案

专业服务

退订

建议反馈

售前咨询热线