API Reference

Copy Markdown

Open in Claude

Open in ChatGPT

Open in Cursor

---

Copy Markdown

View as Markdown

Pipelines

[DEPRECATED] List Pipelines

Deprecated

GET/accounts/{account_id}/pipelines

[DEPRECATED] Get Pipeline

Deprecated

GET/accounts/{account_id}/pipelines/{pipeline_name}

[DEPRECATED] Create Pipeline

Deprecated

POST/accounts/{account_id}/pipelines

[DEPRECATED] Update Pipeline

Deprecated

PUT/accounts/{account_id}/pipelines/{pipeline_name}

[DEPRECATED] Delete Pipeline

Deprecated

DELETE/accounts/{account_id}/pipelines/{pipeline_name}

List Pipelines

GET/accounts/{account_id}/pipelines/v1/pipelines

Get Pipeline Details

GET/accounts/{account_id}/pipelines/v1/pipelines/{pipeline_id}

Create Pipeline

POST/accounts/{account_id}/pipelines/v1/pipelines

Delete Pipelines

DELETE/accounts/{account_id}/pipelines/v1/pipelines/{pipeline_id}

Validate SQL

POST/accounts/{account_id}/pipelines/v1/validate_sql

ModelsExpand Collapse

PipelineListResponse { result_info, results, success }

result_info: { count, page, per_page, total_count }

count: number

Indicates the number of items on current page.

page: number

Indicates the current page number.

per_page: number

Indicates the number of items per page.

total_count: number

Indicates the total number of items.

results: array of { id, destination, endpoint, 3 more }

id: string

Specifies the pipeline identifier.

destination: { batch, compression, format, 2 more }

batch: { max_bytes, max_duration_s, max_rows }

max_bytes: number

Specifies rough maximum size of files.

maximum100000000

minimum1000

max_duration_s: number

Specifies duration to wait to aggregate batches files.

maximum300

minimum0.25

max_rows: number

Specifies rough maximum number of rows per file.

maximum10000000

minimum100

compression: { type }

type: "none" or "gzip" or "deflate"

Specifies the desired compression algorithm and format.

One of the following:

"none"

"gzip"

"deflate"

format: "json"

Specifies the format of data to deliver.

path: { bucket, filename, filepath, prefix }

bucket: string

Specifies the R2 Bucket to store files.

filename: optional string

Specifies the name pattern to for individual data files.

filepath: optional string

Specifies the name pattern for directory.

prefix: optional string

Specifies the base directory within the bucket.

type: "r2"

Specifies the type of destination.

endpoint: string

Indicates the endpoint URL to send traffic.

name: string

Defines the name of the pipeline.

maxLength128

minLength1

source: array of { format, type, authentication, cors } or { format, type }

One of the following:

CloudflarePipelinesWorkersPipelinesHTTPSource { format, type, authentication, cors }

[DEPRECATED] HTTP source configuration. Use the new streams API instead.

format: "json"

Specifies the format of source data.

type: string

authentication: optional boolean

Specifies whether authentication is required to send to this pipeline via HTTP.

cors: optional { origins }

origins: optional array of string

Specifies allowed origins to allow Cross Origin HTTP Requests.

CloudflarePipelinesWorkersPipelinesBindingSource { format, type }

[DEPRECATED] Worker binding source configuration. Use the new streams API instead.

format: "json"

Specifies the format of source data.

type: string

version: number

Indicates the version number of last saved configuration.

success: boolean

Indicates whether the API call was successful.

PipelineGetResponse { id, destination, endpoint, 3 more }

[DEPRECATED] Describes the configuration of a pipeline. Use the new streams/sinks/pipelines API instead.

id: string

Specifies the pipeline identifier.

destination: { batch, compression, format, 2 more }

batch: { max_bytes, max_duration_s, max_rows }

max_bytes: number

Specifies rough maximum size of files.

maximum100000000

minimum1000

max_duration_s: number

Specifies duration to wait to aggregate batches files.

maximum300

minimum0.25

max_rows: number

Specifies rough maximum number of rows per file.

maximum10000000

minimum100

compression: { type }

type: "none" or "gzip" or "deflate"

Specifies the desired compression algorithm and format.

One of the following:

"none"

"gzip"

"deflate"

format: "json"

Specifies the format of data to deliver.

path: { bucket, filename, filepath, prefix }

bucket: string

Specifies the R2 Bucket to store files.

filename: optional string

Specifies the name pattern to for individual data files.

filepath: optional string

Specifies the name pattern for directory.

prefix: optional string

Specifies the base directory within the bucket.

type: "r2"

Specifies the type of destination.

endpoint: string

Indicates the endpoint URL to send traffic.

name: string

Defines the name of the pipeline.

maxLength128

minLength1

source: array of { format, type, authentication, cors } or { format, type }

One of the following:

CloudflarePipelinesWorkersPipelinesHTTPSource { format, type, authentication, cors }

[DEPRECATED] HTTP source configuration. Use the new streams API instead.

format: "json"

