DBT Labs使用DB链接访问远程Postgres DB服务器

发布于 2025-02-05 18:44:32 字数 153 浏览 1 评论 0原文

我是DBT的新手。我了解DBT一旦DWH中的原始数据可用，DBT用于转换数据。但是，我试图查看是否有人使用DBT在选择语句中使用db link从远程数据库服务器进行初始选择/导入数据，其中staging数据库服务器和远程数据库服务器都是Postgres数据库。同样，就我而言，数据量并不多。

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

静若繁花 2025-02-12 18:44:32

我能够进行一些测试，看起来这是可行的。
以下是设置：

profiles.yml文件指向目标数据库服务器。
以下是模型targetTable.sql文件中使用的查询。

{{ config(materialized='table') }}

SELECT i.col1,
        i.col2
        FROM dblink('dbname=sourceDBName port=portNo hostaddr=sourceHostName user=userID password=****', 
                                'SELECT 
                                a.col1, 
                                a.col2
                                from 
                                (SELECT 
                                    col1,col2
                                 FROM 
                                    public.tableName) a
                                ') 
                i (col1 integer, col2 varchar(20))

I was able to do some testing and looks like this is doable.
Below was the set-up:

The profiles.yml file was pointing to target DB server.
Below was the query used in the model targetTable.sql file.

{{ config(materialized='table') }}

SELECT i.col1,
        i.col2
        FROM dblink('dbname=sourceDBName port=portNo hostaddr=sourceHostName user=userID password=****', 
                                'SELECT 
                                a.col1, 
                                a.col2
                                from 
                                (SELECT 
                                    col1,col2
                                 FROM 
                                    public.tableName) a
                                ') 
                i (col1 integer, col2 varchar(20))

回复收藏 0 原文

~没有更多了~