检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
通过函数API开放数据 前提条件 确保业务系统所在网络与ROMA Connect的网络互通。 若通过公网互通,ROMA Connect实例需绑定弹性IP。 确保业务系统的数据库为ROMA Connect支持的数据源类型。 函数API支持的数据源请参见服务集成支持的数据源。 准备一个可用的独立域名,用于作为API的访问域名。
华为云事件源 参数 说明 事件订阅名称 在事件网格创建的事件订阅名称。 区域 事件网格服务所在区域。 项目 事件网格服务所在项目。 通道 事件通道,存储接收到的事件消息,并根据事件规则将事件消息路由到事件目标。 事件源 华为云服务事件源。 事件类型 华为云服务的事件类型,用于生成过滤规则。
导入产品前,请确保产品的配额满足需求。 导入文件格式为csv,并需要使用UTF-8 BOM编码。 在使用导出的文件导入产品时: 如果要新增产品,则需要另外新建导入文件,并在新建的文件中添加新的产品信息。 产品导入文件中表头的名称和顺序固定不能更改,表头名称请参考产品导入文件说明。 确认导入文件是否从老版本实例
7版本,根据实际情况选择。 消息集成(MQS)容量阈值策略 实例中MQS消息存储达到容量阈值时(存储空间的95%)的处理策略,请根据您的业务需要选择。 生产受限:拒绝消息生产请求,直到有消息到达老化时间被删除,腾出存储空间后(剩余存储空间大于5%),才能接收新的消息生产请求。此策略适用于消息消费
- 500 password_type 否 Integer 0-无密码 1-明文密码 最小值:0 最大值:1 file_export_type 否 String 导出文件类型xls和csv。 缺省值:csv 最小长度:1 最大长度:10 请求参数 表3 请求Header参数 参数
curl_global_cleanup(); return 0; } 运行make命令编译,得到可执行文件main,执行main文件,查看结果。 父主题: API调用认证开发(APP认证)
依赖库 licenses\license-crypto-js 第三方库license文件 licenses\license-node 创建工程 打开IntelliJ IDEA,选择菜单“File > New > Project”。 弹出“New Project”对话框。选择“Static
mrshive: mrshive数据源类型(tag:Site_hybrid) type 否 String 脚本类型 SQL:SQL语句 SP:存储过程 object_name 是 String 返回对象。 最小长度:1 最大长度:32 content 是 String API脚本内容
在“Project Structure”对话框中选择“Libraries > + >Java”,界面弹出“Select Library Files”对话框。 选择SDK所在目录中“\libs”目录下所有以“jar”结尾的文件,单击“ok”。 图8 选择jar文件 选择步骤3已创建的工程,单击“ok”。
的首选数据库。 MySQL默认端口为3306,但是管理员可以根据需要将其更改为其他端口。MySQL支持多种存储引擎,包括InnoDB、MyISAM、MEMORY等,每个存储引擎都有其自己的优缺点,可以根据需要进行选择。 创建MySQL连接 登录新版ROMA Connect控制台。
其中bucket为和当前项目处于同一区域的OBS桶名称,object为对象全路径名。例如:obs://hwbucket/hwinfo/hw.png,其中obs://表示OBS存储,hwbucket为桶名,hwinfo/hw.png为对象全路径名。 image_watermark 提取出来的水印图片存放地址,格式要求同src_file。
Topic主题 日志要推送的目标Kafka Topic名称。 Key 填写消息的Key值,表示消息存储在Kafka的指定分区,可以当成有序消息队列使用。如果Key为空,则消息分布式存储在不同的消息分区。 失败重试配置 日志推送到Kafka失败后的重试配置。 重试次数:失败后的重试次数,范围为0-5次。
源端字段a1映射到目标端字段b1,源端字段a2映射到目标端字段b2。 完成Mapping信息配置后,若需要配置异常数据存储、任务完成后执行,请前往配置异常数据存储(可选)、配置任务完成后执行(可选);否则可直接单击“保存”,完成数据集成任务的配置。 MRS Hive分区字段映射配置说明
上传配置文件 单击“上传文件”,上传MRS Kafka配置文件。配置文件获取请参考获取MRS Kafka配置文件。 获取MRS Kafka配置文件 获取“krb5.conf”和“user.keytab”文件。 参考下载用户认证文件,在MRS Manager下载用户认证文件,解压后得到“krb5
Connect可以将这些数据以文本文件的形式存储在OBS中。 表3 异常数据存储信息 参数 配置说明 源数据类型 当前仅支持选择“OBS”。 应用 选择对应的应用。 数据源名称 选择已配置的OBS数据源。 Path 填写异常数据要存储到OBS数据源的对象名。Path的值不能以斜杠(/)结尾。
API表单参数:表示通过API表单的方式来提交目标文件信息。 文本输入:表示直接通过文件传输服务器(如:FTP)方式来提交目标文件信息。 API表单参数 仅当“输入方式”选择“API表单参数”时需要配置。 获取上一节点传递的文件信息,填写API请求体表单中上传文件使用的参数名称,可以通过变量的方式引用前序节点中的数据,请参考引用变量。
上传认证文件 单击“上传文件”,上传FI HBase配置文件。配置文件获取请参考获取FI HBase配置文件。 获取FI HBase配置文件: 参考下载用户认证文件,在FI Manager下载用户认证文件,解压后得到“krb5.conf”和 “user.keytab”文件,即FI
导入 如果本地已存在文件,可以直接在“产品”页签单击“导入”,即可导入包含产品信息的文件。 文件模板获取方式:在界面创建一个产品,选中该产品,单击导出键导出csv文件,根据需要导入的产品修改csv文件的内容。 导出/导出所有产品 导出单个或多个产品信息的csv文件。 如果导出单个或
字符集:中文、英文字母、数字、下划线和空格。 parent_code String 父字典编码,为空时代表自身就是最顶级字典。 type String 字典类型。 system: 代表系统内置字典,用户可编辑但不可删除。 user: 代表用户创建字典。 create_time String 创建时间。 update_time
dameng数据源类型(tag:hcs) opengauss : opengauss数据源类型(tag:hcs) type String 脚本类型 SQL:sql语句 SP:存储过程 object_name String 返回对象。 最小长度:1 最大长度:32 content String API脚本内容 请对脚本进行base64编码