华为云用户手册

配置参数说明 表1 配置参数 参数 配置说明 Name 响应头名称。每个插件中不能添加重复名称的响应头（不区分大小写）。 Value 响应头的值。当“Action”为“Delete”时响应头的值不生效，可为空。 Action 响应头操作，您可以覆盖、添加、删除、跳过或新增指定的响应头。 Override：覆盖 当API响应中存在指定的响应头时，使用当前响应头的值覆盖已有响应头的值。 当API响应中存在多个与指定响应头相同名称的响应头时，只会按当前响应头的值返回一条响应头记录。 当API响应中不存在指定的响应头时，添加当前响应头。 Append：添加 当API响应中存在指定的响应头时，将当前响应头的值添加到已有响应头的值之后，值之间用“,”分隔。 当API响应中存在多个与指定响应头相同名称的响应头时，会将多个响应头的值用“,”拼接后，再添加当前响应头的值。 当API响应中不存在指定的响应头时，添加当前响应头。 Delete：删除 当API响应中存在指定的响应头时，删除当前响应头。 当API响应中存在多个与指定响应头相同名称的响应头时，删除所有相同名称的响应头。 Skip：跳过 当API响应中存在指定的响应头时，跳过当前响应头。 当API响应中存在多个与指定响应头相同名称的响应头时，均不作处理直接返回。 当API响应中不存在指定的响应头时，添加当前响应头。 Add：新增 无论API响应中是否存在指定的响应头，都添加当前响应头。

CTS 支持的ROMA业务流操作 表6 CTS支持的ROMA业务流操作 操作名称 资源类型 事件名称 创建图 graph createGraph 更新图 graph updateGraph 启动图 graph batchStartGraphs 停止图 graph batchStopGraphs 删除图 graph batchDeleteGraphs 删除资产 graph deleteAssets 导出资产 assets handleExportFlowAssets 导入资产 assets handleImportFlowAssets 创建一个集成任务 integration createIntegration 更新集成任务 integration updateNewIntegration 删除一个集成任务 integration deleteIntegration 购买业务流 purchase purchaseBfs

CTS支持的ROMA MQS操作 表4 CTS支持的ROMA MQS操作 操作名称 资源类型 事件名称 MQS的kafka实例创建Topic成功 kafka Kafka_create_topicSuccess MQS的kafka实例创建Topic失败 kafka Kafka_create_topicFailure MQS的kafka实例删除Topic成功 kafka Kafka_delete_topicSuccess MQS的kafka实例删除Topic失败 kafka Kafka_delete_topicsFailure MQS的kafka实例修改Topic成功 kafka Kafka_alter_topicsSuccess MQS的kafka实例修改Topic失败 kafka Kafka_alter_topicsFailure MQS的kafka实例设置集成应用权限任务成功 kafka updateAppPoliciesSuccess MQS的kafka实例设置集成应用权限失败 kafka updateAppPoliciesFailure MQS的rocketmq实例创建Topic成功 rocketmq RocketMQ_Topic_CreationSuccess MQS的rocketmq实例创建Topic失败 rocketmq RocketMQ_Topic_CreationFailure MQS的rocketmq实例修改Topic成功 rocketmq RocketMQ_Topic_ModifySuccess MQS的rocketmq实例修改Topic失败 rocketmq RocketMQ_Topic_ModifyFailure MQS的rocketmq实例删除Topic成功 rocketmq RocketMQ_Topic_DeletionSuccess MQS的rocketmq实例删除Topic失败 rocketmq RocketMQ_Topic_DeletionFailure MQS的rocketmq实例创建消费组成功 rocketmq RocketMQ_Create_GroupSuccess MQS的rocketmq实例创建消费组失败 rocketmq RocketMQ_Create_GroupFailure MQS的rocketmq实例修改消费组成功 rocketmq RocketMQ_Group_ModifySuccess MQS的rocketmq实例修改消费组失败 rocketmq RocketMQ_Group_ModifySFailure MQS的rocketmq实例删除消费组成功 rocketmq RocketMQ_Group_DeletionSuccess MQS的rocketmq实例删除消费组失败 rocketmq RocketMQ_Group_DeletionFailure