Specifies the format of source data.

type: string

authentication: optional boolean

Specifies whether authentication is required to send to this pipeline via HTTP.

cors: optional { origins }

origins: optional array of string

Specifies allowed origins to allow Cross Origin HTTP Requests.

CloudflarePipelinesWorkersPipelinesBindingSource { format, type }

[DEPRECATED] Worker binding source configuration. Use the new streams API instead.

format: "json"

Specifies the format of source data.

type: string

version: number

Indicates the version number of last saved configuration.

PipelineCreateResponse { id, destination, endpoint, 3 more }

[DEPRECATED] Describes the configuration of a pipeline. Use the new streams/sinks/pipelines API instead.

id: string

Specifies the pipeline identifier.

destination: { batch, compression, format, 2 more }

batch: { max_bytes, max_duration_s, max_rows }

max_bytes: number

Specifies rough maximum size of files.

maximum100000000

minimum1000

max_duration_s: number

Specifies duration to wait to aggregate batches files.

maximum300

minimum0.25

max_rows: number

Specifies rough maximum number of rows per file.

maximum10000000

minimum100

compression: { type }

type: "none" or "gzip" or "deflate"

Specifies the desired compression algorithm and format.

One of the following:

"none"

"gzip"

"deflate"

format: "json"

Specifies the format of data to deliver.

path: { bucket, filename, filepath, prefix }

bucket: string

Specifies the R2 Bucket to store files.

filename: optional string

Specifies the name pattern to for individual data files.

filepath: optional string

Specifies the name pattern for directory.

prefix: optional string

Specifies the base directory within the bucket.

type: "r2"

Specifies the type of destination.

endpoint: string

Indicates the endpoint URL to send traffic.

name: string

Defines the name of the pipeline.

maxLength128

minLength1

source: array of { format, type, authentication, cors } or { format, type }

One of the following:

CloudflarePipelinesWorkersPipelinesHTTPSource { format, type, authentication, cors }

[DEPRECATED] HTTP source configuration. Use the new streams API instead.

format: "json"

Specifies the format of source data.

type: string

authentication: optional boolean

Specifies whether authentication is required to send to this pipeline via HTTP.

cors: optional { origins }

origins: optional array of string

Specifies allowed origins to allow Cross Origin HTTP Requests.

CloudflarePipelinesWorkersPipelinesBindingSource { format, type }

[DEPRECATED] Worker binding source configuration. Use the new streams API instead.

format: "json"

Specifies the format of source data.

type: string

version: number

Indicates the version number of last saved configuration.

PipelineUpdateResponse { id, destination, endpoint, 3 more }

[DEPRECATED] Describes the configuration of a pipeline. Use the new streams/sinks/pipelines API instead.

id: string

Specifies the pipeline identifier.

destination: { batch, compression, format, 2 more }

batch: { max_bytes, max_duration_s, max_rows }

max_bytes: number

Specifies rough maximum size of files.

maximum100000000

minimum1000

max_duration_s: number

Specifies duration to wait to aggregate batches files.

maximum300

minimum0.25

max_rows: number

Specifies rough maximum number of rows per file.

maximum10000000

minimum100

compression: { type }

type: "none" or "gzip" or "deflate"

Specifies the desired compression algorithm and format.

One of the following:

"none"

"gzip"

"deflate"

format: "json"

Specifies the format of data to deliver.

path: { bucket, filename, filepath, prefix }

bucket: string

Specifies the R2 Bucket to store files.

filename: optional string

Specifies the name pattern to for individual data files.

filepath: optional string

Specifies the name pattern for directory.

prefix: optional string

Specifies the base directory within the bucket.

type: "r2"

Specifies the type of destination.

endpoint: string

Indicates the endpoint URL to send traffic.

name: string

Defines the name of the pipeline.

maxLength128

minLength1

source: array of { format, type, authentication, cors } or { format, type }

One of the following:

CloudflarePipelinesWorkersPipelinesHTTPSource { format, type, authentication, cors }

[DEPRECATED] HTTP source configuration. Use the new streams API instead.

format: "json"

Specifies the format of source data.

type: string

authentication: optional boolean

Specifies whether authentication is required to send to this pipeline via HTTP.

cors: optional { origins }

origins: optional array of string

Specifies allowed origins to allow Cross Origin HTTP Requests.

CloudflarePipelinesWorkersPipelinesBindingSource { format, type }

[DEPRECATED] Worker binding source configuration. Use the new streams API instead.

format: "json"

Specifies the format of source data.

type: string

version: number

Indicates the version number of last saved configuration.

PipelineListV1Response { id, created_at, modified_at, 3 more }

id: string

Indicates a unique identifier for this pipeline.

created_at: string

modified_at: string

name: string

Indicates the name of the Pipeline.

maxLength128

minLength1

sql: string

Specifies SQL for the Pipeline processing flow.

status: string

Indicates the current status of the Pipeline.

PipelineGetV1Response { id, created_at, modified_at, 5 more }

id: string

Indicates a unique identifier for this pipeline.

