連線至 dbt Cloud
dbt (資料組建工具) 是一個開發環境，可讓資料分析師和資料工程師只要撰寫 select 陳述式即可轉換資料。 dbt 負責將這些 select 陳述式轉換成資料表和檢視。 dbt 會將程式碼編譯成原始 SQL，然後在 Azure Databricks 的指定資料庫中執行該程式碼。 dbt 支援共同作業編碼模式和最佳做法，例如：版本控制、文件和模組化。
dbt 不會擷取或載入資料。 dbt 只著重於轉換步驟，使用「載入後轉換」架構。 dbt 假設您在資料庫中已有一份資料複本。
本文著重於 dbt Cloud。 dbt Cloud 具有對排程作業、CI/CD、服務文件、監視和警示，以及整合式開發環境 (IDE)的周全支援。
也可以使用名為 dbt Core 的 dbt 本機版本。 dbt Core 讓您能在本機開發電腦上，使用您選擇的文字編輯器或 IDE 撰寫 dbt 程式碼，然後從命令列執行 dbt。 dbt Core 包含 dbt 命令列介面 (CLI)。 dbt CLI 可免費使用，並且開放原始碼。 如需詳細資訊，請參閱連線至 dbt Core。
由於 dbt Cloud 和 dbt Core 可以使用託管的 git 存放庫 (例如，在 GitHub、GitLab 或 BitBucket 上)，因此，您可以使用 dbt Cloud 建立一個 dbt 專案，然後使其可供 dbt Cloud 和 dbt Core 使用者使用。 如需詳細資訊，請參閱 dbt 網站上的建立 dbt 專案和使用現有的專案。
如需 dbt 的一般概觀，請觀看下列 YouTube 影片 (26 分鐘)。
使用 Partner Connect 連線至 dbt Cloud
本節說明如何使用 Partner Connect 將 Databricks SQL 倉庫連線至 dbt Cloud，然後為 dbt Cloud 授與對資料的讀取存取權。
標準連線與 dbt Cloud 之間的差異
若要使用 Partner Connect 連線至 dbt Cloud，請遵循使用 Partner Connect 連線至資料準備合作夥伴中的步驟。 dbt Cloud 連線在下列方式與標準資料準備和轉換連線不同：
- 除了服務主體和個人存取權杖之外，Partner Connect 還會預設建立一個名為 DBT_CLOUD_ENDPOINT 的 SQL 倉儲 (先前稱為 SQL 端點)。
連線的步驟
若要使用 Partner Connect 連線至 dbt Cloud，請執行下列動作：
連線至 dbt Cloud 之後，您的 dbt Cloud 儀表板隨即出現。 若要探索 dbt Cloud 專案，請在 dbt 標誌旁邊的功能表列中，從第一個下拉式功能表選取您的 dbt 帳戶名稱 (如果未顯示)，然後從第二個下拉式功能表選取 [Databricks Partner Connect 試用版] 專案 (如果未顯示)。
提示
若要檢視專案的設定，請按一下「三條線」或「漢堡」功能表，按一下 [帳戶設定] > [專案]，然後按一下專案的名稱。 若要檢視連線設定，請按一下 [連線] 旁邊的連結。 若要變更任何設定，請按一下 [編輯]。
若要檢視此專案的 Azure Databricks 個人存取權杖資訊，請按一下功能表列上的 [人員] 圖示，按一下 [設定檔] > [認證] > [Databricks Partner Connect 試用版]，然後按一下專案的名稱。 若要進行變更，請按一下 [編輯]。
為 dbt Cloud 授與對資料的讀取存取權的步驟
Partner Connect 僅為 DBT_CLOUD_USER 服務主體授與對預設目錄的「僅供建立」權限。 請在 Azure Databricks 工作區中執行這些步驟，為 DBT_CLOUD_USER 服務主體授與對所選擇資料的讀取存取權。
警告
您可以調整這些步驟，以為 dbt Cloud 授與對工作區內目錄、資料庫和資料表的其他存取權。 但是，作為安全性最佳做法，Databricks 強烈建議僅授與對需要 DBT_CLOUD_USER 服務主體使用的個別資料表的存取權，並且僅授與對這些資料表的讀取存取權。
按一下側邊欄中的
[目錄]。在右上方的下拉式清單中選取 SQL 倉儲 (DBT_CLOUD_ENDPOINT)。
- 在 [目錄總管] 下，選取包含您資料表的資料庫的目錄。
- 選取包含您的資料表的資料庫。
- 選取您的資料表。
提示
如果您沒有看到列出的目錄、資料庫或資料表，請在 [選取目錄]、[選取資料庫] 或 [篩選資料表] 方塊中分別輸入名稱的任何部分，以縮小清單範圍。
按一下 [權限]。
按一下 [授與]。
對於 [鍵入以新增多個使用者或群組]，選取 [DBT_CLOUD_USER]。 這是 Partner Connect 在上一節中為您建立的 Azure Databricks 服務主體。
提示
如果您沒有看到 [DBT_CLOUD_USER]，請在 [鍵入以新增多個使用者或群組] 方塊中開始鍵入
DBT_CLOUD_USER，直到它出現在清單中，然後加以選取。透過選取
SELECT和READ METADATA僅授與讀取存取權。按一下 [確定]。
對要授與 dbt Cloud 讀取存取權的每個額外資料表重複步驟 4-9。
對 dbt Cloud 連線進行疑難排解
如果有人在 dbt Cloud 中刪除了此帳戶的專案，然後您按一下 [dbt] 磚，則會出現一則錯誤訊息，指出找不到該專案。 若要修正此問題，請按一下 [刪除連線]，然後從頭開始執行此程序，以重新建立連線。
手動連線至 dbt Cloud
本節說明如何將 Azure Databricks 工作區中的 Azure Databricks 叢集或 Databricks SQL 倉儲連線至 dbt Cloud。
重要
Databricks 建議連線至 SQL 倉儲。 如果沒有 Databricks SQL 存取權利，或者想要執行 Python 模型，您可以改為連線至叢集。
需求
Azure Databricks 工作區中的叢集或 SQL 倉儲。
叢集或 SQL 倉儲的連線詳細資料，特別是伺服器主機名稱、連接埠和 HTTP 路徑值。
Azure Databricks 個人存取權杖或 Microsoft Entra ID (先前稱為 Azure Active Directory) 權杖。 若要建立個人存取權杖，請執行下列動作：
- 在 Azure Databricks 工作區中，按一下頂端列中的 Azure Databricks 使用者名稱，然後從下拉式清單中選取 [設定]。
- 按一下 [開發人員]。
- 在 [存取權杖] 旁，按一下 [管理]。
- 按一下 產生新權杖。
- (選擇性) 輸入可協助您之後識別此權杖的註解，並變更權杖的預設存留期 90 天。 若要建立沒有存留期的權杖 (不建議)，請將 [存留期 (天)] 方塊留空 (空白)。
- 按一下 產生。
- 將顯示的權杖複製到安全位置，然後選取 [完成]。
注意
請務必將複製的權杖儲存在安全位置。 請勿與其他人共用複製的權杖。 如果您遺失複製的權杖，就無法重新產生完全相同的權杖。 相反地，您必須重複此程序來建立新的權杖。 如果您遺失複製的權杖，或您認為權杖已遭入侵，Databricks 強烈建議您按一下 [存取權杖] 頁面上權杖旁邊的垃圾桶 (撤銷) 圖示，立即從工作區中刪除該權杖。
注意：如果您無法在工作區中建立或使用 PAT，這可能是因為您的工作區系統管理員已停用權杖，或未授與您建立或使用權杖的權限。 請諮詢您的工作區系統管理員或參閱下列主題：
若要將 dbt Cloud 連線至 Unity Catalog 管理的資料，則必須使用 dbt 1.1 版或更新版本。
本文中的步驟會建立一個使用最新 dbt 版本的新環境。 如需有關升級現有環境的 dbt 版本的資訊，請參閱 dbt 文件中的升級至雲端中的最新版 dbt。
步驟 1：註冊 dbt Cloud
移至 dbt Cloud - 註冊，然後輸入您的電子郵件、名稱和公司資訊。 建立密碼，然後按一下 [建立我的帳戶]。
步驟 2：建立 dbt 專案
在此步驟中，您將建立一個 dbt 專案，其中包含一個至 Azure Databricks 叢集或 SQL 倉儲的連線、一個包含原始程式碼的存放庫，以及一個或多個環境 (例如測試和生產環境)。
按一下 [設定] 圖示，然後按一下 [帳戶設定]。
按一下新增專案。
對於 [名稱]，輸入專案的唯一名稱，然後按一下 [繼續]。
對於 [選擇連線]，按一下 [Databricks]，然後按一下 [下一步]。
對於 [名稱]，輸入此連線的唯一名稱。
對於 [選取配接器]，按一下 [Databricks (dbt-databricks)]。
注意
Databricks 建議使用
dbt-databricks，其支援 Unity Catalog，而非dbt-spark。 根據預設，新專案使用dbt-databricks。 若要將現有的專案移轉至dbt-databricks，請參閱 dbt 文件中的從 dbt-spark 移轉至 dbt-databricks。在 [設定] 下，對於 [伺服器主機名稱]，輸入需求中的伺服器主機名稱值。
對於 [HTTP 路徑]，輸入需求中的 [HTTP 路徑] 值。
如果您的工作區已啟用 Unity Catalog，請在 [選用設定] 下，輸入供 dbt Cloud 使用的目錄名稱。
在 [開發認證] 下，對於 [權杖]，根據需求輸入個人存取權杖或 Microsoft Entra ID 權杖。
對於 [結構描述]，輸入您希望 dbt Cloud 在其中建立資料表和檢視的結構描述的名稱 (例如，
default)。按一下 [測試連接] 。
如果測試成功，請按一下 [下一步]。
如需詳細資訊，請參閱 dbt 網站上的連線至 Databricks ODBC。
提示
若要檢視或變更此專案的設定，或完全刪除專案，請按一下 [設定] 圖示，按一下 [帳戶設定] > [專案]，然後按一下專案的名稱。 若要變更設定，請按一下 [編輯]。 若要刪除專案，請按一下 [編輯] > [刪除專案]。
若要檢視或變更此專案的 Azure Databricks 個人存取權杖值，請按一下 [人員] 圖示，按一下 [設定檔] > [認證]，然後按一下專案的名稱。 若要進行變更，請按一下 [編輯]。
連線至 Azure Databricks 叢集或 Databricks SQL 倉儲之後，遵循畫面上的指示來 [設定存放庫]，然後按一下 [繼續]。
設定存放庫之後，遵循畫面上的指示來邀請使用者，然後按一下 [完成]。 或按一下 [略過和完成]。
教學課程
在本節中，您將使用 dbt Cloud 專案來處理一些範例資料。 本節假設您已建立專案，並已開啟該專案的 dbt Cloud IDE。
步驟 1：建立和執行模型
在此步驟中，您將使用 dbt Cloud IDE 建立並執行模型，即 select 陳述式。這些陳述式可根據資料庫中的現有資料，在同一資料庫中建立新檢視 (預設值) 或新資料表。 此程序根據範例資料集中的範例 diamonds 資料表建立模型。
使用下列程式碼建立此資料表。
DROP TABLE IF EXISTS diamonds;
CREATE TABLE diamonds USING CSV OPTIONS (path "/databricks-datasets/Rdatasets/data-001/csv/ggplot2/diamonds.csv", header "true")
此程序假設已在工作區的 default 資料庫中建立此資料表。
開啟專案後，按一下 UI 頂端的 [開發]。
按一下 [初始化 dbt 專案]。
按一下 [認可並同步]，輸入認可訊息，然後按一下 [認可]。
按一下 [建立分支]，輸入您的分支名稱，然後按一下 [提交]。
建立第一個模型：按一下 [建立新檔案]。
在文字編輯器中，輸入下列 SQL 陳述式。 此陳述式僅從
diamonds資料表中選取每顆寶石的克拉數、切工、色彩和透明度詳細資料。config區塊指示 dbt 根據此陳述式在資料庫中建立資料表。{{ config( materialized='table', file_format='delta' ) }}select carat, cut, color, clarity from diamonds提示
如需其他
config選項 (例如merge累加策略)，請參閱 dbt 文件中的 Databricks 組態。按一下 [另存新檔] 。
對於檔案名稱，輸入
models/diamonds_four_cs.sql，然後按一下 [建立]。建立第二個模型：按一下右上角的
![[建立新檔案] 圖示](../../_static/images/third-party-integrations/dbt-cloud-create-new-file.png)
([建立新檔案])。在文字編輯器中，輸入下列 SQL 陳述式。 此陳述式會從
colors資料表中的diamonds_four_cs資料行中選取唯一值，依字母順序從頭到尾對結果進行排序。 由於沒有config區塊，此模型將指示 dbt 根據此陳述式在資料庫中建立檢視。select distinct color from diamonds_four_cs sort by color asc按一下 [另存新檔] 。
對於檔案名稱，輸入
models/diamonds_list_colors.sql，然後按一下 [建立]。建立第三個模型：按一下右上角的
([建立新檔案])。在文字編輯器中，輸入下列 SQL 陳述式。 此陳述式依色彩計算寶石的平均價格，並依平均價格從最高到最低對結果進行排序。 此模型將指示 dbt 根據此陳述式在資料庫中建立檢視。
select color, avg(price) as price from diamonds group by color order by price desc按一下 [另存新檔] 。
對於檔案名稱，輸入
models/diamonds_prices.sql，然後按一下 [建立]。執行模型：在命令列中，使用上述三個檔案的路徑執行
dbt run命令。 在default資料庫中，dbt 會建立一個名為diamonds_four_cs的資料表，以及兩個名為diamonds_list_colors和diamonds_prices的檢視。 dbt 從相關的.sql檔案名稱中取得這些檢視和資料表名稱。dbt run --model models/diamonds_four_cs.sql models/diamonds_list_colors.sql models/diamonds_prices.sql... ... | 1 of 3 START table model default.diamonds_four_cs.................... [RUN] ... | 1 of 3 OK created table model default.diamonds_four_cs............... [OK ...] ... | 2 of 3 START view model default.diamonds_list_colors................. [RUN] ... | 2 of 3 OK created view model default.diamonds_list_colors............ [OK ...] ... | 3 of 3 START view model default.diamonds_prices...................... [RUN] ... | 3 of 3 OK created view model default.diamonds_prices................. [OK ...] ... | ... | Finished running 1 table model, 2 view models ... Completed successfully Done. PASS=3 WARN=0 ERROR=0 SKIP=0 TOTAL=3執行下列 SQL 程式碼，以列出有關新檢視的資訊並選取資料表和檢視中的所有資料列。
如果要連線至叢集，您可以從連結至叢集的筆記本中執行此 SQL 程式碼，並將 SQL 指定為筆記本的預設語言。 如果要連線至 SQL 倉儲，您可以從查詢執行此 SQL 程式碼。
SHOW views IN default+-----------+----------------------+-------------+ | namespace | viewName | isTemporary | +===========+======================+=============+ | default | diamonds_list_colors | false | +-----------+----------------------+-------------+ | default | diamonds_prices | false | +-----------+----------------------+-------------+SELECT * FROM diamonds_four_cs+-------+---------+-------+---------+ | carat | cut | color | clarity | +=======+=========+=======+=========+ | 0.23 | Ideal | E | SI2 | +-------+---------+-------+---------+ | 0.21 | Premium | E | SI1 | +-------+---------+-------+---------+ ...SELECT * FROM diamonds_list_colors+-------+ | color | +=======+ | D | +-------+ | E | +-------+ ...SELECT * FROM diamonds_prices+-------+---------+ | color | price | +=======+=========+ | J | 5323.82 | +-------+---------+ | I | 5091.87 | +-------+---------+ ...
步驟 2：建立和執行更複雜的模型
在此步驟中，您將為一組相關的資料表建立更複雜的模型。 這些資料表包含有關虛擬體育聯賽的資訊，其中三支隊伍需要在一個賽季中完成六場比賽。 此程序將建立資料表、建立模型並執行模型。
執行下列 SQL 程式碼以建立必要的資料表。
如果要連線至叢集，您可以從連結至叢集的筆記本中執行此 SQL 程式碼，並將 SQL 指定為筆記本的預設語言。 如果要連線至 SQL 倉儲，您可以從查詢執行此 SQL 程式碼。
本步驟中的資料表和檢視以
zzz_開頭，有助於在本範例中加以識別。 對於自己的資料表和檢視，無需遵循此模式。DROP TABLE IF EXISTS zzz_game_opponents; DROP TABLE IF EXISTS zzz_game_scores; DROP TABLE IF EXISTS zzz_games; DROP TABLE IF EXISTS zzz_teams; CREATE TABLE zzz_game_opponents ( game_id INT, home_team_id INT, visitor_team_id INT ) USING DELTA; INSERT INTO zzz_game_opponents VALUES (1, 1, 2); INSERT INTO zzz_game_opponents VALUES (2, 1, 3); INSERT INTO zzz_game_opponents VALUES (3, 2, 1); INSERT INTO zzz_game_opponents VALUES (4, 2, 3); INSERT INTO zzz_game_opponents VALUES (5, 3, 1); INSERT INTO zzz_game_opponents VALUES (6, 3, 2); -- Result: -- +---------+--------------+-----------------+ -- | game_id | home_team_id | visitor_team_id | -- +=========+==============+=================+ -- | 1 | 1 | 2 | -- +---------+--------------+-----------------+ -- | 2 | 1 | 3 | -- +---------+--------------+-----------------+ -- | 3 | 2 | 1 | -- +---------+--------------+-----------------+ -- | 4 | 2 | 3 | -- +---------+--------------+-----------------+ -- | 5 | 3 | 1 | -- +---------+--------------+-----------------+ -- | 6 | 3 | 2 | -- +---------+--------------+-----------------+ CREATE TABLE zzz_game_scores ( game_id INT, home_team_score INT, visitor_team_score INT ) USING DELTA; INSERT INTO zzz_game_scores VALUES (1, 4, 2); INSERT INTO zzz_game_scores VALUES (2, 0, 1); INSERT INTO zzz_game_scores VALUES (3, 1, 2); INSERT INTO zzz_game_scores VALUES (4, 3, 2); INSERT INTO zzz_game_scores VALUES (5, 3, 0); INSERT INTO zzz_game_scores VALUES (6, 3, 1); -- Result: -- +---------+-----------------+--------------------+ -- | game_id | home_team_score | visitor_team_score | -- +=========+=================+====================+ -- | 1 | 4 | 2 | -- +---------+-----------------+--------------------+ -- | 2 | 0 | 1 | -- +---------+-----------------+--------------------+ -- | 3 | 1 | 2 | -- +---------+-----------------+--------------------+ -- | 4 | 3 | 2 | -- +---------+-----------------+--------------------+ -- | 5 | 3 | 0 | -- +---------+-----------------+--------------------+ -- | 6 | 3 | 1 | -- +---------+-----------------+--------------------+ CREATE TABLE zzz_games ( game_id INT, game_date DATE ) USING DELTA; INSERT INTO zzz_games VALUES (1, '2020-12-12'); INSERT INTO zzz_games VALUES (2, '2021-01-09'); INSERT INTO zzz_games VALUES (3, '2020-12-19'); INSERT INTO zzz_games VALUES (4, '2021-01-16'); INSERT INTO zzz_games VALUES (5, '2021-01-23'); INSERT INTO zzz_games VALUES (6, '2021-02-06'); -- Result: -- +---------+------------+ -- | game_id | game_date | -- +=========+============+ -- | 1 | 2020-12-12 | -- +---------+------------+ -- | 2 | 2021-01-09 | -- +---------+------------+ -- | 3 | 2020-12-19 | -- +---------+------------+ -- | 4 | 2021-01-16 | -- +---------+------------+ -- | 5 | 2021-01-23 | -- +---------+------------+ -- | 6 | 2021-02-06 | -- +---------+------------+ CREATE TABLE zzz_teams ( team_id INT, team_city VARCHAR(15) ) USING DELTA; INSERT INTO zzz_teams VALUES (1, "San Francisco"); INSERT INTO zzz_teams VALUES (2, "Seattle"); INSERT INTO zzz_teams VALUES (3, "Amsterdam"); -- Result: -- +---------+---------------+ -- | team_id | team_city | -- +=========+===============+ -- | 1 | San Francisco | -- +---------+---------------+ -- | 2 | Seattle | -- +---------+---------------+ -- | 3 | Amsterdam | -- +---------+---------------+建立第一個模型：按一下右上角的
([建立新檔案])。在文字編輯器中，輸入下列 SQL 陳述式。 此陳述式會建立一個資料表，該資料表提供每場比賽的詳細資料，例如隊伍名稱和分數。
config區塊指示 dbt 根據此陳述式在資料庫中建立資料表。-- Create a table that provides full details for each game, including -- the game ID, the home and visiting teams' city names and scores, -- the game winner's city name, and the game date.{{ config( materialized='table', file_format='delta' ) }}-- Step 4 of 4: Replace the visitor team IDs with their city names. select game_id, home, t.team_city as visitor, home_score, visitor_score, -- Step 3 of 4: Display the city name for each game's winner. case when home_score > visitor_score then home when visitor_score > home_score then t.team_city end as winner, game_date as date from ( -- Step 2 of 4: Replace the home team IDs with their actual city names. select game_id, t.team_city as home, home_score, visitor_team_id, visitor_score, game_date from ( -- Step 1 of 4: Combine data from various tables (for example, game and team IDs, scores, dates). select g.game_id, go.home_team_id, gs.home_team_score as home_score, go.visitor_team_id, gs.visitor_team_score as visitor_score, g.game_date from zzz_games as g, zzz_game_opponents as go, zzz_game_scores as gs where g.game_id = go.game_id and g.game_id = gs.game_id ) as all_ids, zzz_teams as t where all_ids.home_team_id = t.team_id ) as visitor_ids, zzz_teams as t where visitor_ids.visitor_team_id = t.team_id order by game_date desc按一下 [另存新檔] 。
對於檔案名稱，輸入
models/zzz_game_details.sql，然後按一下 [建立]。建立第二個模型：按一下右上角的
([建立新檔案])。在文字編輯器中，輸入下列 SQL 陳述式。 此陳述式會建立一個檢視，其中列出該賽季隊伍的勝負記錄。
-- Create a view that summarizes the season's win and loss records by team. -- Step 2 of 2: Calculate the number of wins and losses for each team. select winner as team, count(winner) as wins, -- Each team played in 4 games. (4 - count(winner)) as losses from ( -- Step 1 of 2: Determine the winner and loser for each game. select game_id, winner, case when home = winner then visitor else home end as loser from zzz_game_details ) group by winner order by wins desc按一下 [另存新檔] 。
對於檔案名稱，輸入
models/zzz_win_loss_records.sql，然後按一下 [建立]。執行模型：在命令列中，使用上述兩個檔案的路徑執行
dbt run命令。 在default資料庫 (在專案設定中指定) 中，dbt 會建立一個名為zzz_game_details的資料表和一個名為zzz_win_loss_records的檢視。 dbt 從相關的.sql檔案名稱中取得這些檢視和資料表名稱。dbt run --model models/zzz_game_details.sql models/zzz_win_loss_records.sql... ... | 1 of 2 START table model default.zzz_game_details.................... [RUN] ... | 1 of 2 OK created table model default.zzz_game_details............... [OK ...] ... | 2 of 2 START view model default.zzz_win_loss_records................. [RUN] ... | 2 of 2 OK created view model default.zzz_win_loss_records............ [OK ...] ... | ... | Finished running 1 table model, 1 view model ... Completed successfully Done. PASS=2 WARN=0 ERROR=0 SKIP=0 TOTAL=2執行下列 SQL 程式碼，以列出有關新檢視的資訊並選取資料表和檢視中的所有資料列。
如果要連線至叢集，您可以從連結至叢集的筆記本中執行此 SQL 程式碼，並將 SQL 指定為筆記本的預設語言。 如果要連線至 SQL 倉儲，您可以從查詢執行此 SQL 程式碼。
SHOW VIEWS FROM default LIKE 'zzz_win_loss_records';+-----------+----------------------+-------------+ | namespace | viewName | isTemporary | +===========+======================+=============+ | default | zzz_win_loss_records | false | +-----------+----------------------+-------------+SELECT * FROM zzz_game_details;+---------+---------------+---------------+------------+---------------+---------------+------------+ | game_id | home | visitor | home_score | visitor_score | winner | date | +=========+===============+===============+============+===============+===============+============+ | 1 | San Francisco | Seattle | 4 | 2 | San Francisco | 2020-12-12 | +---------+---------------+---------------+------------+---------------+---------------+------------+ | 2 | San Francisco | Amsterdam | 0 | 1 | Amsterdam | 2021-01-09 | +---------+---------------+---------------+------------+---------------+---------------+------------+ | 3 | Seattle | San Francisco | 1 | 2 | San Francisco | 2020-12-19 | +---------+---------------+---------------+------------+---------------+---------------+------------+ | 4 | Seattle | Amsterdam | 3 | 2 | Seattle | 2021-01-16 | +---------+---------------+---------------+------------+---------------+---------------+------------+ | 5 | Amsterdam | San Francisco | 3 | 0 | Amsterdam | 2021-01-23 | +---------+---------------+---------------+------------+---------------+---------------+------------+ | 6 | Amsterdam | Seattle | 3 | 1 | Amsterdam | 2021-02-06 | +---------+---------------+---------------+------------+---------------+---------------+------------+SELECT * FROM zzz_win_loss_records;+---------------+------+--------+ | team | wins | losses | +===============+======+========+ | Amsterdam | 3 | 1 | +---------------+------+--------+ | San Francisco | 2 | 2 | +---------------+------+--------+ | Seattle | 1 | 3 | +---------------+------+--------+
步驟 3：建立並執行測試
在此步驟中，您將建立測試，這些測試是您對模型所做的判斷提示。 執行這些測試時，dbt 會告訴您專案中的每個測試是通過還是失敗。
有兩種類型的測試。 結構描述測試 (以 YAML 撰寫) 會傳回未通過判斷提示的記錄數目。 此數字為零時，表示所有記錄都通過，因此測試也通過。 資料測試是必須傳回零個記錄才算通過的特定查詢。
建立結構描述測試：按一下右上角的
([建立新檔案])。在文字編輯器中，輸入下列內容。 此檔案包含結構描述測試，用於確定指定的資料行是否具有唯一值、不為 null、僅具有指定值或具有組合。
version: 2 models: - name: zzz_game_details columns: - name: game_id tests: - unique - not_null - name: home tests: - not_null - accepted_values: values: ['Amsterdam', 'San Francisco', 'Seattle'] - name: visitor tests: - not_null - accepted_values: values: ['Amsterdam', 'San Francisco', 'Seattle'] - name: home_score tests: - not_null - name: visitor_score tests: - not_null - name: winner tests: - not_null - accepted_values: values: ['Amsterdam', 'San Francisco', 'Seattle'] - name: date tests: - not_null - name: zzz_win_loss_records columns: - name: team tests: - unique - not_null - relationships: to: ref('zzz_game_details') field: home - name: wins tests: - not_null - name: losses tests: - not_null按一下 [另存新檔] 。
對於檔案名稱，輸入
models/schema.yml，然後按一下 [建立]。建立第一個資料測試：按一下右上角的
([建立新檔案])。在文字編輯器中，輸入下列 SQL 陳述式。 此檔案包含一個資料測試，用於確定常規賽季外是否進行了任何比賽。
-- This season's games happened between 2020-12-12 and 2021-02-06. -- For this test to pass, this query must return no results. select date from zzz_game_details where date < '2020-12-12' or date > '2021-02-06'按一下 [另存新檔] 。
對於檔案名稱，輸入
tests/zzz_game_details_check_dates.sql，然後按一下 [建立]。建立第二個資料測試：按一下右上角的
([建立新檔案])。在文字編輯器中，輸入下列 SQL 陳述式。 此檔案包含一個資料測試，用於確定是否有任何分數為負或任何比賽為平局。
-- This sport allows no negative scores or tie games. -- For this test to pass, this query must return no results. select home_score, visitor_score from zzz_game_details where home_score < 0 or visitor_score < 0 or home_score = visitor_score按一下 [另存新檔] 。
對於檔案名稱，輸入
tests/zzz_game_details_check_scores.sql，然後按一下 [建立]。建立第三個資料測試：按一下右上角的
([建立新檔案])。在文字編輯器中，輸入下列 SQL 陳述式。 此檔案包含一個資料測試，用於確定任何隊伍是否有負數的勝場或敗場記錄、是否有超過進行比賽數的勝負記錄，或者進行的比賽數是否多於允許的比賽數。
-- Each team participated in 4 games this season. -- For this test to pass, this query must return no results. select wins, losses from zzz_win_loss_records where wins < 0 or wins > 4 or losses < 0 or losses > 4 or (wins + losses) > 4按一下 [另存新檔] 。
對於檔案名稱，輸入
tests/zzz_win_loss_records_check_records.sql，然後按一下 [建立]。執行測試：在命令列中，執行
dbt test命令。
步驟 4：清理
您可以透過執行下列 SQL 程式碼來刪除為此範例建立的資料表和檢視。
如果要連線至叢集，您可以從連結至叢集的筆記本中執行此 SQL 程式碼，並將 SQL 指定為筆記本的預設語言。 如果要連線至 SQL 倉儲，您可以從查詢執行此 SQL 程式碼。
DROP TABLE zzz_game_opponents;
DROP TABLE zzz_game_scores;
DROP TABLE zzz_games;
DROP TABLE zzz_teams;
DROP TABLE zzz_game_details;
DROP VIEW zzz_win_loss_records;
DROP TABLE diamonds;
DROP TABLE diamonds_four_cs;
DROP VIEW diamonds_list_colors;
DROP VIEW diamonds_prices;