CREATE EXTERNAL TABLE AS SELECT (CETAS) (Transact-SQL)

Область применения: SQL Server 2022 (16.x) и более поздних версий Azure Synapse Analytics Analytics Platform System (PDW)

Создает внешнюю таблицу, а затем параллельно экспортирует результаты инструкции Transact-SQL SELECT.

• Система платформы Azure Synapse Analytics и Analytics поддерживает Hadoop или хранилище BLOB-объектов Azure.
• SQL Server 2022 (16.x) и более поздних версий поддерживают CREATE EXTERNAL TABLE AS SELECT (CETAS) для создания внешней таблицы, а затем экспорта, параллельного экспорта инструкции Transact-SQL SELECT в Azure Data Lake Storage (ADLS) 2-го поколения, служба хранилища Azure account версии 2 и хранилища объектов, совместимых с S3.

Примечание.

Возможности и безопасность CETAS для Управляемый экземпляр SQL Azure отличаются от SQL Server или Azure Synapse Analytics. Дополнительные сведения см. в Управляемый экземпляр SQL Azure версии CREATE EXTERNAL TABLE AS SELECT.

Примечание.

Возможности и безопасность CETAS для бессерверных пулов в Azure Synapse Analytics отличаются от SQL Server. Дополнительные сведения см. в разделе CETAS с Synapse SQL.

Соглашения о синтаксисе Transact-SQL

Синтаксис

CREATE EXTERNAL TABLE { [ [ database_name . [ schema_name ] . ] | schema_name . ] table_name }
    [ (column_name [ , ...n ] ) ]
    WITH (
        LOCATION = 'hdfs_folder' | '<prefix>://<path>[:<port>]' ,
        DATA_SOURCE = external_data_source_name ,
        FILE_FORMAT = external_file_format_name
        [ , <reject_options> [ , ...n ] ]
    )
    AS <select_statement>
[;]

<reject_options> ::=
{
    | REJECT_TYPE = value | percentage
    | REJECT_VALUE = reject_value
    | REJECT_SAMPLE_VALUE = reject_sample_value
}

<select_statement> ::=
    [ WITH <common_table_expression> [ , ...n ] ]
    SELECT <select_criteria>

Аргументы

[ [ database_name . [ schema_name ] . ] | schema_name . ] table_name

Одно-трехкомпонентное имя таблицы, создаваемой в базе данных. Для внешней таблицы реляционная база данных хранит только метаданные таблицы.

[ ( column_name [ ,...n ] ) ]

Имя столбца таблицы.

LOCATION

Область применения: Azure Synapse Analytics и Analytics Platform System

'hdfs_folder'**
Указывает место записи результатов инструкции SELECT во внешнем источнике данных. Расположение — это имя папки. Оно может включать путь относительно корневой папки кластера Hadoop или Хранилища BLOB-объектов. PolyBase создает путь и папку, если она еще не существует.

Внешние файлы записываются hdfs_folder в и именуются QueryID_date_time_ID.format, где ID является добавочным идентификатором и format является экспортируемым форматом данных. Например, QID776_20160130_182739_0.orc.

LOCATION должен указывать на папку и иметь конечный путь/, например: aggregated_data/

Область применения: SQL Server 2022 (16.x) и более поздних версий

prefix://path[:port] предоставляет протокол подключения (префикс), путь и при необходимости порт к внешнему источнику данных, где будет записан результат инструкции SELECT.

Если назначение является хранилищем объектов, совместимым с S3, сначала должен существовать контейнер, но PolyBase может создавать вложенные папки при необходимости. SQL Server 2022 (16.x) поддерживает Azure Data Lake Storage 2-го поколения, служба хранилища Azure учетную запись 2 и хранилище объектов, совместимое с S3. В настоящее время файлы ORC не поддерживаются.

DATA_SOURCE = external_data_source_name

