数据湖探索 DLI-pyspark样例代码:通过SQL API 访问数据源
时间：2025-04-22 17:27:19
下载数据湖探索 DLI用户手册完整版
复制链接到剪贴板
分享文章到微博
分享文章到朋友圈
通过SQL API 访问数据源
- 创建 DLI 跨源访问 dws 的关联表。
1 2 3 4 5 6 7
sparkSession.sql( "CREATE TABLE IF NOT EXISTS dli_to_dws USING JDBC OPTIONS ( 'url'='jdbc:postgresql://to-dws-1174404951-W8W4cW8I.datasource.com:8000/postgres',\ 'dbtable'='customer',\ 'user'='dbadmin',\ 'password'='######',\ 'driver'='org.postgresql.Driver')")
- 插入数据
1sparkSession.sql("insert into dli_to_dws values(2,'John',24)")
- 查询数据
1jdbcDF = sparkSession.sql("select * from dli_to_dws").show()
- 操作结果
support.huaweicloud.com/devg-dli/dli_09_0087.html
