使用 Azure Synapse Analytics 中的無伺服器 SQL 集區來查詢儲存體資料

發行項
10/02/2024

無伺服器 SQL 集區可讓您查詢資料湖中的資料。其提供可搭載半結構化和非結構化資料查詢的 T-SQL 查詢介面區。在查詢方面，可支援下列 T-SQL 層面：

完整的 SELECT 介面區，包括大部分的 SQL 函式及運算子。
CREATE EXTERNAL TABLE AS SELECT (CETAS) 會建立外部資料表，然後將 Transact-SQL SELECT 陳述式的結果以平行方式匯出至 Azure 儲存體。

如需有關目前支援及不支援的功能詳細資訊，請參閱無伺服器 SQL 集區概觀一文，或參閱下列文章：

開發儲存體存取，您可以在其中了解如何使用外部資料表及 OPENROWSET 函式從儲存體讀取資料。
控制儲存體存取，您可以在其中了解如何讓 Synapse SQL 使用 SAS 驗證或工作區的受控識別來存取儲存體。

概觀

為了在 Azure 儲存體檔案中進行資料就地查詢時有流暢的體驗，無伺服器 SQL 集區使用了 OPENROWSET 函式與其他功能：

查詢多個檔案或資料夾
PARQUET 檔案格式
查詢 CSV 和分隔文字 (欄位結束字元、資料列結束字元、逸出字元)
DELTA LAKE 格式
讀取選擇的資料行子集
結構描述推斷
filename 函式
filepath 函式
使用複雜類型和巢狀或重複的資料結構

查詢 PARQUET 檔案

如要查詢 Parquet 來源資料，請使用 FORMAT = 'PARQUET'：

SELECT * FROM
OPENROWSET( BULK N'https://myaccount.dfs.core.windows.net/mycontainer/mysubfolder/data.parquet', FORMAT = 'PARQUET') 
WITH (C1 int, C2 varchar(20), C3 varchar(max)) as rows

如需使用範例，請參閱查詢 Parquet 檔案一文。

查詢 CSV 檔案

若要查詢 CSV 來源資料，請使用 FORMAT = 'CSV'。當您查詢 CSV 檔案時，您可以在 OPENROWSET 函式中指定 CSV 檔案的結構描述：

SELECT * FROM
OPENROWSET( BULK N'https://myaccount.dfs.core.windows.net/mycontainer/mysubfolder/data.csv', FORMAT = 'CSV', PARSER_VERSION='2.0') 
WITH (C1 int, C2 varchar(20), C3 varchar(max)) as rows

還有一些其他選項可用來將剖析規則調整為自訂 CSV 格式：

ESCAPE_CHAR = 'char' 會指定檔案中用來將本身和所有分隔符號值逸出的字元。如果逸出字元後面接著本身或任何分隔符號值以外的值，讀取值時就會捨棄逸出字元。無論 FIELDQUOTE 已啟用或未啟用，都會套用 ESCAPE_CHAR 參數。其不會用來逸出引號字元。引號字元必須以另一個引號字元來逸出。只有在以引號字元封住值時，引號字元才能在資料行值中出現。
FIELDTERMINATOR ='field_terminator' 會指定要使用的欄位結束字元。預設的欄位結束字元為逗號 (",")
ROWTERMINATOR ='row_terminator' 會指定要使用的資料列結束字元。預設的資料列結束字元是新行字元：\r\n。

查詢 DELTA LAKE 格式

如要查詢 Delta Lake 來源資料，請使用 FORMAT = 'DELTA'，並參考包含 Delta Lake 檔案的根資料夾。

SELECT * FROM
OPENROWSET( BULK N'https://myaccount.dfs.core.windows.net/mycontainer/mysubfolder', FORMAT = 'DELTA') 
WITH (C1 int, C2 varchar(20), C3 varchar(max)) as rows

根資料夾必須包含名為 _delta_log 的子資料夾。如需使用範例，請檢閱《查詢 Delta Lake 格式》一文。

檔案結構描述

Synapse SQL 中的 SQL 語言可讓您將檔案的結構描述定義為 OPENROWSET 函式的一部分，以及讀取全部或部分的資料行，或嘗試使用結構描述推斷，自動從檔案中判斷資料行類型。

讀取選擇的資料行子集

若要指定您想要讀取的資料行，您可以在 OPENROWSET 陳述式內提供選擇性的 WITH 子句。

如果有 CSV 資料檔案，應提供資料行名稱及其資料類型，才能讀取所有資料行。如果您想要讀取一小組資料行，請使用序數從原始資料檔案中依序挑選資料行。資料行將會以加上順序的指派來繫結。
如果有 Parquet 資料檔案，請提供與原始資料檔案中資料行名稱相符的資料行名稱。資料行將會依名稱來繫結。

SELECT * FROM
OPENROWSET( BULK N'https://myaccount.dfs.core.windows.net/mycontainer/mysubfolder/data.parquet', FORMAT = 'PARQUET') 
WITH (
      C1 int, 
      C2 varchar(20),
      C3 varchar(max)
) as rows

針對每個資料行，您都必須在 WITH 子句中指定資料行名稱和類型。如需範例，請參閱在不指定所有資料行的情況下讀取 CSV 檔案。

結構描述推斷

您可以藉由省略 OPENROWSET 陳述式中的 WITH 子句，來指示服務從基礎檔案中自動偵測 (推斷) 結構描述。