Задает имя объекта внешнего источника данных, которое содержит расположение, где хранятся или будут храниться внешние данные. Это расположение — кластер Hadoop или Хранилище BLOB-объектов Azure. Для создания внешнего источника данных используйте инструкцию CREATE EXTERNAL DATA SOURCE (Transact-SQL).

FILE_FORMAT = external_file_format_name

Задает имя объекта формата внешнего файла, который хранит формат внешнего файла данных. Чтобы создать формат внешнего файла, используйте CREATE EXTERNAL FILE FORMAT (Transact-SQL).

Параметры REJECT

Параметры REJECT не применяются в момент выполнения инструкции CREATE EXTERNAL TABLE AS SELECT. Они указываются здесь, чтобы база данных могла использовать их позже при импорте данных из внешней таблицы. Позже, когда инструкция CREATE TABLE AS SELECT выбирает данные из внешней таблицы, базы данных будет использовать параметры отклонения, чтобы определить число и процент строк, которые, возможно, не удастся импортировать до завершения импорта.

• REJECT_VALUE = reject_value

  Указывает значение или процент строк, которые могут не импортироваться до остановки импорта базы данных.

• REJECT_TYPE = значение | процент

  Указывает, является ли параметр REJECT_VALUE литеральным значением или процентом.

  • значение

    Используется, если REJECT_VALUE является литеральным значением, а не процентом. База данных перестает импортировать строки из внешнего файла данных, когда количество неудачных строк превышает reject_value.

    Например, если REJECT_VALUE = 5 и REJECT_TYPE = valueбаза данных перестает импортировать строки после того, как пять строк не удалось импортировать.

  • процент

    Используется, если REJECT_VALUE является процентом, а не литеральным значением. База данных перестает импортировать строки из внешнего файла данных, если процент неудачных строк превышает reject_value. Процент недопустимых строк вычисляется с интервалами. Допустимо только в выделенных пулах SQL, если TYPE=HADOOP.

• REJECT_SAMPLE_VALUE = reject_sample_value

  Обязательный, если REJECT_TYPE = percentage. Указывает количество строк, которые необходимо импортировать, прежде чем база данных пересчитывает процент неудачных строк.

  Например, если задано REJECT_SAMPLE_VALUE = 1000, база данных рассчитает процент отклоненных строк после попытки импортировать 1000 строк из внешнего файла данных. Если процент неудачных строк меньше reject_value, база данных пытается загрузить еще 1000 строк. База данных продолжает повторно вычислять процент отклоненных строк после каждой попытки извлечения 1000 строк.

  Примечание.

  Так как база данных вычисляет процент отклоненных строк с интервалами, фактический процент отклоненных строк может превысить значение reject_value.

  Пример:

  В этом примере показано, как три параметра REJECT взаимодействуют друг с другом. Например, если REJECT_TYPE = percentage, REJECT_VALUE = 30, REJECT_SAMPLE_VALUE = 100может произойти следующий сценарий:

  • База данных пытается загрузить первые 100 строк, из которых 25 отклонены и 75 загружены.
  • Показатель строк с ошибками составляет 25 %, что меньше значения отклонения в 30 %. Следовательно, останавливать загрузку не нужно.
  • База данных пытается загрузить следующие 100 строк. На этот раз 25 строк загружены и 75 отклонены.
  • Показатель отклоненных строк вычислен повторно и составляет 50 %. Процент отклоненных строк превысил значение отклонения 30 %.
  • Загрузка завершится ошибкой с 50 % отклоненных строк после попытки загрузить 200 строк, что превышает заданный лимит 30 %.

WITH common_table_expression

Задается временно именованный результирующий набор, называемый обобщенным табличным выражением (ОТВ). Дополнительные сведения см. в статье WITH common_table_expression (Transact-SQL).

SELECT <select_criteria>

Заполняет новую таблицу результатами выполнения инструкции SELECT. select_criteria являются основной частью инструкции SELECT и определяют, какие данные нужно скопировать в новую таблицу. Сведения об инструкциях SELECT см. в статье SELECT (Transact-SQL).

Примечание.