created_at: string

modified_at: string

name: string

Indicates the name of the Pipeline.

maxLength128

minLength1

sql: string

Specifies SQL for the Pipeline processing flow.

status: string

Indicates the current status of the Pipeline.

tables: array of { id, latest, name, 2 more }

List of streams and sinks used by this pipeline.

id: string

Unique identifier for the connection (stream or sink).

latest: number

Latest available version of the connection.

name: string

Name of the connection.

maxLength128

minLength1

type: "stream" or "sink"

Type of the connection.

One of the following:

"stream"

"sink"

version: number

Current version of the connection used by this pipeline.

failure_reason: optional string

Indicates the reason for the failure of the Pipeline.

PipelineCreateV1Response { id, created_at, modified_at, 3 more }

id: string

Indicates a unique identifier for this pipeline.

created_at: string

modified_at: string

name: string

Indicates the name of the Pipeline.

maxLength128

minLength1

sql: string

Specifies SQL for the Pipeline processing flow.

status: string

Indicates the current status of the Pipeline.

PipelineValidateSqlResponse { tables, graph }

tables: map[ { id, name, type, version } ]

Indicates tables involved in the processing.

id: string

name: string

type: string

version: number

graph: optional { edges, nodes }

edges: array of { dest_id, edge_type, key_type, 2 more }

dest_id: number

formatint32

minimum0

edge_type: string

key_type: string

src_id: number

formatint32

minimum0

value_type: string

nodes: array of { description, node_id, operator, parallelism }

description: string

node_id: number

formatint32

minimum0

operator: string

parallelism: number

formatint32

minimum0

PipelinesSinks

List Sinks

GET/accounts/{account_id}/pipelines/v1/sinks

Get Sink Details

GET/accounts/{account_id}/pipelines/v1/sinks/{sink_id}

Create Sink

POST/accounts/{account_id}/pipelines/v1/sinks

Delete Sink

DELETE/accounts/{account_id}/pipelines/v1/sinks/{sink_id}

ModelsExpand Collapse

SinkListResponse { id, created_at, modified_at, 5 more }

id: string

Indicates a unique identifier for this sink.

created_at: string

formatdate-time

modified_at: string

formatdate-time

name: string

Defines the name of the Sink.

maxLength128

minLength1

type: "r2" or "r2_data_catalog"

Specifies the type of sink.

One of the following:

"r2"

"r2_data_catalog"

config: optional { account_id, bucket, file_naming, 4 more } or { account_id, bucket, table_name, 2 more }

Defines the configuration of the R2 Sink.

One of the following:

CloudflarePipelinesR2TablePublic { account_id, bucket, file_naming, 4 more }

R2 Sink public configuration.

account_id: string

Cloudflare Account ID for the bucket

bucket: string

R2 Bucket to write to

file_naming: optional { prefix, strategy, suffix }

Controls filename prefix/suffix and strategy.

prefix: optional string

The prefix to use in file name. i.e prefix-.parquet

strategy: optional "serial" or "uuid" or "uuid_v7" or "ulid"

Filename generation strategy.

One of the following:

"serial"

"uuid"

"uuid_v7"

"ulid"

suffix: optional string

This will overwrite the default file suffix. i.e .parquet, use with caution

jurisdiction: optional string

Jurisdiction this bucket is hosted in

partitioning: optional { time_pattern }

Data-layout partitioning for sinks.

time_pattern: optional string

The pattern of the date string

path: optional string

Subpath within the bucket to write to

rolling_policy: optional { file_size_bytes, inactivity_seconds, interval_seconds }

Rolling policy for file sinks (when & why to close a file and open a new one).

file_size_bytes: optional number

Files will be rolled after reaching this number of bytes

formatuint64

minimum0

inactivity_seconds: optional number

Number of seconds of inactivity to wait before rolling over to a new file

formatuint64

minimum1

interval_seconds: optional number

Number of seconds to wait before rolling over to a new file

formatuint64

minimum1

CloudflarePipelinesR2DataCatalogTablePublic { account_id, bucket, table_name, 2 more }

R2 Data Catalog Sink public configuration.

account_id: string

Cloudflare Account ID

formaturi

bucket: string

The R2 Bucket that hosts this catalog

table_name: string

Table name

namespace: optional string

Table namespace

rolling_policy: optional { file_size_bytes, inactivity_seconds, interval_seconds }

Rolling policy for file sinks (when & why to close a file and open a new one).

file_size_bytes: optional number

Files will be rolled after reaching this number of bytes

formatuint64

minimum0

inactivity_seconds: optional number

Number of seconds of inactivity to wait before rolling over to a new file

formatuint64

minimum1

interval_seconds: optional number

Number of seconds to wait before rolling over to a new file

formatuint64

minimum1

format: optional { type, decimal_encoding, timestamp_format, unstructured } or { type, compression, row_group_bytes }

One of the following:

Json { type, decimal_encoding, timestamp_format, unstructured }

type: "json"

decimal_encoding: optional "number" or "string" or "bytes"

