Azure Blob Storage is Microsoft’s object storage solution that allows you to store and manage massive amounts of unstructured data.

​
Syntax

CREATE SINK [ IF NOT EXISTS ] sink_name
[FROM sink_from | AS select_query]
WITH (
   connector='azblob',
   connector_parameter = 'value', ...
);

​
Parameters

Parameter namesDescription
azblob.container_nameRequired. The name of the Azure Blob Storage container.
azblob.pathRequired. The directory where the sink file is located.
azblob.credentials.account_nameOptional. The Azure Storage account name for authentication.
azblob.credentials.account_keyOptional. The access key for the Azure Storage account.
azblob.endpoint_urlRequired. The URL endpoint for the Azure Blob Storage service.
typeRequired. Defines the type of the sink. Options include append-only or upsert.

​
Example

CREATE SINK azblob_sink AS SELECT v1
FROM t
WITH (
    connector='azblob',
    azblob.path = 'test_sink/',
    azblob.container_name = '<container_name>',
    azblob.credentials.account_name = '<account_name>',
    azblob.credentials.account_key = '<account_key>',
    azblob.endpoint_url = '<endpoint_url>',
    type = 'append-only',
)FORMAT PLAIN ENCODE PARQUET(force_append_only=true);

​
Advanced topics

For more information about encode Parquet or JSON, see Sink data in parquet or json format.

For more information about batching strategy, see Batching strategy for file sink.

Azure Blob Storage is Microsoft’s object storage solution that allows you to store and manage massive amounts of unstructured data.

​
Syntax

CREATE SINK [ IF NOT EXISTS ] sink_name
[FROM sink_from | AS select_query]
WITH (
   connector='azblob',
   connector_parameter = 'value', ...
);

​
Parameters

Parameter namesDescription
azblob.container_nameRequired. The name of the Azure Blob Storage container.
azblob.pathRequired. The directory where the sink file is located.
azblob.credentials.account_nameOptional. The Azure Storage account name for authentication.
azblob.credentials.account_keyOptional. The access key for the Azure Storage account.
azblob.endpoint_urlRequired. The URL endpoint for the Azure Blob Storage service.
typeRequired. Defines the type of the sink. Options include append-only or upsert.

​
Example

CREATE SINK azblob_sink AS SELECT v1
FROM t
WITH (
    connector='azblob',
    azblob.path = 'test_sink/',
    azblob.container_name = '<container_name>',
    azblob.credentials.account_name = '<account_name>',
    azblob.credentials.account_key = '<account_key>',
    azblob.endpoint_url = '<endpoint_url>',
    type = 'append-only',
)FORMAT PLAIN ENCODE PARQUET(force_append_only=true);

​
Advanced topics

For more information about encode Parquet or JSON, see Sink data in parquet or json format.

For more information about batching strategy, see Batching strategy for file sink.