淮北网站开发,网站怎样设计网页,十堰专业网站建设,部门网站建设情况总结导语#xff1a;恭喜 OceanBase 生态全景图中又添一员#xff0c;Apache Linkis 构建了一个计算中间件层#xff0c;以促进上层应用程序和底层数据引擎之间的连接、治理和编排。 近日#xff0c;计算中间件 Apache Linkis 在其新版本中通过数据源功能#xff0c;支持用户通…导语恭喜 OceanBase 生态全景图中又添一员Apache Linkis 构建了一个计算中间件层以促进上层应用程序和底层数据引擎之间的连接、治理和编排。 近日计算中间件 Apache Linkis 在其新版本中通过数据源功能支持用户通过 Linkis 去对接使用 OceanBase 数据库。本文主要介绍 Linkis v1.3.2 中 OceanBase 数据库的集成。由于 OceanBase 数据库兼容 MySQL 5.7/8.0 的大部分功能和语法。因此OceanBase 数据库可以当作 MySQL 使用。 准备工作 1. 环境安装 安装和部署 OceanBase 数据库请参阅 部署文档
https://www.oceanbase.com/docs/common-oceanbase-database-cn-10000000001687861 一文讲透如何部署OceanBase社区版
https://open.oceanbase.com/blog/2235967744 2. 环境验证 你可以使用 MySQL 命令来验证 OceanBase 数据库的安装情况。 mysql -h${ip} -P${port} -u${username} -p${password} -D${db_name} 连接成功如下图所示 Linkis 提交执行 OceanBase 数据库任务 1. 通过 linkis-cli 提交 sh ./bin/linkis-cli -engineType jdbc-4 -codeType jdbc -code show tables -submitUser hadoop -proxyUser hadoop -runtimeMap wds.linkis.jdbc.connect.urljdbc:mysql://${ip} :${port}/${db_name} -runtimeMap wds.linkis.jdbc.drivercom.mysql.jdbc.Driver -runtimeMap wds.linkis.jdbc.username${username} -runtimeMap wds.linkis.jdbc.password ${password} 2. 通过 Linkis Java SDK 提交任务 Linkis 提供 Java 和 Scala 的 SDK用于向 Linkis 服务器提交任务。有关详细信息请参阅 JAVA SDK Manual
https://linkis.apache.org/docs/latest/user-guide/sdk-manual 对于 OceanBase 任务用户只需要在 Demo 中修改 EngineConnType 和 CodeType 参数
MapString, Object labels new HashMapString, Object(); labels.put (LabelKeyConstant.ENGINE_TYPE_KEY, jdbc-4); // required engineType Labellabels.put(LabelKeyConstant.USER_CREATOR_TYPE_KEY, hadoop-IDE);// required execute user and creator labels.put(LabelKeyConstant.CODE_TYPE_KEY, jdbc); // required codeType 3. 多数据源支持 路径登录管理平台--数据源管理 第一步创建新的数据源 第二步连接测试
单击测试连接按钮进行测试 第三步发布数据源 第四步通过指定数据源名称提交 OceanBase 任务
请求 URL
http://${gateway_url}:${port}/api/rest_j/v1/entrance/submit
方法POST
请求参数
{ executionContent: { code: show databases, runType: jdbc }, params: { variable: {}, configuration: { startup: {}, runtime: { wds.linkis.engine.runtime.datasource: ob-test } } }, labels: { engineType: jdbc-4 }}回应{ method: /api/entrance/submit, status: 0, message: OK, data: { taskID: 93, execID: exec_id018017linkis-cg-entrance000830fb1364:9104IDE_hadoop_jdbc_0 }} Linkis 作为中间计算层使各个上层应用以紧耦合的方式直接连接和访问各种底层引擎如 OceanBase、MySQL 等。实现了统一变量等用户资源的互通脚本、UDF、函数和资源文件并通过 REST 标准接口提供数据源和元数据管理服务。 Linkis 强大的连接、重用、编排、扩展和治理能力通过应用层和引擎层的解耦以标准化可重用的方式解决了扩展难、应用孤岛、重复造轮子等复杂的连接问题。简化了复杂的网络调用关系从而降低了整体的复杂度也节省了开发和维护成本。