SELECT * FROM
OPENROWSET( BULK N'https://myaccount.dfs.core.windows.net/mycontainer/mysubfolder/data.parquet', FORMAT = 'PARQUET')

請確定使用適當的推斷資料類型來達到最佳效能。

查詢多個檔案或資料夾

若要對資料夾或資料夾集合中的一組檔案執行 T-SQL 查詢，並同時將其視為單一實體或資料列集，請提供單一資料夾的路徑，或代表一組檔案或資料夾的模式 (使用萬用字元)。

適用的規則如下：

模式可能會出現在目錄路徑或檔案名稱中。
相同目錄步驟或檔案名稱中可出現多個模式。
如果有多個萬用字元，則會在產生的檔案集中包含所有相符路徑內的檔案。

SELECT * FROM
OPENROWSET( BULK N'https://myaccount.dfs.core.windows.net/myroot/*/mysubfolder/*.parquet', FORMAT = 'PARQUET' ) as rows

如需使用範例，請參閱查詢資料夾和多個檔案。

檔案中繼資料函式

Filename 函式

此函式會傳回資料列來源的檔案名稱。

若要查詢特定檔案，請閱讀查詢特定檔案一文中的＜Filename＞一節。

傳回資料類型為 nvarchar(1024)。為了達到最佳效能，請一律將 filename 函式的結果轉換成適當的資料類型。如果您使用字元資料類型，請務必確認長度適當。

Filepath 函式

此函式會傳回完整路徑或部分路徑的：

若在沒有參數的情況下進行呼叫，會傳回資料列來源的完整檔案路徑。
若以參數進行呼叫，則會傳回路徑的一部分，該部分會與參數中所指定位置上的萬用字元相符。例如，參數值 1 會傳回符合第一個萬用字元的路徑部分。

如需詳細資訊，請參閱查詢特定檔案一文的 Filepath 區段。

傳回資料類型為 nvarchar(1024)。為了達到最佳效能，請一律將 filepath 函式的結果轉換成適當的資料類型。如果您使用字元資料類型，請務必確認長度適當。

使用複雜類型和巢狀或重複的資料結構

為了在使用以巢狀或重複資料類型 (例如 Parquet 檔案) 儲存的資料時擁有流暢的體驗，無伺服器 SQL 集區已新增下列延伸模組。

投射巢狀或重復資料

若要投射資料，請在包含資料行 (巢狀資料類型) 的 Parquet 檔案上執行 SELECT 陳述式。在輸出時，巢狀值會序列化為 JSON，並以 varchar(8000) SQL 資料類型的形式傳回。

    SELECT * FROM
    OPENROWSET
    (   BULK 'unstructured_data_path' ,
        FORMAT = 'PARQUET' )
    [AS alias]

如需詳細資訊，請參閱查詢 Parquet 巢狀型別一文中的＜投射巢狀或重復資料＞一節。

從巢狀資料行存取元素

若要從巢狀資料行 (例如 Struct) 存取巢狀元素，請使用「點標記法」將欄位名稱串連到路徑中。在 OPENROWSET 函式的 WITH 子句中，提供路徑作為 column_name。

語法片段範例如下：

    OPENROWSET
    (   BULK 'unstructured_data_path' ,
        FORMAT = 'PARQUET' )
    WITH ({'column_name' 'column_type',})
    [AS alias]
    'column_name' ::= '[field_name.] field_name'

根據預設，OPENROWSET 函式會以 WITH 子句中提供的資料行名稱來比對來源欄位名稱和路徑。您可以使用 WITH 子句來存取包含在相同來源 Parquet 檔案中，但位於不同巢狀層級的元素。

傳回值

針對不在巢狀型別群組中的所有 Parquet 類型，函式會從指定的專案和指定的路徑傳回純量值 (例如 int、decimal 和 varchar)。
如果路徑指向屬於巢狀型別的元素，則函式會從指定路徑的最上層元素開始傳回 JSON 片段。 JSON 片段的類型為 varchar(8000)。
如果在指定的 column_name 中找不到屬性，則函數會傳回錯誤。
如果在指定的 column_path 中找不到屬性，則視路徑模式而定，函式會在 strict 模式中傳回錯誤，而在 lax 模式中則會傳回 null。

如需查詢範例，請參閱查詢 Parquet 巢狀型別一文中的＜從巢狀資料行存取元素＞一節。

從重複的資料行存取元素

若要從重複的資料行存取元素 (例如陣列或對應的元素)，請針對您需要投影和提供的每個純量元素，使用 JSON_VALUE 函式：

使用巢狀或重復資料行作為第一個參數
第二個參數則使用 JSON 路徑，該路徑會指定要存取的元素或屬性

若要從重複的資料行存取非純量元素，請針對您需要投影和提供的每個非純量元素，使用 JSON_QUERY 函式：

使用巢狀或重復資料行作為第一個參數
第二個參數則使用 JSON 路徑，該路徑會指定要存取的元素或屬性

請參閱下面的語法片段：

    SELECT
       { JSON_VALUE (column_name, path_to_sub_element), }
       { JSON_QUERY (column_name [ , path_to_sub_element ]), )
    FROM
    OPENROWSET
    (   BULK 'unstructured_data_path' ,
        FORMAT = 'PARQUET' )
    [AS alias]

您可以在查詢 Parquet 巢狀型別一文中，找到用來從重復資料行中存取元素的查詢範例。

下一步

如需如何查詢不同檔案類型以及建立和使用檢視的詳細資訊，請參閱下列文章：

共用方式為