Предложение ORDER BY в SELECT не влияет на CETAS.

Параметры столбцов

• column_name [ ,... n ]

  В именах столбцов не могут использоваться параметры столбцов, указанные в разделе, посвященном инструкции CREATE TABLE. Вместо этого можно указать необязательный список из одного или нескольких имен столбцов для новой таблицы. Столбцы в новой таблице используют указанные имена. При указании имен столбцов число столбцов в списке столбцов должно совпадать с числом столбцов в результатах выборки. Если имена столбцов не указаны, новая целевая таблица использует имена столбцов в результатах инструкции select.

  Вы не можете указать другие параметры столбца, такие как типы данных, параметры сортировки или значение NULL. Каждый из этих атрибутов определяется на основе результатов выполнения инструкции SELECT. Тем не менее инструкцию SELECT можно использовать для изменения атрибутов. Пример см. в разделе Использование инструкции CETAS для изменения атрибутов столбца.

Разрешения

Для выполнения этой команды пользователю базы данных потребуются все следующие разрешения и роли:

• Разрешение ALTER SCHEMA для локальной схемы, которая будет содержать новую таблицу, или наличие предопределенной роли базы данных db_ddladmin.
• Разрешение CREATE TABLE или наличие предопределенной роли базы данных db_ddladmin.
• Разрешение SELECT для любых объектов, на которые ссылается select_criteria.

Учетные данные для входа в систему должны обладать всеми нижеперечисленными разрешениями:

• АДМИНИСТРИРОВАНИЕ МАССОВЫХ ОПЕРАЦИЙ
• ALTER ANY EXTERNAL DATA SOURCE
• ALTER ANY EXTERNAL FILE FORMAT
• Как правило, у вас должны быть разрешения на содержимое папки List и запись в папку LOCATION для CETAS.
• В Azure Synapse Analytics и analytics Platform System разрешение на запись для чтения и записи в внешнюю папку в кластере Hadoop или в хранилище BLOB-объектов Azure.
• В SQL Server 2022 (16.x) также необходимо задать соответствующие разрешения во внешнем расположении. Разрешение на запись для вывода данных в расположение и разрешение на чтение для доступа к нему.
• Для Хранилище BLOB-объектов Azure и Azure Data Lake 2-го SHARED ACCESS SIGNATURE поколения маркер должен быть предоставлен следующим привилегиям в контейнере: чтение, запись, создание списка.
• Для хранилища Allowed Servicesблогов Azure установите флажок : Blob для создания маркера SAS.
• Для Azure Data Lake 2-го Allowed Servicesпоколения установите флажки и Container Object флажки для создания маркера SAS.

Внимание

Разрешение ALTER ANY EXTERNAL DATA SOURCE позволяет любому субъекту создавать и изменять объект внешнего источника данных, обеспечивая таким образом возможность доступа ко всем учетным данным уровня базы данных в базе данных. Это разрешение следует рассматривать как высоко привилегированное, поэтому его следует предоставлять только доверенным субъектам в системе.

Обработка ошибок

Когда инструкция CREATE EXTERNAL TABLE AS SELECT экспортирует данные в файл с разделителями текста, файл отклонения для строк, которые не удается экспортировать, отсутствует.

При создании внешней таблицы база данных пытается подключиться к внешнему местоположению. Если подключение завершается ошибкой, команда завершается ошибкой, и внешняя таблица не создается. Это может занять около минуты, так как база данных повторяет попытки подключения по меньшей мере три раза.

Если инструкция CREATE EXTERNAL TABLE AS SELECT отменена или завершается ошибкой, база данных пытается удалить все новые файлы и папки, уже созданные во внешнем источнике данных.

В Azure Synapse Analytics и analytics Platform System база данных сообщает об ошибках Java, возникающих во время экспорта данных во время экспорта данных.

Замечания

После выполнения инструкции CREATE EXTERNAL TABLE AS SELECT можно выполнять запросы Transact-SQL во внешней таблице. Эти операции импортируют данные в базу данных в течение длительности запроса, если вы не импортируете с помощью инструкции CREATE TABLE AS SELECT.