One of the following:

"number"

"string"

"bytes"

timestamp_format: optional "rfc3339" or "unix_millis"

One of the following:

"rfc3339"

"unix_millis"

unstructured: optional boolean

Parquet { type, compression, row_group_bytes }

type: "parquet"

compression: optional "uncompressed" or "snappy" or "gzip" or 2 more

One of the following:

"uncompressed"

"snappy"

"gzip"

"zstd"

"lz4"

row_group_bytes: optional number

formatint64

minimum0

schema: optional { fields, format, inferred }

fields: optional array of { type, metadata_key, name, 2 more } or { type, metadata_key, name, 2 more } or { type, metadata_key, name, 2 more } or 8 more

One of the following:

Int32 { type, metadata_key, name, 2 more }

type: "int32"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Int64 { type, metadata_key, name, 2 more }

type: "int64"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Float32 { type, metadata_key, name, 2 more }

type: "float32"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Float64 { type, metadata_key, name, 2 more }

type: "float64"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Bool { type, metadata_key, name, 2 more }

type: "bool"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

String { type, metadata_key, name, 2 more }

type: "string"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Binary { type, metadata_key, name, 2 more }

type: "binary"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Timestamp { type, metadata_key, name, 3 more }

type: "timestamp"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

unit: optional "second" or "millisecond" or "microsecond" or "nanosecond"

One of the following:

"second"

"millisecond"

"microsecond"

"nanosecond"

Json { type, metadata_key, name, 2 more }

type: "json"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Struct =

List =

format: optional { type, decimal_encoding, timestamp_format, unstructured } or { type, compression, row_group_bytes }

One of the following:

Json { type, decimal_encoding, timestamp_format, unstructured }

type: "json"

decimal_encoding: optional "number" or "string" or "bytes"

One of the following:

"number"

"string"

"bytes"

timestamp_format: optional "rfc3339" or "unix_millis"

One of the following:

"rfc3339"

"unix_millis"

unstructured: optional boolean

Parquet { type, compression, row_group_bytes }

type: "parquet"

compression: optional "uncompressed" or "snappy" or "gzip" or 2 more

One of the following:

"uncompressed"

"snappy"

"gzip"

"zstd"

"lz4"

row_group_bytes: optional number

formatint64

minimum0

inferred: optional boolean

SinkGetResponse { id, created_at, modified_at, 5 more }

id: string

Indicates a unique identifier for this sink.

created_at: string

formatdate-time

modified_at: string

formatdate-time

name: string

Defines the name of the Sink.

maxLength128

minLength1

type: "r2" or "r2_data_catalog"

Specifies the type of sink.

One of the following:

"r2"

"r2_data_catalog"

config: optional { account_id, bucket, file_naming, 4 more } or { account_id, bucket, table_name, 2 more }

Defines the configuration of the R2 Sink.

One of the following:

CloudflarePipelinesR2TablePublic { account_id, bucket, file_naming, 4 more }

R2 Sink public configuration.

account_id: string

Cloudflare Account ID for the bucket

bucket: string

R2 Bucket to write to

file_naming: optional { prefix, strategy, suffix }

Controls filename prefix/suffix and strategy.

prefix: optional string

The prefix to use in file name. i.e prefix-.parquet

strategy: optional "serial" or "uuid" or "uuid_v7" or "ulid"

Filename generation strategy.

One of the following:

"serial"

"uuid"

"uuid_v7"

"ulid"

suffix: optional string

This will overwrite the default file suffix. i.e .parquet, use with caution

jurisdiction: optional string

Jurisdiction this bucket is hosted in

partitioning: optional { time_pattern }

Data-layout partitioning for sinks.

time_pattern: optional string

The pattern of the date string

path: optional string

Subpath within the bucket to write to

rolling_policy: optional { file_size_bytes, inactivity_seconds, interval_seconds }

Rolling policy for file sinks (when & why to close a file and open a new one).

file_size_bytes: optional number

Files will be rolled after reaching this number of bytes

formatuint64

minimum0

inactivity_seconds: optional number

Number of seconds of inactivity to wait before rolling over to a new file

formatuint64

minimum1

interval_seconds: optional number

Number of seconds to wait before rolling over to a new file

formatuint64

minimum1

CloudflarePipelinesR2DataCatalogTablePublic { account_id, bucket, table_name, 2 more }

R2 Data Catalog Sink public configuration.

account_id: string

Cloudflare Account ID

formaturi

bucket: string

The R2 Bucket that hosts this catalog

table_name: string

Table name

namespace: optional string

Table namespace

rolling_policy: optional { file_size_bytes, inactivity_seconds, interval_seconds }

Rolling policy for file sinks (when & why to close a file and open a new one).

file_size_bytes: optional number

Files will be rolled after reaching this number of bytes

formatuint64

minimum0

inactivity_seconds: optional number

Number of seconds of inactivity to wait before rolling over to a new file

formatuint64

minimum1

interval_seconds: optional number

Number of seconds to wait before rolling over to a new file