CTS支持的ROMA LINK操作 表5 CTS支持的ROMA LINK操作 操作名称 资源类型 事件名称 创建产品 Product createProduct 编辑产品 Product updateProduct 删除产品 Product deleteProduct 上传产品 Product uploadProducts 重置产品密码 Product resetProductPassword 创建产品属性 Product addProductAttribute 编辑产品属性 Product updateProductAttribute 删除产品属性 Product removeProductAttribute 创建产品模板 Product createProductTemplete 更新产品模板 Product updateProductTemplete 删除产品模板 Product deleteProductTemplete 创建产品模板属性 Product addTempleteAttribute 更新产品模板属性 Product updateTempleteAttribute 删除产品模板属性 Product removeTempleteAttribute 创建设备 Device createDevice 编辑设备 Device updateDevice 删除设备 Device deleteDevice 上传设备 Device uploadDevices 重置设备密码 Device resetDevicePassword 创建Topic Topic createTopic 编辑Topic Topic updateTopic 删除Topic Topic deleteTopic 编辑设备影子 Device updateDeviceShadow 创建规则 Rule createRule 编辑规则 Rule updateRule 删除规则 Rule deleteRule 添加源端规则 Rule addRuleSource 删除源端规则 Rule removeRuleSource 添加目标端规则 Rule addRuleDestination 删除目标端规则 Rule removeRuleDestination

CTS支持的ROMA APIC操作 表3 CTS支持的ROMA APIC操作 操作名称 资源类型 事件名称 创建API分组 ApiGroup createApiGroup 删除API分组 ApiGroup deleteApiGroup 更新API分组 ApiGroup updateApiGroup 添加访问限制 ApiGroup deleteApiGroupLimit 解除访问限制 ApiGroup updateApiGroupLimit 为分组绑定自定义域名 ApiGroup createDomainBinding 为分组解绑自定义域名 ApiGroup relieveDomainBinding 为自定义域名添加证书 ApiGroup addDomainCertificate 为自定义域名删除证书 ApiGroup deleteDomainCertificate 创建API Api createApi 删除API Api deleteApi 批量删除API Api batchDeleteApi 修改API Api updateApi 发布API Api publishApi 下线API Api offlineApi 批量发布或下线API Api batchPublishOrOfflineApi 切换API版本 Api switchApiVersion 根据版本下线API Api offlineApiByVersion 调试API Api debugApi 创建环境 Environment createEnvironment 删除环境 Environment deleteEnvironment 修改环境 Environment updateEnvironment 创建环境变量 EnvVariable createEnvVariable 删除环境变量 EnvVariable deleteEnvVariable 创建集成应用 App createApp 删除集成应用 App deleteApp 修改集成应用 App updateApp 重置集成应用密钥 App resetAppSecret 授权 AppAuth grantAuth 解除授权 AppAuth relieveAuth 创建签名密钥 Signature createSignature 删除签名密钥 Signature deleteSignature 修改签名密钥 Signature updateSignature 绑定签名密钥 SignatureBinding createSignatureBinding 解绑签名密钥 SignatureBinding relieveSignatureBinding 创建访问控制策略 Acl createAcl 删除访问控制策略 Acl deleteAcl 批量删除访问控制策略 Acl batchDeleteAcl 修改访问控制策略 Acl updateAcl 添加访问控制策略的值 Acl addAclValue 删除访问控制策略的值 Acl deleteAclValue 绑定访问控制策略 AclBinding createAclBinding 解绑访问控制策略 AclBinding relieveAclBinding 批量解绑访问控制策略 AclBinding batchRelieveAclBinding 创建流控策略 Throttle createThrottle 删除流控策略 Throttle deleteThrottle 批量删除流控策略 Throttle batchDeleteThrottle 修改流控策略 Throttle updateThrottle 绑定流控策略 ThrottleBinding createThrottleBinding 解绑流控策略 ThrottleBinding relieveThrottleBinding 批量解绑流控策略 ThrottleBinding batchRelieveThrottleBinding 创建特殊流控策略 ThrottleSpecial createSpecialThrottle 删除特殊流控策略 ThrottleSpecial deleteSpecialThrottle 修改特殊流控策略 ThrottleSpecial updateSpecialThrottle 创建负载通道 Vpc createVpc 删除负载通道 Vpc deleteVpc 修改负载通道 Vpc updateVpc 为负载通道添加后端实例 Vpc addVpcMember 为负载通道删除后端实例 Vpc deleteVpcMember 导出单个API Swagger swaggerExportApi 批量导出API Swagger swaggerExportApiList 导出分组下所有API Swagger swaggerExportApiByGroup 导入API到新分组 Swagger swaggerImportApiToNewGroup 导入API到已有分组 Swagger swaggerImportApiToExistGroup 创建自定义认证 Authorizer createAuthorizer 删除自定义认证 Authorizer deleteAuthorizer 修改自定义认证 Authorizer updateAuthorizer

