SYS.PROJECT.PIPES Preview

The sys.project.pipes table contains the metadata for autoingest pipes in a project.

Syntax

SELECT *
FROM sys.project.pipes

Example Output

org_id	project_id	pipe_name	pipe_id	source_path	target_table	target_branch	dedup_lookback_period	file_format	format_options	pipe_status	error_message	cloud_settings	cloud_cli_command_settings	created_at	last_updated_at	created_by	last_updated_by	created_by_id
c47082e0-830b-4ca8-8d52-b0dd794a5933	5b4b8cdb-a308-4919-aa42-486d4bbcd879	test_pipe	525ffe04-97bb-473e-8e76-fa559faa7d0d	@pipetest/folder	pipe_sink_table	main	20	json	{"DATE_FORMAT":"DD-MM-YYYY","TIME_FORMAT":"HH24:MI:SS"}	Running	empty text	{"eventName":"pipe_5b4b8cdb-a308-4919-ac42-486d4bbcd879_525ffe04-97bb-473e-8e76-fa559faa7d0d","prefix":"ingestionE2E/232","eventTypes":["s3:ObjectCreated:Put","s3:ObjectCreated:Post"],"destination":"arn:aws:sns:us-west-2:1234asad:dremio-69505c78-17f8-456e-ba37-ee72a151fec8"}	aws s3api put-bucket-notification-configuration --bucket tlelek-test-bucket --notification-configuration "$(notification=$(aws s3api get-bucket-notification-configuration --bucket pipetest); if [ -z "$notification" ]; then echo '{"TopicConfigurations": []}'; else echo "$notification"; fi | jq --argjson new_config '{"Id":"pipe_5b4b8cdb-a308-4919-ac42-486d4bbcd879_525ffe04-97bb-473e-8e76-fa559faa7d0d","TopicArn":"arn:aws:sns:us-west-2:1234abc:dremio-69505c78-17f8-456e-ba37-aa72a151fec8","Events":["s3:ObjectCreated:Put","s3:ObjectCreated:Post"],"Filter":{"Key":{"FilterRules":[{"Name":"prefix","Value":"ingestionE2E/232"}]}}}' '.TopicConfigurations += [$new_config]')"	2024-05-20 15:34:18	2024-05-25 5:46:52	user@customer.com	user@customer.com	09ff36d0-0d53-4f87-8a05-0211d9fab76c

Columns

Column	Data Type	Description
org_id	varchar	The unique identifier of the organization in which the autoingest pipe was created.
project_id	varchar	The unique identifier of the project in which the autoingest pipe was created.
pipe_name	varchar	The name of the autoingest pipe.
pipe_id	varchar	The unique identifier of the autoingest pipe.
source_path	varchar	The preconfigured source path specified in the CREATE PIPE statement.
target_table	varchar	The name of the target Iceberg table.
target_branch	varchar	The name of the target branch if Arctic was used as a catalog.
dedup_lookback_period	integer	The number of days that Dremio looks back when comparing newly uploaded files to previously loaded files for file deduplication.
file_format	varchar	The file format associated with the pipe.
format_options	varchar	The specific file format options that are used in the COPY INTO statement when the pipe is triggered.
pipe_status	varchar	The state of the pipe. Enum: Running: The pipe is running as expected. Paused: The pipe exists but loads are not triggered when files are uploaded to the source. Stopped_Missing_Table_or_Branch: Dremio has stopped the pipe because either the target table or target branch does not exist. Stopped_Storage_Location_Altered: Dremio has stopped the pipe because a user has altered the source root path. Stopped_Access_Denied: Dremio has stopped the pipe because Dremio cannot access the source location. Stopped_Missing_Dremio_Source: Dremio has stopped the pipe because the source referenced in the pipe no longer exists. Unhealthy: Autoingestion is failing due to an unknown root cause. Often a transient issue, and the system usually self-corrects and catches up. Stopped_Internal_Error: The pipe is stopped because all pipe jobs failed within 5 days due to an unknown cause.
error_message	varchar	The last error message for a pipe job that did not complete successfully.
cloud_settings	timestamp	The configuration settings for connecting to the cloud environment.
cloud_cli_command_settings	varchar	The command that uses the cloud_settings to set up autoingest pipes in the user's cloud storage location.
created_at	timestamp	The date and time at which the pipe was created.
last_updated_at	timestamp	The date and time of the last modification to the pipe definition.
created_by	varchar	The user who created the pipe.
last_updated_by	varchar	The user who last updated the pipe definition.
created_by_id	varchar	The ID of the user who created the pipe.