共用方式為

第 1 課：使用 SQL Server Integration Services (SSIS) 來建立專案和基本套件

適用於：SQL Server Azure Data Factory 中的 SSIS Integration Runtime

在這一課，您會建立一個簡單的擷取、轉換和載入 (ETL) 套件。 該套件從單一平面檔案來源擷取資料，透過兩次查找轉換轉換資料，並將轉換後的資料寫入 FactCurrencyRate 範例資料庫中的事實表 AdventureWorksDW2025 副本。 作為這堂課的一部分，你會建立新的套件、新增並設定資料來源與目的地的連線，並操作新的控制流程與資料流程元件。

在建立套件之前，您必須先了解來源資料和目的地中使用的格式。 接著，你就可以定義將來源資料映射到目的地所需的轉換。

必要條件

本教學課程倚賴 Microsoft SQL Server Data Tools，這是一組範例套件及一個範例資料庫。

備註

本文中的程式代碼範例會使用 AdventureWorks2025 或 AdventureWorksDW2025 範例資料庫，您可以從 Microsoft SQL Server 範例和社群專案 首頁下載。

要安裝 SQL Server 資料工具，請參見 Visual Studio 安裝 SQL Server 資料工具（SSDT）。

下載本教學課程的所有課程套件：

  1. 瀏覽至 Integration Services 教學課程檔案 \(英文\)。
  2. 選擇 下載 按鈕。
  3. 選擇檔案， Creating a Simple ETL Package.zip 然後選擇 「下一步」。
  4. 下載檔案之後，將其內容解壓縮至本機目錄。

查看資料來源

本教學的來源資料是一組歷史貨幣資料，存放於一個名為 SampleCurrencyData.txt的平面檔案中。 來源資料具有下列四個資料行：貨幣的平均匯率、貨幣索引鍵、日期索引鍵和收盤匯率。

以下是檔案中 SampleCurrencyData.txt 原始資料的範例：

1.00070049USD9/3/05 0:001.001201442
1.00020004USD9/4/05 0:001
1.00020004USD9/5/05 0:001.001201442
1.00020004USD9/6/05 0:001
1.00020004USD9/7/05 0:001.00070049
1.00070049USD9/8/05 0:000.99980004
1.00070049USD9/9/05 0:001.001502253
1.00070049USD9/10/05 0:000.99990001
1.00020004USD9/11/05 0:001.001101211
1.00020004USD9/12/05 0:000.99970009

使用一般檔案來源資料時，請務必了解「一般檔案」連線管理員如何解譯一般檔案資料。 若扁平檔來源為 Unicode，平面檔案連接管理器會定義所有欄位 [DT_WSTR] ，預設欄位寬度為 50。 若平面檔案來源為 ANSI 編碼，欄位定義為 [DT_STR] ，預設欄位寬度為 50。 您可能必須變更這些預設值，以便讓字串資料行類型更適用於您的資料。 您必須查看目的地的資料類型，然後在「一般檔案」連線管理員內選擇該類型。

查看目的地資料

來源資料的目的地是一份 中FactCurrencyRate事實表的副本AdventureWorksDW2025。 FactCurrencyRate事實表有四欄，並與二維資料表有關聯，如下表所示。

欄位名稱 數據類型 查詢表 查詢欄
AverageRate 浮動 無 無
CurrencyKey 整數 (FK) 1 DimCurrency CurrencyKey （PK） 2
DateKey 整數 (FK) 1 DimDate DateKey （PK） 2
EndOfDayRate 浮動 無 無

1 FK：外鍵

2 PK：主鍵

將來源資料對應至目的地

我們對來源與目的資料格式的分析顯示，對於 CurrencyKey 和 DateKey 值進行查詢是必要的。 執行這些查找的轉換通過使用DimCurrency和DimDate維度表中的替代鍵來獲取這些值。

平面檔案欄位 數據表名稱 欄位名稱 數據類型
0 FactCurrencyRate AverageRate 浮動
1 DimCurrency CurrencyAlternateKey nchar（3）
2 DimDate FullDateAlternateKey date
3 FactCurrencyRate EndOfDayRate 浮動

課程工作

後續步驟

步驟 1：建立新的 Integration Services 專案

  • Last updated on