CTS支持的ROMA Connect操作 表1 CTS支持的ROMA Connect操作 操作名称 资源类型 事件名称 创建实例 instance createRomaInstance 创建实例的结果 instance createRomaInstanceResult 删除实例 instance deleteRomaInstance 删除实例的结果 instance deleteRomaInstanceResult 修改实例 instance updateRomaInstance 修改实例名称 instance updateRomaInstanceName 修改实例描述 instance updateRomaInstanceDesc 修改实例安全组 instance updateRomaInstanceSecurityGroup 修改实例维护时间窗 instance updateRomaInstanceMaintainTime 修改实例的弹性公网ip instance updateRomaInstanceEip 清除创建失败的实例 instance cleanFailedRomaInstance

CTS支持的ROMA FDI操作 表2 CTS支持的ROMA FDI操作 操作名称 资源类型 事件名称 创建任务 task createTask 编辑任务 task updateTask 删除任务 task deleteTask 启动/停止任务 task operateTask 手工启动/手工停止任务 task handleTask 制定调度计划 task addDispatch 编辑调度计划 task updateDispatch 接入数据源 dataSource createDatasource 编辑数据源 dataSource updateDatasource 删除数据源 dataSource deleteDatasource 指定SQL语句查询插件数据源的表字段信息 column checkSql

功能简介 应用业务模型ABM是ROMA Connect的模型集成组件，ABM为客户提供统一的业务模型管理平台，可以提供通用的业务/技术模型定义管理，业务/技术模型对应元数据的自动/手动采集，提供模型查询、维护、业务与技术模型关联、数据关联分析等功能，同时提供数据访问管控、开放共享等能力，使用ROMA Connect进行模型集成，有如下优势： 支持模型采集 系统预置常用数据源的采集适配器，针对数据采集提供了数据源管理、采集任务管理功能，实现自动模型采集。 支持模型管理 遵循MOF规范提供业务/技术元模型管理，支持对采集的模型进行搜索配置、业务与技术数据关联、定义业务流程模板等功能。 支持模型访问 提供模型查询搜索功能，便于用于快速浏览模型数据；针对第三方应用开放模型查询搜索能力，实现模型共享。