formatuint64

minimum1

format: optional { type, decimal_encoding, timestamp_format, unstructured } or { type, compression, row_group_bytes }

One of the following:

Json { type, decimal_encoding, timestamp_format, unstructured }

type: "json"

decimal_encoding: optional "number" or "string" or "bytes"

One of the following:

"number"

"string"

"bytes"

timestamp_format: optional "rfc3339" or "unix_millis"

One of the following:

"rfc3339"

"unix_millis"

unstructured: optional boolean

Parquet { type, compression, row_group_bytes }

type: "parquet"

compression: optional "uncompressed" or "snappy" or "gzip" or 2 more

One of the following:

"uncompressed"

"snappy"

"gzip"

"zstd"

"lz4"

row_group_bytes: optional number

formatint64

minimum0

schema: optional { fields, format, inferred }

fields: optional array of { type, metadata_key, name, 2 more } or { type, metadata_key, name, 2 more } or { type, metadata_key, name, 2 more } or 8 more

One of the following:

Int32 { type, metadata_key, name, 2 more }

type: "int32"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Int64 { type, metadata_key, name, 2 more }

type: "int64"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Float32 { type, metadata_key, name, 2 more }

type: "float32"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Float64 { type, metadata_key, name, 2 more }

type: "float64"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Bool { type, metadata_key, name, 2 more }

type: "bool"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

String { type, metadata_key, name, 2 more }

type: "string"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Binary { type, metadata_key, name, 2 more }

type: "binary"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Timestamp { type, metadata_key, name, 3 more }

type: "timestamp"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

unit: optional "second" or "millisecond" or "microsecond" or "nanosecond"

One of the following:

"second"

"millisecond"

"microsecond"

"nanosecond"

Json { type, metadata_key, name, 2 more }

type: "json"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Struct =

List =

format: optional { type, decimal_encoding, timestamp_format, unstructured } or { type, compression, row_group_bytes }

One of the following:

Json { type, decimal_encoding, timestamp_format, unstructured }

type: "json"

decimal_encoding: optional "number" or "string" or "bytes"

One of the following:

"number"

"string"

"bytes"

timestamp_format: optional "rfc3339" or "unix_millis"

One of the following:

"rfc3339"

"unix_millis"

unstructured: optional boolean

Parquet { type, compression, row_group_bytes }

type: "parquet"

compression: optional "uncompressed" or "snappy" or "gzip" or 2 more

One of the following:

"uncompressed"

"snappy"

"gzip"

"zstd"

"lz4"

row_group_bytes: optional number

formatint64

minimum0

inferred: optional boolean

SinkCreateResponse { id, created_at, modified_at, 5 more }

id: string

Indicates a unique identifier for this sink.

created_at: string

formatdate-time

modified_at: string

formatdate-time

name: string

Defines the name of the Sink.

maxLength128

minLength1

type: "r2" or "r2_data_catalog"

Specifies the type of sink.

One of the following:

"r2"

"r2_data_catalog"

config: optional { account_id, bucket, credentials, 5 more } or { token, account_id, bucket, 3 more }

R2 Data Catalog Sink

One of the following:

CloudflarePipelinesR2Table { account_id, bucket, credentials, 5 more }

account_id: string

Cloudflare Account ID for the bucket

bucket: string

R2 Bucket to write to

credentials: { access_key_id, secret_access_key }

access_key_id: string

Cloudflare Account ID for the bucket

formatvar-str

secret_access_key: string

Cloudflare Account ID for the bucket

formatvar-str

file_naming: optional { prefix, strategy, suffix }

Controls filename prefix/suffix and strategy.

prefix: optional string

The prefix to use in file name. i.e prefix-.parquet

strategy: optional "serial" or "uuid" or "uuid_v7" or "ulid"

Filename generation strategy.

One of the following:

"serial"

"uuid"

"uuid_v7"

"ulid"

suffix: optional string

This will overwrite the default file suffix. i.e .parquet, use with caution

jurisdiction: optional string

Jurisdiction this bucket is hosted in

partitioning: optional { time_pattern }

Data-layout partitioning for sinks.

time_pattern: optional string

The pattern of the date string

path: optional string

Subpath within the bucket to write to

rolling_policy: optional { file_size_bytes, inactivity_seconds, interval_seconds }

Rolling policy for file sinks (when & why to close a file and open a new one).

file_size_bytes: optional number

Files will be rolled after reaching this number of bytes

formatuint64

minimum0

inactivity_seconds: optional number

Number of seconds of inactivity to wait before rolling over to a new file

formatuint64

minimum1

interval_seconds: optional number

Number of seconds to wait before rolling over to a new file

formatuint64

minimum1

CloudflarePipelinesR2DataCatalogTable { token, account_id, bucket, 3 more }

R2 Data Catalog Sink

token: string

Authentication token

formatvar-str

account_id: string

Cloudflare Account ID

formaturi

bucket: string

The R2 Bucket that hosts this catalog

table_name: string

Table name

namespace: optional string