Имя и определение внешней таблицы хранятся в метаданных базы данных. Данные хранятся во внешнем источнике данных.

При использовании инструкции CREATE EXTERNAL TABLE AS SELECT всегда создается несекционированная таблица, даже если исходная таблица является секционированной.

Для SQL Server 2022 (16.x) параметр allow polybase export должен быть включен с помощью sp_configure. Дополнительные сведения см. в статье Установка параметра конфигурации allow polybase export.

Для планов запросов в Azure Synapse Analytics и Analytics Platform System, созданных с помощью EXPLAIN, база данных использует следующие операции плана запросов для внешних таблиц: перемещение "Внешнее перемешивание", перемещение "Внешняя трансляция", перемещение "Внешнее секционирование".

В Analytics Platform System в качестве предварительного условия для создания внешней таблицы администратор устройства должен настроить подключение к Hadoop. Дополнительные сведения см. в разделе с инструкциями по настройке подключения к внешним данным (Analytics Platform System) в документации по APS, доступной для скачивания в Центре загрузки Майкрософт.

ограничения

Так как данные внешней таблицы находятся за пределами базы данных, операции резервного копирования и восстановления работают только с данными, хранящимися в базе данных. В результате резервное копирование и восстановление только метаданных.

База данных не проверяет подключение к внешнему источнику данных при восстановлении резервной копии базы данных, которая содержит внешнюю таблицу. Если исходный источник недоступен, восстановление метаданных внешней таблицы по-прежнему будет выполнено успешно, но операции SELECT во внешней таблице завершаются ошибкой.

База данных не обеспечивает согласованность данных между базой данных и внешними данными. Вы, клиент, несете полную ответственность за поддержание согласованности между внешними данными и базой данных

Внешние таблицы не поддерживают операции языка обработки данных (DML). Например, нельзя использовать инструкции Transact-SQL update, insert или delete Transact-SQL для изменения внешних данных.

CREATE TABLE, DROP TABLE, CREATE STATISTICS, DROP STATISTICS, CREATE VIEW и DROP VIEW — это все операции языка описания данных (DDL), которые можно выполнять во внешних таблицах.

Ограничения и ограничения для Azure Synapse Analytics

• В выделенных пулах SQL Azure Synapse Analytics и системе платформы Аналитики PolyBase может использовать не более 33 000 файлов для каждой папки при выполнении 32 одновременных запросов PolyBase. Это максимальное число включает файлы и вложенные папки в каждой папке HDFS. Если степень параллелизма меньше 32, пользователь может выполнять запросы PolyBase к папкам в HDFS, если в них содержится более 33 тысяч файлов. Мы рекомендуем пользователям Hadoop и PolyBase указывать короткие пути к файлам и использовать не более 30 тысяч файлов на папку HDFS. Если указать слишком большое число файлов, может возникнуть исключение, связанное с нехваткой памяти на виртуальной машине Java.

• В бессерверных пулах SQL внешние таблицы нельзя создавать в расположении, где в настоящее время есть данные. Чтобы повторно использовать расположение, которое использовалось для хранения данных, необходимо вручную удалить его в ADLS. Дополнительные ограничения и рекомендации см. в рекомендациях по оптимизации фильтров.

В выделенных пулах SQL Azure Synapse Analytics и системе платформ аналитики при выборе из RCFile значения столбцов в RCFile не должны содержать символ канала (|).

SET ROWCOUNT (Transact-SQL) не влияет на CREATE EXTERNAL TABLE AS SELECT. Чтобы обеспечить аналогичное поведение, воспользуйтесь инструкцией TOP (Transact-SQL).

Ознакомьтесь с ограничениями именования и ссылок на контейнеры, большие двоичные объекты и метаданные для ограничений имен файлов.

Ошибки символов

