成都网站建设scyiyou,昆明做网站多少钱,如何用织梦建网站,天元建设集团有限公司资质计算中间件 Apache Linkis 构建了一个计算中间件层#xff0c;以实现上层应用程序和底层数据引擎之间的连接、治理和编排。目前#xff0c;已经支持通过数据源的功能#xff0c;实现用户通过Linkis 对接并使用 OceanBase数据库。 本文详细阐述了在 Apache Linkis v1.3.2中以实现上层应用程序和底层数据引擎之间的连接、治理和编排。目前已经支持通过数据源的功能实现用户通过Linkis 对接并使用 OceanBase数据库。 本文详细阐述了在 Apache Linkis v1.3.2中如何集成OceanBase数据库。鉴于OceanBase数据库兼容MySQL 5.7/8.0的众多功能与语法特性用户在实际操作中可将OceanBase 当做 MySQL来类似应用。
1、 准备工作 1.1 环境安装 安装和部署OceanBase数据库请参阅
部署文档https://www.oceanbase.com/docs/common-oceanbase-database-cn-10000000001687861一文讲透如何部署OceanBase社区版https://open.oceanbase.com/blog/2235967744 1.2 环境验证 你可以使用MySQL命令来验证OceanBase数据库的安装情况。 mysql -h${ip} -P${port} -u${username} -p${password} -D${db_name} 连接成功如下图所示 2. Linkis提交执行OceanBase数据库任务 2.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.2通过Linkis Java SDK提交任务 Linkis提供Java和Scala的SDK用于向Linkis服务器提交任务。有关详细信息请参阅JAVA SDK Manual对于OceanBase任务用户只需要在Demo中修改EngineConnType和CodeType参数 MapString, Object labels new HashMapString, Object();
labels.put (LabelKeyConstant.ENGINE_TYPE_KEY, jdbc-4); // required engineType Label
labels.put(LabelKeyConstant.USER_CREATOR_TYPE_KEY, hadoop-IDE);// required execute user and creator
labels.put(LabelKeyConstant.CODE_TYPE_KEY, jdbc); // required codeType 2.3多数据源支持 路径登录管理平台--数据源管理 第一步创建新的数据源。 第二步连接测试。 单击测试连接按钮进行测试 第三步发布数据源。 第四步通过指定数据源名称提交OceanBase任务。
请求URLhttp://${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 强大的连接、重用、编排、扩展和治理能力通过应用层和引擎层的解耦以标准化可重用的方式解决了扩展难、应用孤岛、重复造轮子等复杂的连接问题。简化了复杂的网络调用关系从而降低了整体的复杂度也节省了开发和维护成本。
未来 Linkis计划进一步和OceanBase进行集成包括Linkis ETL功能支持OceanBase完成OceanBase和其他数据源的导入导出等并支持将Linkis的元数据存储到OceanBase。另外期待更多伙伴加入OceanBase生态共建阵营我们将向合作伙伴分享开源及公有云的商业机会欢迎合作