Table namespace

rolling_policy: optional { file_size_bytes, inactivity_seconds, interval_seconds }

Rolling policy for file sinks (when & why to close a file and open a new one).

file_size_bytes: optional number

Files will be rolled after reaching this number of bytes

formatuint64

minimum0

inactivity_seconds: optional number

Number of seconds of inactivity to wait before rolling over to a new file

formatuint64

minimum1

interval_seconds: optional number

Number of seconds to wait before rolling over to a new file

formatuint64

minimum1

format: optional { type, decimal_encoding, timestamp_format, unstructured } or { type, compression, row_group_bytes }

One of the following:

Json { type, decimal_encoding, timestamp_format, unstructured }

type: "json"

decimal_encoding: optional "number" or "string" or "bytes"

One of the following:

"number"

"string"

"bytes"

timestamp_format: optional "rfc3339" or "unix_millis"

One of the following:

"rfc3339"

"unix_millis"

unstructured: optional boolean

Parquet { type, compression, row_group_bytes }

type: "parquet"

compression: optional "uncompressed" or "snappy" or "gzip" or 2 more

One of the following:

"uncompressed"

"snappy"

"gzip"

"zstd"

"lz4"

row_group_bytes: optional number

formatint64

minimum0

schema: optional { fields, format, inferred }

fields: optional array of { type, metadata_key, name, 2 more } or { type, metadata_key, name, 2 more } or { type, metadata_key, name, 2 more } or 8 more

One of the following:

Int32 { type, metadata_key, name, 2 more }

type: "int32"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Int64 { type, metadata_key, name, 2 more }

type: "int64"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Float32 { type, metadata_key, name, 2 more }

type: "float32"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Float64 { type, metadata_key, name, 2 more }

type: "float64"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Bool { type, metadata_key, name, 2 more }

type: "bool"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

String { type, metadata_key, name, 2 more }

type: "string"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Binary { type, metadata_key, name, 2 more }

type: "binary"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Timestamp { type, metadata_key, name, 3 more }

type: "timestamp"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

unit: optional "second" or "millisecond" or "microsecond" or "nanosecond"

One of the following:

"second"

"millisecond"

"microsecond"

"nanosecond"

Json { type, metadata_key, name, 2 more }

type: "json"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Struct =

List =

format: optional { type, decimal_encoding, timestamp_format, unstructured } or { type, compression, row_group_bytes }

One of the following:

Json { type, decimal_encoding, timestamp_format, unstructured }

type: "json"

decimal_encoding: optional "number" or "string" or "bytes"

One of the following:

"number"

"string"

"bytes"

timestamp_format: optional "rfc3339" or "unix_millis"

One of the following:

"rfc3339"

"unix_millis"

unstructured: optional boolean

Parquet { type, compression, row_group_bytes }

type: "parquet"

compression: optional "uncompressed" or "snappy" or "gzip" or 2 more

One of the following:

"uncompressed"

"snappy"

"gzip"

"zstd"

"lz4"

row_group_bytes: optional number

formatint64

minimum0

inferred: optional boolean

PipelinesStreams

List Streams

GET/accounts/{account_id}/pipelines/v1/streams

Get Stream Details

GET/accounts/{account_id}/pipelines/v1/streams/{stream_id}

Create Stream

POST/accounts/{account_id}/pipelines/v1/streams

Update Stream

PATCH/accounts/{account_id}/pipelines/v1/streams/{stream_id}

Delete Stream

DELETE/accounts/{account_id}/pipelines/v1/streams/{stream_id}

ModelsExpand Collapse

StreamListResponse { id, created_at, http, 7 more }

id: string

Indicates a unique identifier for this stream.

created_at: string

formatdate-time

http: { authentication, enabled, cors }

authentication: boolean

Indicates that authentication is required for the HTTP endpoint.

enabled: boolean

Indicates that the HTTP endpoint is enabled.

cors: optional { origins }

Specifies the CORS options for the HTTP endpoint.

origins: optional array of string

modified_at: string

formatdate-time

name: string

Indicates the name of the Stream.

maxLength128

minLength1

version: number

Indicates the current version of this stream.

worker_binding: { enabled }

enabled: boolean

Indicates that the worker binding is enabled.

endpoint: optional string

Indicates the endpoint URL of this stream.

formaturi

format: optional { type, decimal_encoding, timestamp_format, unstructured } or { type, compression, row_group_bytes }

One of the following:

Json { type, decimal_encoding, timestamp_format, unstructured }

type: "json"

decimal_encoding: optional "number" or "string" or "bytes"

One of the following:

"number"

"string"

"bytes"

timestamp_format: optional "rfc3339" or "unix_millis"

One of the following:

"rfc3339"

"unix_millis"

unstructured: optional boolean

Parquet { type, compression, row_group_bytes }

type: "parquet"

compression: optional "uncompressed" or "snappy" or "gzip" or 2 more

One of the following:

"uncompressed"

"snappy"

"gzip"

"zstd"

"lz4"