Следующие символы, присутствующие в данных, могут вызвать ошибки, включая отклонение записей с CREATE EXTERNAL TABLE AS SELECT для файлов Parquet.

В Azure Synapse Analytics и Analytics Platform System это также относится к файлам ORC.

• |
• " (символ кавычки)
• \r\n
• \r
• \n

Чтобы использовать инструкцию CREATE EXTERNAL TABLE AS SELECT с такими символами, сначала выполните эту инструкцию для экспорта данных в текстовые файлы с разделителями, которые затем можно преобразовать в файлы PARQUET или ORC с помощью внешнего инструмента.

Работа с parquet

При работе с файлами CREATE EXTERNAL TABLE AS SELECT parquet создается один файл parquet на доступную ЦП до заданной максимальной степени параллелизма (MAXDOP). Каждый файл может увеличиться до 190 ГБ, после этого SQL Server создаст больше файлов Parquet по мере необходимости.

Указание OPTION (MAXDOP n) запроса влияет только на часть CREATE EXTERNAL TABLE AS SELECTSELECT, она не влияет на объем файлов parquet. Считается, что считается только MAXDOP уровня базы данных и уровня экземпляра MAXDOP.

Блокировка

Принимает общую блокировку на объект SCHEMARESOLUTION.

Поддерживаемые типы данных

CETAS можно использовать для хранения результирующих наборов со следующими типами данных SQL:

• binary
• varbinary
• char
• varchar
• nchar
• nvarchar
• smalldate
• Дата
• datetime
• datetime2
• datetimeoffset
• Время
• десятичное
• numeric
• с плавающей запятой
• real
• bigint
• tinyint
• smallint
• INT
• bigint
• bit
• money
• smallmoney

Примеры

А. Создание таблицы Hadoop с использованием инструкции CREATE EXTERNAL TABLE AS SELECT

Область применения: Azure Synapse Analytics и Analytics Platform System

В следующем примере создается новая внешняя таблица с именем hdfsCustomer. Для этого используются определения столбцов и данные из исходной таблицы dimCustomer.

Определение таблицы хранится в базе данных, а результаты инструкции SELECT экспортируются /pdwdata/customer.tbl в файл во внешнем источнике данных Hadoop customer_ds. Этот файл форматируется в соответствии с форматом внешнего файла customer_ff.

Имя файла создается базой данных и содержит ИД запроса, что позволяет легко сопоставить файл с создавшим его запросом.

Путь hdfs://xxx.xxx.xxx.xxx:5000/files/, предшествующий каталогу "Клиент", должен уже существовать. Если каталог клиента не существует, база данных создает каталог.

Примечание.

В этом примере указано значение 5000. Если порт не задан, база данных использует в качестве порта по умолчанию порт 8020.

Конечное расположение Hadoop и имя файла будут иметь вид hdfs:// xxx.xxx.xxx.xxx:5000/files/Customer/ QueryID_YearMonthDay_HourMinutesSeconds_FileIndex.txt..

-- Example is based on AdventureWorks
CREATE EXTERNAL TABLE hdfsCustomer
    WITH (
            LOCATION = '/pdwdata/customer.tbl',
            DATA_SOURCE = customer_ds,
            FILE_FORMAT = customer_ff
            ) AS

SELECT *
FROM dimCustomer;
GO

B. Использование указания запроса с инструкцией CREATE EXTERNAL TABLE AS SELECT

Область применения: Azure Synapse Analytics и Analytics Platform System

В этом запросе показан базовый синтаксис для указания запроса на соединение с инструкцией CREATE EXTERNAL TABLE AS SELECT. После отправки запроса база данных использует стратегию хэш-соединения для создания плана запроса. Дополнительные сведения об указаниях соединения и использовании предложения OPTION см. в статье Предложение OPTION (Transact-SQL).

Примечание.

В этом примере указано значение 5000. Если порт не задан, база данных использует в качестве порта по умолчанию порт 8020.

