导语:恭喜 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.url=jdbc:mysql://${ip} :${port}/${db_name} -runtimeMap
wds.linkis.jdbc.driver=com.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 参数:
Maplabels=newHashMap();
labels.put(LabelKeyConstant.ENGINE_TYPE_KEY,"jdbc-4");//requiredengineTypeLabel
labels.put(LabelKeyConstant.USER_CREATOR_TYPE_KEY,"hadoop-IDE");//requiredexecuteuserandcreator
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":"showdatabases",
"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 强大的连接、重用、编排、扩展和治理能力,通过应用层和引擎层的解耦,以标准化可重用的方式解决了扩展难、应用孤岛、重复造轮子等复杂的连接问题。简化了复杂的网络调用关系,从而降低了整体的复杂度,也节省了开发和维护成本。
服务器托管,北京服务器托管,服务器租用 http://www.fwqtg.net
本文首发自公粽hao「林行学长」,欢迎来撩,免费领取20个求职工具资源包。 了解校招、分享校招知识的学长来了! 春招日渐结束,暑期实习也随之落下帷幕。 肯定有 24 届的小伙伴心里有些慌张:没有实习,裸着简历上秋招吗? 当然不是同学们不想实习,实在是暑期实习也…