row_group_bytes: optional number

formatint64

minimum0

schema: optional { fields, format, inferred }

fields: optional array of { type, metadata_key, name, 2 more } or { type, metadata_key, name, 2 more } or { type, metadata_key, name, 2 more } or 8 more

One of the following:

Int32 { type, metadata_key, name, 2 more }

type: "int32"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Int64 { type, metadata_key, name, 2 more }

type: "int64"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Float32 { type, metadata_key, name, 2 more }

type: "float32"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Float64 { type, metadata_key, name, 2 more }

type: "float64"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Bool { type, metadata_key, name, 2 more }

type: "bool"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

String { type, metadata_key, name, 2 more }

type: "string"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Binary { type, metadata_key, name, 2 more }

type: "binary"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Timestamp { type, metadata_key, name, 3 more }

type: "timestamp"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

unit: optional "second" or "millisecond" or "microsecond" or "nanosecond"

One of the following:

"second"

"millisecond"

"microsecond"

"nanosecond"

Json { type, metadata_key, name, 2 more }

type: "json"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Struct =

List =

format: optional { type, decimal_encoding, timestamp_format, unstructured } or { type, compression, row_group_bytes }

One of the following:

Json { type, decimal_encoding, timestamp_format, unstructured }

type: "json"

decimal_encoding: optional "number" or "string" or "bytes"

One of the following:

"number"

"string"

"bytes"

timestamp_format: optional "rfc3339" or "unix_millis"

One of the following:

"rfc3339"

"unix_millis"

unstructured: optional boolean

Parquet { type, compression, row_group_bytes }

type: "parquet"

compression: optional "uncompressed" or "snappy" or "gzip" or 2 more

One of the following:

"uncompressed"

"snappy"

"gzip"

"zstd"

"lz4"

row_group_bytes: optional number

formatint64

minimum0

inferred: optional boolean

StreamGetResponse { id, created_at, http, 7 more }

id: string

Indicates a unique identifier for this stream.

created_at: string

formatdate-time

http: { authentication, enabled, cors }

authentication: boolean

Indicates that authentication is required for the HTTP endpoint.

enabled: boolean

Indicates that the HTTP endpoint is enabled.

cors: optional { origins }

Specifies the CORS options for the HTTP endpoint.

origins: optional array of string

modified_at: string

formatdate-time

name: string

Indicates the name of the Stream.

maxLength128

minLength1

version: number

Indicates the current version of this stream.

worker_binding: { enabled }

enabled: boolean

Indicates that the worker binding is enabled.

endpoint: optional string

Indicates the endpoint URL of this stream.

formaturi

format: optional { type, decimal_encoding, timestamp_format, unstructured } or { type, compression, row_group_bytes }

One of the following:

Json { type, decimal_encoding, timestamp_format, unstructured }

type: "json"

decimal_encoding: optional "number" or "string" or "bytes"

One of the following:

"number"

"string"

"bytes"

timestamp_format: optional "rfc3339" or "unix_millis"

One of the following:

"rfc3339"

"unix_millis"

unstructured: optional boolean

Parquet { type, compression, row_group_bytes }

type: "parquet"

compression: optional "uncompressed" or "snappy" or "gzip" or 2 more

One of the following:

"uncompressed"

"snappy"

"gzip"

"zstd"

"lz4"

row_group_bytes: optional number

formatint64

minimum0

schema: optional { fields, format, inferred }

fields: optional array of { type, metadata_key, name, 2 more } or { type, metadata_key, name, 2 more } or { type, metadata_key, name, 2 more } or 8 more

One of the following:

Int32 { type, metadata_key, name, 2 more }

type: "int32"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Int64 { type, metadata_key, name, 2 more }

type: "int64"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Float32 { type, metadata_key, name, 2 more }

type: "float32"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Float64 { type, metadata_key, name, 2 more }

type: "float64"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Bool { type, metadata_key, name, 2 more }

type: "bool"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

String { type, metadata_key, name, 2 more }

type: "string"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Binary { type, metadata_key, name, 2 more }

type: "binary"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Timestamp { type, metadata_key, name, 3 more }

type: "timestamp"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

unit: optional "second" or "millisecond" or "microsecond" or "nanosecond"

One of the following:

"second"

"millisecond"

"microsecond"

"nanosecond"

Json { type, metadata_key, name, 2 more }

type: "json"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Struct =

List =

format: optional { type, decimal_encoding, timestamp_format, unstructured } or { type, compression, row_group_bytes }

One of the following:

Json { type, decimal_encoding, timestamp_format, unstructured }

type: "json"

decimal_encoding: optional "number" or "string" or "bytes"

One of the following:

"number"

"string"

"bytes"

timestamp_format: optional "rfc3339" or "unix_millis"

One of the following:

"rfc3339"

"unix_millis"

unstructured: optional boolean

Parquet { type, compression, row_group_bytes }

type: "parquet"

compression: optional "uncompressed" or "snappy" or "gzip" or 2 more

One of the following:

"uncompressed"

"snappy"