-- Example is based on AdventureWorks
CREATE EXTERNAL TABLE dbo.FactInternetSalesNew
    WITH (
            LOCATION = '/files/Customer',
            DATA_SOURCE = customer_ds,
            FILE_FORMAT = customer_ff
            ) AS

SELECT T1.*
FROM dbo.FactInternetSales T1
INNER JOIN dbo.DimCustomer T2
    ON (T1.CustomerKey = T2.CustomerKey)
OPTION (HASH JOIN);
GO

C. Использование инструкции CETAS для изменения атрибутов столбца

Область применения: Azure Synapse Analytics и Analytics Platform System

В этом примере инструкция CETAS используется для изменения типов данных, допустимости значений NULL и параметров сортировки для нескольких столбцов в таблице FactInternetSales.

-- Example is based on AdventureWorks
CREATE EXTERNAL TABLE dbo.FactInternetSalesNew
    WITH (
            LOCATION = '/files/Customer',
            DATA_SOURCE = customer_ds,
            FILE_FORMAT = customer_ff
            ) AS

SELECT T1.ProductKey AS ProductKeyNoChange,
    T1.OrderDateKey AS OrderDate,
    T1.ShipDateKey AS ShipDate,
    T1.CustomerKey AS CustomerKeyNoChange,
    T1.OrderQuantity AS Quantity,
    T1.SalesAmount AS MONEY
FROM dbo.FactInternetSales T1
INNER JOIN dbo.DimCustomer T2
    ON (T1.CustomerKey = T2.CustomerKey)
OPTION (HASH JOIN);
GO

D. Использование инструкции CREATE EXTERNAL TABLE AS SELECT для экспорта данных в качестве файла Parquet

Область применения: SQL Server 2022 (16.x)

В следующем примере создается новая внешняя таблица с именем ext_sales , которая использует данные из таблицы SalesOrderDetail AdventureWorks2022. Необходимо включить параметр конфигурации экспорта polybase.

Результат инструкции SELECT будет сохранен в хранилище объектов, совместимом с S3, ранее настроенным и именованным s3_eds, и соответствующими учетными данными, созданными как s3_dsc. Местом расположения файла Parquet будет <ip>:<port>/cetas/sales.parquet, в котором cetas — ранее созданный сегмент хранилища.

Примечание.

Разностный формат сейчас поддерживается только для чтения.

-- Credential to access the S3-compatible object storage
CREATE DATABASE SCOPED CREDENTIAL s3_dsc
    WITH IDENTITY = 'S3 Access Key',
        SECRET = '<accesskeyid>:<secretkeyid>'
GO

-- S3-compatible object storage data source
CREATE EXTERNAL DATA SOURCE s3_eds
    WITH (
            LOCATION = 's3://<ip>:<port>',
            CREDENTIAL = s3_dsc
            )

-- External File Format for PARQUET
CREATE EXTERNAL FILE FORMAT ParquetFileFormat
    WITH (FORMAT_TYPE = PARQUET);
GO

CREATE EXTERNAL TABLE ext_sales
    WITH (
            LOCATION = '/cetas/sales.parquet',
            DATA_SOURCE = s3_eds,
            FILE_FORMAT = ParquetFileFormat
            ) AS

SELECT *
FROM AdventureWorks2022.[Sales].[SalesOrderDetail];
GO

Е. Использование инструкции CREATE EXTERNAL TABLE AS SELECT из разностной таблицы в Parquet

Область применения: SQL Server 2022 (16.x)

В следующем примере создается новая внешняя таблица с именем Delta_to_Parquet, которая использует тип данных Delta Table, расположенный в хранилище объектов, совместимом с S3, и записывает результат в другой источник данных с именем s3_deltas3_parquet parquet. Для этого в примере используется команда OPENROWSET. Необходимо включить параметр конфигурации экспорта polybase.

-- External File Format for PARQUET
CREATE EXTERNAL FILE FORMAT ParquetFileFormat
    WITH (FORMAT_TYPE = PARQUET);
GO