脚本模式 可通过编辑JavaScript脚本来配置源端数据（sourceObj指源表的字段集合对象）和目标端数据（targetObj指目标表的字段集合对象）的Mapping映射关系信息，增强复杂对象的Mapping处理能力。 脚本映射样例： 样例模板。 function excute(sourceObj){ //请在此处编写脚本内容， 注意大小写敏感。 //定义目标端数据对象 targetObj = {}; //支持普通的加减乘除运算 targetObj.a= (sourceObj.id * 3 + 1) % 5; //支持js的Math函数 targetObj.b= Math.sqrt(100); //支持类型转换 targetObj.c = Number("3.14"); //支持调用系统的时间函数 targetObj.date = new Date().toLocaleString(); //支持正则表达式 targetObj.fdi = sourceObj.name.replace(/world/i,"fdi"); //支持json转换 var json = JSON.parse(sourceObj.infoJson); targetObj.address = json.address; targetObj.age = json.age; targetObj.sex = json.other.sex; targetObj.hobby = json.other.hobby; //支持条件语句 if(targetObj.hobby == "rap"){ targetObj.ikun = true; }else{ targetObj.ikun = false; } return targetObj; } 仅字段映射。 function excute(sourceObject) {//sourceObject即源端传送的数据对象 //请在此处编写脚本内容； var targetObject = {}; targetObject.mqs_id = sourceObject.id;//映射源端数据表中的id字段至目标端字段mqs_id targetObject.mqs_name = sourceObject.name; targetObject.mqs_date = sourceObject.date; targetObject.mqs_date = sourceObject['customized-outdutydate'];//属性带中划线的字段，需要使用中括号进行引用 return targetObject; //targetObject即返回给目标端的数据对象 } 目标端数据源类型为API。 API数据类型的目标端需要分别使用三个对象进行传递，对象包含params、headers和body。 function excute(sourceObj) { print("execute js"); print(sourceObj); var targetObj = {}; targetObj.params = {}; targetObj.params.id = sourceObj.uid targetObj.headers = {}; targetObj.headers['X-HW-ID'] = "应用ID"; targetObj.headers['X-HW-APPKEY'] = "应用密钥"; targetObj.body = {}; return obj; } 如果转换的数据存在时间类型。则JS脚本中需参考以下加黑字段修改： 编排模式下，目标端数据源类型为API，且使用JS脚本进行数据转换时，会自动先将源端类型为Date的数据类型转换为yyyy-MM-dd HH:mm:ss的字符串类型。例如，源端时间数据为19:55:20，通过JS脚本转换后会变为1970-01-01 19:55:20，而不是预期的19:55:20。其中1970-01-01为系统统一添加的默认值。 如果要目标端要获得指定格式的数据，需要参考下述示例在JS脚本中对时间数据进行转换。 function excute(sourceObj) {/** * 自定义时间格式函数 * @param {format} 时间显示格式 */Date.prototype.format = function (format) { var date = { "M+": this.getMonth() + 1, "d+": this.getDate(), "h+": this.getHours(), "m+": this.getMinutes(), "s+": this.getSeconds(), "q+": Math.floor((this.getMonth() + 3) / 3), "S": this.getMilliseconds() }; if (/(y+)/i.test(format)) { format = format.replace(RegExp.$1, (this.getFullYear() + '').substr(4 - RegExp.$1.length)); } for (var k in date) { if (new RegExp("(" + k + ")").test(format)) { format = format.replace(RegExp.$1, RegExp.$1.length == 1 ? date[k] : ("00" + date[k]).substr(("" + date[k]).length)); } } return format;}; print("execute js"); print(sourceObj); var targetObj = {}; targetObj.params = {}; targetObj.params.id = sourceObj.uid//对时间格式的数据进行转换时，调用上述自定义的函数进行处理， 抽取时、分、秒部分的数据给目标字段。//其中下述代码中的HH:mm:ss为时分秒时间的显示格式。如果写为hhmmss，则返回给目标字段的格式不带冒号。 targetObj.params.time = (new Date(sourceObj.time)).format("hh:mm:ss"); targetObj.headers = {}; targetObj.headers['X-HW-ID'] = "应用ID"; targetObj.headers['X-HW-APPKEY'] = "应用密钥"; targetObj.body = {}; return obj; } 数据库字段涉及多层json解析。 如果源端数据对象包含的字段涉及多层json对象嵌套，则需要对每一个解析出来的字段使用“[]”引用。 例如如下脚本表示root字段包含id、name、double等多层对象嵌套，则每一个解析的字段需要单独引用。 function excute(sourceObject) { //请在此处编写脚本内容； var targetObject = {}; targetObject.mqs_id = sourceObject["root.id"]; targetObject.mqs_name = sourceObject["root.name"]; targetObject.mqs_double = sourceObject["root.double"]; targetObject.mqs_date = sourceObject["root.date"]; targetObject.mqs_boolean = sourceObject["root.boolean"]; targetObject.mqs_timestamp = sourceObject["root.timestamp"]; targetObject.mqs_time = sourceObject["root.time"]; targetObject.mqs_long = sourceObject["root.long"]; return targetObject; }

映射模式 自动配置Mapping 若源端信息与目标端信息中都定义了元数据，可使用“自动Mapping”方式配置Mapping信息。 单击“自动Mapping”，源端和目标端数据字段间的映射规则自动建立。 源端或目标端数据类型为API时，数据字段不支持自动Mapping，需要手动配置Mapping。 图1 自动Mapping 手动配置Mapping 如果两端的数据表字段不一致，可单击下方的“添加mapping映射”，配置源端数据字段到目标端数据字段的映射关系。 用户可以手动添加源端数据字段与目标端数据字段的映射规则，该方式适用于所有数据类型的集成场景。可以通过键值对输入或文本框输入两种方式配置Mapping映射规则。

维度 Key Value instance_id ROMA Connect实例 fdi 数据集成 apic 服务集成 kafka_instance_id 消息集成实例 kafka_broker 消息集成Broker节点 kafka_rest 消息集成Rest节点 kafka_topics 消息集成队列 kafka_partitions 消息集成分区 kafka_groups-partitions 消息集成分区的消费组 kafka_groups_topics 消息集成队列的消费组 kafka_groups 消息集成消费组 link 设备集成

MQS支持的监控指标 表3 MQS支持的监控指标 分类 监控指标 说明 实例 分区数 统计实例中已经使用的分区数量。 主题数 统计实例中已经创建的主题数量。 堆积消息数 统计实例中所有消费组中总堆积消息数。 节点 节点数据容量 统计节点当前的消息数据大小。 消息生产速率 统计每秒生产的消息数量。 消费流量 统计每秒消费的字节数。 生产流量 统计每秒生产的字节数。 公网入流量 统计Broker节点每秒公网访问流入流量。 公网出流量 统计Broker节点每秒公网访问流出流量。 生产请求平均处理时长 统计Broker节点处理生产请求平均时长。 消费请求平均处理时长 统计Broker节点处理消费请求平均时长。 节点存活状态 统计MQS节点是否存活。 连接数 统计MQS节点当前所有TCP连接数量。 CPU使用率 统计MQS节点虚拟机的CPU使用率。 磁盘平均读操作耗时 统计磁盘在测量周期内平均每个读IO的操作时长。 磁盘平均写操作耗时 统计磁盘在测量周期内平均每个写IO的操作时长。 网络入流量 统计MQS节点每秒网络访问流入流量。 网络出流量 统计MQS节点每秒网络访问流出流量。 CPU核均负载 统计MQS节点虚拟机CPU每个核的平均负载。 磁盘容量使用率 统计MQS节点虚拟机的磁盘容量使用率。 内存使用率 统计MQS节点虚拟机的内存使用率。 Kafka进程JVM堆内存使用率 统计MQS节点Kafka进程JVM中的堆内存使用率。 生产成功次数 统计Rest节点每分钟生产请求成功次数。 生产失败次数 统计Rest节点每分钟生产请求失败次数。 生产请求时延 统计Rest节点生产请求平均时延。 生产消息数 统计Rest节点每分钟生产消息数。 生产流量 统计Rest每秒钟生产流量。 消费成功次数 统计Rest节点每分钟消费请求成功次数。 消费失败次数 统计Rest节点每分钟消费请求失败次数。 消费请求时延 统计Rest节点消费请求平均时延。 消费消息数 统计Rest节点每分钟消费消息数。 消费流量 统计Rest每秒钟消费流量。 提交请求成功次数 统计Rest节点每分钟提交请求成功次数。 提交请求失败次数 统计Rest节点每分钟提交请求失败次数。 提交请求时延 统计Rest节点提交请求平均时延。 提交消息数 统计Rest节点每分钟提交消息数。 提交请求流量 统计Rest每秒钟提交请求流量。 队列 队列数据容量 统计队列当前的消息数据大小。 消息生产速率 统计每秒生产的消息数量。 消费流量 统计每秒消费的字节数。 生产流量 统计每秒生产的字节数。 队列消息总数 统计队列当前的消息总数。 生产消息数 统计目前生产的消息总数。 分区消息数 统计分区中当前的消息个数。 消费组 分区已消费消息数 统计当前消费组已经消费的消息个数。 分区可消费消息数 统计消费组可消费的消息个数。 队列可消费消息数 统计消费组指定队列可以消费的消息个数。 队列已消费消息数 统计消费组指定队列当前已经消费的消息数。 消费组可消费消息数 统计消费组剩余可以消费的消息个数。 消费组已消费消息数 统计消费组当前已经消费的消息数。

APIC支持的监控指标 表2 APIC支持的监控指标 分类 监控指标 说明 实例 Data API调用次数 统计Data API调用次数。 Data API最大延迟毫秒数 统计Data API最大响应延时时间。 Data API平均延迟毫秒数 统计Data API平均响应延时时间。 Data API错误次数 统计Data API错误次数。 Function API调用次数 统计Function API调用次数。 Function API最大延迟毫秒数 统计Function API最大响应延时时间。 Function API平均延迟毫秒数 统计Function API平均响应延时时间。 Function API错误次数 统计Function API错误次数。 接口调用次数 统计测量api接口被调用的次数。 4xx 异常次数 统计测量api接口返回4xx错误的次数。 5xx 异常次数 统计测量api接口返回5xx错误的次数。 被流控的调用次数 统计测量api被流控的调用次数。 平均延迟毫秒数 统计测量api接口平均响应延时时间。 最大延迟毫秒数 统计测量api接口最大响应延时时间。 API 接口调用次数 统计测量api接口调用次数。 2xx调用次数 统计测量api接口调用2xx的次数。 4xx异常次数 统计测量api接口返回4xx错误的次数。 5xx异常次数 统计测量api接口返回5xx错误的次数。 异常次数 统计测量api接口总的错误次数。 平均延迟毫秒数 统计测量api接口平均响应延时时间。 最大延迟毫秒数 统计测量api接口最大响应延时时间。 流入流量 统计测量api接口请求流量。 流出流量 统计测量api接口返回流量。

操作步骤 在实例控制台的“实例信息”页面选择“数据字典”页签。 单击“创建字典”。 在创建字典弹窗中配置数据字典相关信息，完成后单击“确认”。 表1 数据字典配置 参数 配置说明 字典编码 填写字典类唯一标识。 字典名称 填写字典类名称。 扩展字段1 作为字典类默认值，预留字段，可不填。 扩展字段2 描述 填写数据字典的描述信息。 数据字典创建完成后，单击字典名称前的“”展开字典项列表。 单击“创建字典项”。 在创建字典项弹窗中配置字典项相关信息，完成后单击“确认”。 表2 字典项配置 参数 配置说明 项编码 填写字典项唯一标识。 项名称 填写字典项名称。 扩展字段1 作为字典项默认值，预留字段，可不填。 扩展字段2 描述 填写字典项的描述信息。

订阅资产 在“资产市场”页面中查找需要使用的资产。 您可以通过筛选“行业”和“资产类型”来查找您需要的资产，也可以通过搜索资产名称、关键词、所属组织来查找您需要的资产。 单击某个资产，可以查看资产的详情信息。 将光标移动到选定的资产上，然后单击“订阅”。 图1 订阅资产 在订阅弹窗中单击“确定”，完成资产的订阅。 图2 订阅弹窗 订阅资产成功后，您可以在“我的订阅”页面中查看已订阅的资产，并可以进行后续的部署资产操作。 图3 已订阅资产

部署资产 在资产市场中，您可以对订阅的资产或自己发布的资产进行部署操作。 部署订阅的资产：单击页面上方的“我的订阅”，在要部署的资产上单击“部署资产”，进入部署资产页面。 部署自己发布的资产：单击页面上方的“我的资产”，在要部署的资产上单击“部署资产”，进入部署资产页面。 配置资产部署相关信息，然后单击“提交”，开始部署资产。 区域：选择ROMA Connect服务所在的区域，即资产要部署到哪个区域的ROMA Connect服务中。 ROMA实例：仅当部署“业务流”和“集成应用”类型的资产时需要选择ROMA Connect实例，即资产要部署到哪个ROMA Connect实例中。 图1 部署资产 页面中显示部署的进度，单击“返回我的订阅”回到“我的订阅”页面。 找到部署的资产，单击资产左下角的“部署记录”，可以查看资产的部署记录。 当部署记录的状态为“部署成功”，则资产成功部署到您的ROMA Connect服务中。 图2 资产部署记录 登录ROMA Connect控制台，在资产管理页面中查看已部署的连接器，或者进入资产部署的实例中，查看部署的FDI集成任务或集成应用资源。

发布资产 在资产市场中，单击右上角的“发布资产”，进入发布资产页面。 根据页面向导配置资产相关信息。 填写资产基本信息，然后单击“下一步”。 图1 资产基本信息 表1 资产基本信息 参数 配置说明 资产名称 资产的名称，自定义，建议您按照一定的命名规则填写资产名称，方便您快速识别和查找。 简介 资产的描述介绍信息。 行业 选择该资产所应用的行业，可选择“智慧园区”、“工业制造”或“其他”。 标签 为资产添加自定义的标签，可用于在资产市场进行资产搜索。 资产图片 上传资产的图片，仅支持上传PNG、JPG、SVG格式图片，且图片大小不超过5MB。 所属组织 填写资产所归属的组织，即资产的发布者名称。 配置要发布的资产信息，然后单击“下一步”。 资产发布后，资产配置信息将无法修改，请确保资产配置信息的正确性。 图2 资产配置信息 表2 资产配置信息 参数 配置说明 版本 填写资产的版本，根据界面的填写要求自定义。 资产类型 选择要发布的资产类型，可选择“业务流”（即FDI的数据集成任务）、“集成应用”（即集成应用及集成应用下的资源）或“连接器”。 区域 选择要发布资产的ROMA Connect服务所在区域。 ROMA实例 当“资产类型”选择“业务流”或“集成应用”时需要选择ROMA Connect实例，选择数据集成任务或集成应用所在的ROMA Connect实例。 数据集成任务/集成应用/连接器 根据选择的资产类型，选择要发布为资产的数据集成任务、集成应用或连接器。 编写资产文档，包括资产的简介、规格、典型案例和使用指导文档，然后单击“下一步”。 您可以单击右下角的“模板”，使用系统提供的默认文档模板。也可以拖动添加“文本”、“图片”和“文件”等组件自定义文档结构。 请确保资产文档信息的正确性和完整性，否则会影响资产上架的审批。 图3 资产文档 确认前面配置的资产基本信息、资产配置和资产文档内容正确无误，单击“提交”进行资产的发布。 单击“返回控制台”回到资产市场页面，然后单击页面上方的“我的资产”，在我的资产列表中查看刚发布的资产。 若资产图片下方的状态为“已发布”，则资产发布成功。您可以对发布成功的资产进行后续的上架、部署和更新操作。 图4 已发布资产

上架资产 在资产市场中，单击页面上方的“我的资产”，在要上架的资产上单击“上架”。 在上架确认弹窗中单击“确定”，申请上架资产。 图1 上架确认 提交上架申请后，资产图片下方的状态为“上架审核中”。 同时您可以单击页面上方的“权限管理”，在“我的上架申请”中可以查看上架申请的审核情况。 图2 上架申请 待资产市场管理员进行资产的上架审批。 审批通过： 在“我的资产”页面中，资产的上架状态为“已上架”，并且其他用户可以在“资产市场”页面中查看和订阅该资产。 图3 上架审批通过 审批不通过： 在“权限管理”页面查看上架申请的驳回理由，并根据驳回理由修改资产信息，然后重新提交资产上架申请。 图4 上架审批不通过

概述 ROMA Site是ROMA Connect的边缘形态，与ROMA Connect具有相同的数据集成、服务集成和消息集成能力。ROMA Site可部署于用户IDC和第三方公有云，与云端ROMA Connect反向互联，不破坏企业的安全边界。 ROMA Site实例是一个独立的资源空间，所有的操作都是在实例内进行，不同实例间的资源相互隔离。您可以根据业务需要使用一个或多个实例。 若需要删除实例，会同步删除实例中所创建的所有资源数据，请谨慎操作。建议在删除实例前导出实例的资产数据进行备份。 ROMA Site实例与华为云断连会导致实例状态异常、告警无法上报与部分功能不可用等问题。

业务对接适配 与ROMA Connect对接的业务应用或设备，需要修改如下对接配置。 分类 业务场景 配置数据 服务集成 调用API API的调用地址（仅资产迁移场景需要）。 API的认证信息，包括集成应用/客户端的Key和Secret、AppCode、AK/SK。 后端服务签名密钥的Key和Secret。 消息集成 发送和接收消息 Topic的连接地址（仅资产迁移场景需要）。 启用SASL认证时使用的认证Key和Secret。 设备集成 设备上报消息和下发命令 设备的连接地址（仅资产迁移场景需要）。 设备的接入认证信息，包括客户端ID、用户名和密码。

操作步骤 登录ROMA Connect控制台，在“实例”页面单击实例上的“查看控制台”，进入实例控制台。 修改安全组配置，仅资产迁移场景需要，否则跳过此步。 在“实例信息”页面的“基本信息”页签下，单击安全组的名称。 在安全组配置页面中，根据准备工作中获取的源实例安全组信息和新实例的实际组网需求，修改安全组的规则配置。 ROMA Connect实例的安全组规则要求请参见表2。 修改实例配置参数，仅资产迁移场景需要，否则跳过此步。 在“实例信息”页面的“配置参数”页签下，根据准备工作中获取的源实例配置参数信息，修改配置参数。 添加数据字典配置。 在“实例信息”页面的“数据字典”页签下，根据准备工作中获取的源实例数据字典信息，添加数据字典配置。 具体创建字典的操作请参见创建数据字典。

准备工作 在进行集成资产的恢复或迁移前，您需要做如下准备： 准备集成资产包。 获取用于导入的集成资产包。 获取资产包所属源实例的配置信息，仅资产迁移场景需要。 主要包括实例的安全组配置、实例配置参数和数据字典信息。 获取周边系统的对接信息，仅资产迁移场景需要。 系统 数据项 用途 数据源 数据源的访问IP、用户名和密码。 用于ROMA Connect对接数据源。 业务应用 业务应用的网段信息。 用于打通ROMA Connect到业务应用的网络。 父主题： 恢复/迁移集成资产

操作步骤 登录ROMA Connect控制台，在左侧的导航栏选择“资产管理”。 在资产管理页面的“连接器”页签下，单击连接器上的“发布”。 在发布连接器弹窗中配置相关发布参数，完成后单击“确定” 表1 连接器配置 参数 配置说明 连接器实例名称 填写连接器实例的名称，根据规划自定义。建议您按照一定的命名规则填写连接器实例名称，方便您快速识别和查找。 连接地址 已部署连接器的访问地址。 认证方式 选择访问连接器实例所使用的安全认证方式，为简单起见，此处选择“无”。 无：不对接入请求进行认证。 AppKey：使用AppKey和AppSecret进行接入认证。 AppKey 填写用于连接器接入认证的AppKey，自定义。 AppSecret 填写用于连接器接入认证的AppSecret，自定义。 仅“编辑”状态的连接器可编辑，“发布”状态的连接器无法进行编辑。

功能简介 消息集成MQS是ROMA Connect的消息集成组件，使用统一的消息接入机制，提供跨网络访问的安全、标准化消息通道。使用ROMA Connect进行消息集成，有如下优势： 支持原生Kafka特性 兼容社区版Kafka的API，具备原生Kafka的所有消息处理特性。 支持安全的消息传输 独有的安全加固体系，提供业务操作云端审计，消息存储加密等有效安全措施。通过SASL认证，安全组等加强网络访问控制。 支持消息数据高可靠 支持消息持久化，多副本存储机制。副本间消息同步、异步复制，数据同步或异步落盘多种方式供您自由选择。

使用流程 使用ROMA Connect进行消息集成的流程如下图所示。 图1 业务使用流程 已创建实例和集成应用。 创建Topic 创建用于存储消息的Topic，供消息生产方发布消息和供消息消费方订阅消息。 配置Topic授权（可选） 若ROMA Connect实例开启了MQS的SASL_SSL，客户端向Topic发布和订阅消息时，需要使用授权集成应用的Key和Secret进行安全认证。 连接Topic 在系统中集成开源的Kafka客户端，然后通过客户端提供的命令行向Topic生产和消费消息。

前提条件 导入Topic前，请确保Topic所属的集成应用已创建，否则请提前创建集成应用。 导入Topic前，请检查导入Topic的实例中是否存在重名Topic，若存在重名Topic，会导致导入Topic失败。 导入Topic前，请确保Topic的配额满足需求。 若Topic的描述信息中有换行符时，导出Topic的csv文件中会将换行符转义成“\n”。若使用该csv文件导入Topic，在导入Topic后，需在控制台上手动修改Topic的描述信息，把转义字符“\n”修改成换行符。 导入Topic时，导入的文件中最多包含100个Topic，否则将导入Topic失败。 请勿使用Excel编辑导出的csv文件，否则会打乱csv文件的内容格式，导致导入失败。若需要编辑导出的文件后导入，请导出xlsx或xls格式进行编辑。

常用语法 table_references: table_reference [, table_reference] ... table_reference: table_factor | join_table table_factor: tbl_name [[AS] alias]| table_subquery [AS] alias| ( table_references ) join_table: table_reference [INNER | CROSS] JOIN table_factor [join_condition]| table_reference {LEFT|RIGHT} [OUTER] JOIN table_reference join_condition| table_reference [{LEFT|RIGHT} [OUTER]] JOIN table_factor join_condition: ON conditional_expr| USING (column_list)

使用示例 增加字段 # 向表t2中增加字段x，类型为int，Online DDL 算法为inplace，锁为NONEALTER TABLE t2 ADD COLUMN x INT, ALGORITHM=INPLACE, LOCK=NONE; 修改字段 # 修改表t2的字段x，修改字段类型为varchar(255)，Online DDL 算法为copy，锁为sharedALTER TABLE t2 MODIFY x VARCHAR(255), ALGORITHM=COPY, LOCK=SHARED; 修改编码 # 修改表t2编码为utf8，排序算法为utf8_bin，Online DDL 算法为copy，锁为sharedALTER TABLE t2 CHARACTER SET utf8 COLLATE utf8_bin, ALGORITHM=COPY, LOCK=SHARED;

语法说明 暂不支持以空字符串作为别名; 不支持select ... group by ... with rollup； 暂不支持 STRAIGHT_JOIN 和 NATURAL JOIN； select for update 仅支持简单查询，不支持 join、group by、order by、limit； 对于 UNION 中的每个 SELECT, DDM 暂不支持使用多个同名的列，如下： # 如下 SQL 的 SELECT 中存在重复的列名，暂不支持SELECT id, id, name FROM t1 UNION SELECT pk, pk, name FROM t2。

The Subquery as Scalar Operand 示例 SELECT (SELECT id FROM test1 where id=1); SELECT (SELECT id FROM test2 where id=1)FROM test1; SELECT UPPER((SELECT name FROM test1 limit 1)) FROM test2;