"gzip"

"zstd"

"lz4"

row_group_bytes: optional number

formatint64

minimum0

inferred: optional boolean

StreamCreateResponse { id, created_at, http, 7 more }

id: string

Indicates a unique identifier for this stream.

created_at: string

formatdate-time

http: { authentication, enabled, cors }

authentication: boolean

Indicates that authentication is required for the HTTP endpoint.

enabled: boolean

Indicates that the HTTP endpoint is enabled.

cors: optional { origins }

Specifies the CORS options for the HTTP endpoint.

origins: optional array of string

modified_at: string

formatdate-time

name: string

Indicates the name of the Stream.

maxLength128

minLength1

version: number

Indicates the current version of this stream.

worker_binding: { enabled }

enabled: boolean

Indicates that the worker binding is enabled.

endpoint: optional string

Indicates the endpoint URL of this stream.

formaturi

format: optional { type, decimal_encoding, timestamp_format, unstructured } or { type, compression, row_group_bytes }

One of the following:

Json { type, decimal_encoding, timestamp_format, unstructured }

type: "json"

decimal_encoding: optional "number" or "string" or "bytes"

One of the following:

"number"

"string"

"bytes"

timestamp_format: optional "rfc3339" or "unix_millis"

One of the following:

"rfc3339"

"unix_millis"

unstructured: optional boolean

Parquet { type, compression, row_group_bytes }

type: "parquet"

compression: optional "uncompressed" or "snappy" or "gzip" or 2 more

One of the following:

"uncompressed"

"snappy"

"gzip"

"zstd"

"lz4"

row_group_bytes: optional number

formatint64

minimum0

schema: optional { fields, format, inferred }

fields: optional array of { type, metadata_key, name, 2 more } or { type, metadata_key, name, 2 more } or { type, metadata_key, name, 2 more } or 8 more

One of the following:

Int32 { type, metadata_key, name, 2 more }

type: "int32"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Int64 { type, metadata_key, name, 2 more }

type: "int64"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Float32 { type, metadata_key, name, 2 more }

type: "float32"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Float64 { type, metadata_key, name, 2 more }

type: "float64"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Bool { type, metadata_key, name, 2 more }

type: "bool"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

String { type, metadata_key, name, 2 more }

type: "string"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Binary { type, metadata_key, name, 2 more }

type: "binary"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Timestamp { type, metadata_key, name, 3 more }

type: "timestamp"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

unit: optional "second" or "millisecond" or "microsecond" or "nanosecond"

One of the following:

"second"

"millisecond"

"microsecond"

"nanosecond"

Json { type, metadata_key, name, 2 more }

type: "json"

metadata_key: optional string

name: optional string

required: optional boolean

sql_name: optional string

Struct =

List =

format: optional { type, decimal_encoding, timestamp_format, unstructured } or { type, compression, row_group_bytes }

One of the following:

Json { type, decimal_encoding, timestamp_format, unstructured }

type: "json"

decimal_encoding: optional "number" or "string" or "bytes"

One of the following:

"number"

"string"

"bytes"

timestamp_format: optional "rfc3339" or "unix_millis"

One of the following:

"rfc3339"

"unix_millis"

unstructured: optional boolean

Parquet { type, compression, row_group_bytes }

type: "parquet"

compression: optional "uncompressed" or "snappy" or "gzip" or 2 more

One of the following:

"uncompressed"

"snappy"

"gzip"

"zstd"

"lz4"

row_group_bytes: optional number

formatint64

minimum0

inferred: optional boolean

StreamUpdateResponse { id, created_at, http, 6 more }

id: string

Indicates a unique identifier for this stream.

created_at: string

formatdate-time

http: { authentication, enabled, cors }

authentication: boolean

Indicates that authentication is required for the HTTP endpoint.

enabled: boolean

Indicates that the HTTP endpoint is enabled.

cors: optional { origins }

Specifies the CORS options for the HTTP endpoint.

origins: optional array of string

modified_at: string

formatdate-time

name: string

Indicates the name of the Stream.

maxLength128

minLength1

version: number

Indicates the current version of this stream.

worker_binding: { enabled }

enabled: boolean

Indicates that the worker binding is enabled.

endpoint: optional string

Indicates the endpoint URL of this stream.

formaturi

format: optional { type, decimal_encoding, timestamp_format, unstructured } or { type, compression, row_group_bytes }

One of the following:

Json { type, decimal_encoding, timestamp_format, unstructured }

type: "json"

decimal_encoding: optional "number" or "string" or "bytes"

One of the following:

"number"

"string"

"bytes"

timestamp_format: optional "rfc3339" or "unix_millis"

One of the following:

"rfc3339"

"unix_millis"

unstructured: optional boolean

Parquet { type, compression, row_group_bytes }

type: "parquet"

compression: optional "uncompressed" or "snappy" or "gzip" or 2 more

One of the following:

"uncompressed"

"snappy"

"gzip"

"zstd"

"lz4"

row_group_bytes: optional number

formatint64

minimum0