CREATE EXTERNAL TABLE Delta_to_Parquet
    WITH (
            LOCATION = '/backup/sales.parquet',
            DATA_SOURCE = s3_parquet,
            FILE_FORMAT = ParquetFileFormat
            ) AS

SELECT *
FROM OPENROWSET(BULK '/delta/sales_fy22/', FORMAT = 'DELTA', DATA_SOURCE = 's3_delta') AS [r];
GO

F. Использование CREATE EXTERNAL TABLE AS SELECT с представлением в качестве источника

Область применения: бессерверные пулы SQL Azure Synapse Analytics и выделенные пулы SQL.

В этом примере мы видим пример кода шаблона для написания CETAS с пользовательским представлением в качестве источника, используя управляемое удостоверение в качестве проверки подлинности и wasbs:.

CREATE DATABASE [<mydatabase>];
GO

USE [<mydatabase>];
GO

CREATE MASTER KEY ENCRYPTION BY PASSWORD = '<strong password>';

CREATE DATABASE SCOPED CREDENTIAL [WorkspaceIdentity] WITH IDENTITY = 'managed identity';
GO

CREATE EXTERNAL FILE FORMAT [ParquetFF] WITH (
    FORMAT_TYPE = PARQUET,
    DATA_COMPRESSION = 'org.apache.hadoop.io.compress.SnappyCodec'
);
GO

CREATE EXTERNAL DATA SOURCE [SynapseSQLwriteable] WITH (
    LOCATION = 'wasbs://<mystoageaccount>.dfs.core.windows.net/<mycontainer>/<mybaseoutputfolderpath>',
    CREDENTIAL = [WorkspaceIdentity]
);
GO

CREATE EXTERNAL TABLE [dbo].[<myexternaltable>] WITH (
        LOCATION = '<myoutputsubfolder>/',
        DATA_SOURCE = [SynapseSQLwriteable],
        FILE_FORMAT = [ParquetFF]
) AS
SELECT * FROM [<myview>];
GO

G. Использование CREATE EXTERNAL TABLE AS SELECT с представлением в качестве источника

Область применения: бессерверные пулы SQL Azure Synapse Analytics и выделенные пулы SQL.

В этом примере мы видим пример кода шаблона для написания CETAS с пользовательским представлением в качестве источника, используя управляемое удостоверение в качестве проверки подлинности и https:.

CREATE DATABASE [<mydatabase>];
GO

USE [<mydatabase>];
GO

CREATE MASTER KEY ENCRYPTION BY PASSWORD = '<strong password>';

CREATE DATABASE SCOPED CREDENTIAL [WorkspaceIdentity] WITH IDENTITY = 'managed identity';
GO

CREATE EXTERNAL FILE FORMAT [ParquetFF] WITH (
    FORMAT_TYPE = PARQUET,
    DATA_COMPRESSION = 'org.apache.hadoop.io.compress.SnappyCodec'
);
GO

CREATE EXTERNAL DATA SOURCE [SynapseSQLwriteable] WITH (
    LOCATION = 'https://<mystoageaccount>.dfs.core.windows.net/<mycontainer>/<mybaseoutputfolderpath>',
    CREDENTIAL = [WorkspaceIdentity]
);
GO

CREATE EXTERNAL TABLE [dbo].[<myexternaltable>] WITH (
        LOCATION = '<myoutputsubfolder>/',
        DATA_SOURCE = [SynapseSQLwriteable],
        FILE_FORMAT = [ParquetFF]
) AS
SELECT * FROM [<myview>];
GO

Следующие шаги

• CREATE EXTERNAL DATA SOURCE (Transact-SQL)
• CREATE EXTERNAL FILE FORMAT (Transact-SQL)
• CREATE EXTERNAL TABLE (Transact-SQL)
• CREATE TABLE (Azure Synapse Analytics, Parallel Data Warehouse)
• CREATE TABLE AS SELECT (Azure Synapse Analytics)
• DROP TABLE (Transact-SQL)
• Инструкция ALTER TABLE (Transact-SQL)