1. Packages
  2. Packages
  3. Cloudflare Provider
  4. API Docs
  5. getPipelineSinks
Viewing docs for Cloudflare v6.15.0
published on Saturday, May 2, 2026 by Pulumi
Schema (JSON)
pulumi/pulumi-cloudflare

cloudflare.getPipelineSinks

cloudflare logo
Viewing docs for Cloudflare v6.15.0
published on Saturday, May 2, 2026 by Pulumi
Schema (JSON)
pulumi/pulumi-cloudflare

    Accepted Permissions

    • Pipelines Read
    • Pipelines Write

    Example Usage

    import * as pulumi from "@pulumi/pulumi";
import * as cloudflare from "@pulumi/cloudflare";

const examplePipelineSinks = cloudflare.getPipelineSinks({
    accountId: "0123105f4ecef8ad9ca31a8372d0c353",
    pipelineId: "pipeline_id",
});

    import pulumi
import pulumi_cloudflare as cloudflare

example_pipeline_sinks = cloudflare.get_pipeline_sinks(account_id="0123105f4ecef8ad9ca31a8372d0c353",
    pipeline_id="pipeline_id")

    package main

import (
	"github.com/pulumi/pulumi-cloudflare/sdk/v6/go/cloudflare"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := cloudflare.GetPipelineSinks(ctx, &cloudflare.LookupPipelineSinksArgs{
			AccountId:  pulumi.StringRef("0123105f4ecef8ad9ca31a8372d0c353"),
			PipelineId: pulumi.StringRef("pipeline_id"),
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

    using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Cloudflare = Pulumi.Cloudflare;

return await Deployment.RunAsync(() => 
{
    var examplePipelineSinks = Cloudflare.Index.GetPipelineSinks.Invoke(new()
    {
        AccountId = "0123105f4ecef8ad9ca31a8372d0c353",
        PipelineId = "pipeline_id",
    });

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.cloudflare.CloudflareFunctions;
import com.pulumi.cloudflare.inputs.GetPipelineSinksArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        final var examplePipelineSinks = CloudflareFunctions.getPipelineSinks(GetPipelineSinksArgs.builder()
            .accountId("0123105f4ecef8ad9ca31a8372d0c353")
            .pipelineId("pipeline_id")
            .build());

    }
}

    variables:
  examplePipelineSinks:
    fn::invoke:
      function: cloudflare:getPipelineSinks
      arguments:
        accountId: 0123105f4ecef8ad9ca31a8372d0c353
        pipelineId: pipeline_id

    Using getPipelineSinks

    Two invocation forms are available. The direct form accepts plain arguments and either blocks until the result value is available, or returns a Promise-wrapped result. The output form accepts Input-wrapped arguments and returns an Output-wrapped result.

    function getPipelineSinks(args: GetPipelineSinksArgs, opts?: InvokeOptions): Promise<GetPipelineSinksResult>
function getPipelineSinksOutput(args: GetPipelineSinksOutputArgs, opts?: InvokeOptions): Output<GetPipelineSinksResult>
    def get_pipeline_sinks(account_id: Optional[str] = None,
                       max_items: Optional[int] = None,
                       pipeline_id: Optional[str] = None,
                       opts: Optional[InvokeOptions] = None) -> GetPipelineSinksResult
def get_pipeline_sinks_output(account_id: Optional[pulumi.Input[str]] = None,
                       max_items: Optional[pulumi.Input[int]] = None,
                       pipeline_id: Optional[pulumi.Input[str]] = None,
                       opts: Optional[InvokeOptions] = None) -> Output[GetPipelineSinksResult]
    func LookupPipelineSinks(ctx *Context, args *LookupPipelineSinksArgs, opts ...InvokeOption) (*LookupPipelineSinksResult, error)
func LookupPipelineSinksOutput(ctx *Context, args *LookupPipelineSinksOutputArgs, opts ...InvokeOption) LookupPipelineSinksResultOutput

    > Note: This function is named LookupPipelineSinks in the Go SDK.

    public static class GetPipelineSinks 
{
    public static Task<GetPipelineSinksResult> InvokeAsync(GetPipelineSinksArgs args, InvokeOptions? opts = null)
    public static Output<GetPipelineSinksResult> Invoke(GetPipelineSinksInvokeArgs args, InvokeOptions? opts = null)
}
    public static CompletableFuture<GetPipelineSinksResult> getPipelineSinks(GetPipelineSinksArgs args, InvokeOptions options)
public static Output<GetPipelineSinksResult> getPipelineSinks(GetPipelineSinksArgs args, InvokeOptions options)

    fn::invoke:
  function: cloudflare:index/getPipelineSinks:getPipelineSinks
  arguments:
    # arguments dictionary

    The following arguments are supported:

    AccountId string
    Specifies the public ID of the account.
    MaxItems int
    Max items to fetch, default: 1000
    PipelineId string
    AccountId string
    Specifies the public ID of the account.
    MaxItems int
    Max items to fetch, default: 1000
    PipelineId string
    accountId String
    Specifies the public ID of the account.
    maxItems Integer
    Max items to fetch, default: 1000
    pipelineId String
    accountId string
    Specifies the public ID of the account.
    maxItems number
    Max items to fetch, default: 1000
    pipelineId string
    account_id str
    Specifies the public ID of the account.
    max_items int
    Max items to fetch, default: 1000
    pipeline_id str
    accountId String
    Specifies the public ID of the account.
    maxItems Number
    Max items to fetch, default: 1000
    pipelineId String

    getPipelineSinks Result

    The following output properties are available:

    Id string
    The provider-assigned unique ID for this managed resource.
    Results List<GetPipelineSinksResult>
    The items returned by the data source
    AccountId string
    Specifies the public ID of the account.
    MaxItems int
    Max items to fetch, default: 1000
    PipelineId string
    Id string
    The provider-assigned unique ID for this managed resource.
    Results []GetPipelineSinksResult
    The items returned by the data source
    AccountId string
    Specifies the public ID of the account.
    MaxItems int
    Max items to fetch, default: 1000
    PipelineId string
    id String
    The provider-assigned unique ID for this managed resource.
    results List<GetPipelineSinksResult>
    The items returned by the data source
    accountId String
    Specifies the public ID of the account.
    maxItems Integer
    Max items to fetch, default: 1000
    pipelineId String
    id string
    The provider-assigned unique ID for this managed resource.
    results GetPipelineSinksResult[]
    The items returned by the data source
    accountId string
    Specifies the public ID of the account.
    maxItems number
    Max items to fetch, default: 1000
    pipelineId string
    id str
    The provider-assigned unique ID for this managed resource.
    results Sequence[GetPipelineSinksResult]
    The items returned by the data source
    account_id str
    Specifies the public ID of the account.
    max_items int
    Max items to fetch, default: 1000
    pipeline_id str
    id String
    The provider-assigned unique ID for this managed resource.
    results List<Property Map>
    The items returned by the data source
    accountId String
    Specifies the public ID of the account.
    maxItems Number
    Max items to fetch, default: 1000
    pipelineId String

    Supporting Types

    GetPipelineSinksResult

    Config GetPipelineSinksResultConfig
    Defines the configuration of the R2 Sink.
    CreatedAt string
    Format GetPipelineSinksResultFormat
    Id string
    Indicates a unique identifier for this sink.
    ModifiedAt string
    Name string
    Defines the name of the Sink.
    Schema GetPipelineSinksResultSchema
    Type string
    Specifies the type of sink. Available values: "r2", "r2datacatalog".
    Config GetPipelineSinksResultConfig
    Defines the configuration of the R2 Sink.
    CreatedAt string
    Format GetPipelineSinksResultFormat
    Id string
    Indicates a unique identifier for this sink.
    ModifiedAt string
    Name string
    Defines the name of the Sink.
    Schema GetPipelineSinksResultSchema
    Type string
    Specifies the type of sink. Available values: "r2", "r2datacatalog".
    config GetPipelineSinksResultConfig
    Defines the configuration of the R2 Sink.
    createdAt String
    format GetPipelineSinksResultFormat
    id String
    Indicates a unique identifier for this sink.
    modifiedAt String
    name String
    Defines the name of the Sink.
    schema GetPipelineSinksResultSchema
    type String
    Specifies the type of sink. Available values: "r2", "r2datacatalog".
    config GetPipelineSinksResultConfig
    Defines the configuration of the R2 Sink.
    createdAt string
    format GetPipelineSinksResultFormat
    id string
    Indicates a unique identifier for this sink.
    modifiedAt string
    name string
    Defines the name of the Sink.
    schema GetPipelineSinksResultSchema
    type string
    Specifies the type of sink. Available values: "r2", "r2datacatalog".
    config GetPipelineSinksResultConfig
    Defines the configuration of the R2 Sink.
    created_at str
    format GetPipelineSinksResultFormat
    id str
    Indicates a unique identifier for this sink.
    modified_at str
    name str
    Defines the name of the Sink.
    schema GetPipelineSinksResultSchema
    type str
    Specifies the type of sink. Available values: "r2", "r2datacatalog".
    config Property Map
    Defines the configuration of the R2 Sink.
    createdAt String
    format Property Map
    id String
    Indicates a unique identifier for this sink.
    modifiedAt String
    name String
    Defines the name of the Sink.
    schema Property Map
    type String
    Specifies the type of sink. Available values: "r2", "r2datacatalog".

    GetPipelineSinksResultConfig

    AccountId string
    Cloudflare Account ID for the bucket
    Bucket string
    R2 Bucket to write to
    FileNaming GetPipelineSinksResultConfigFileNaming
    Controls filename prefix/suffix and strategy.
    Jurisdiction string
    Jurisdiction this bucket is hosted in
    Namespace string
    Table namespace
    Partitioning GetPipelineSinksResultConfigPartitioning
    Data-layout partitioning for sinks.
    Path string
    Subpath within the bucket to write to
    RollingPolicy GetPipelineSinksResultConfigRollingPolicy
    Rolling policy for file sinks (when & why to close a file and open a new one).
    TableName string
    Table name
    AccountId string
    Cloudflare Account ID for the bucket
    Bucket string
    R2 Bucket to write to
    FileNaming GetPipelineSinksResultConfigFileNaming
    Controls filename prefix/suffix and strategy.
    Jurisdiction string
    Jurisdiction this bucket is hosted in
    Namespace string
    Table namespace
    Partitioning GetPipelineSinksResultConfigPartitioning
    Data-layout partitioning for sinks.
    Path string
    Subpath within the bucket to write to
    RollingPolicy GetPipelineSinksResultConfigRollingPolicy
    Rolling policy for file sinks (when & why to close a file and open a new one).
    TableName string
    Table name
    accountId String
    Cloudflare Account ID for the bucket
    bucket String
    R2 Bucket to write to
    fileNaming GetPipelineSinksResultConfigFileNaming
    Controls filename prefix/suffix and strategy.
    jurisdiction String
    Jurisdiction this bucket is hosted in
    namespace String
    Table namespace
    partitioning GetPipelineSinksResultConfigPartitioning
    Data-layout partitioning for sinks.
    path String
    Subpath within the bucket to write to
    rollingPolicy GetPipelineSinksResultConfigRollingPolicy
    Rolling policy for file sinks (when & why to close a file and open a new one).
    tableName String
    Table name
    accountId string
    Cloudflare Account ID for the bucket
    bucket string
    R2 Bucket to write to
    fileNaming GetPipelineSinksResultConfigFileNaming
    Controls filename prefix/suffix and strategy.
    jurisdiction string
    Jurisdiction this bucket is hosted in
    namespace string
    Table namespace
    partitioning GetPipelineSinksResultConfigPartitioning
    Data-layout partitioning for sinks.
    path string
    Subpath within the bucket to write to
    rollingPolicy GetPipelineSinksResultConfigRollingPolicy
    Rolling policy for file sinks (when & why to close a file and open a new one).
    tableName string
    Table name
    account_id str
    Cloudflare Account ID for the bucket
    bucket str
    R2 Bucket to write to
    file_naming GetPipelineSinksResultConfigFileNaming
    Controls filename prefix/suffix and strategy.
    jurisdiction str
    Jurisdiction this bucket is hosted in
    namespace str
    Table namespace
    partitioning GetPipelineSinksResultConfigPartitioning
    Data-layout partitioning for sinks.
    path str
    Subpath within the bucket to write to
    rolling_policy GetPipelineSinksResultConfigRollingPolicy
    Rolling policy for file sinks (when & why to close a file and open a new one).
    table_name str
    Table name
    accountId String
    Cloudflare Account ID for the bucket
    bucket String
    R2 Bucket to write to
    fileNaming Property Map
    Controls filename prefix/suffix and strategy.
    jurisdiction String
    Jurisdiction this bucket is hosted in
    namespace String
    Table namespace
    partitioning Property Map
    Data-layout partitioning for sinks.
    path String
    Subpath within the bucket to write to
    rollingPolicy Property Map
    Rolling policy for file sinks (when & why to close a file and open a new one).
    tableName String
    Table name

    GetPipelineSinksResultConfigFileNaming

    Prefix string
    The prefix to use in file name. i.e prefix-\n\n.parquet
    Strategy string
    Filename generation strategy. Available values: "serial", "uuid", "uuidV7", "ulid".
    Suffix string
    This will overwrite the default file suffix. i.e .parquet, use with caution
    Prefix string
    The prefix to use in file name. i.e prefix-\n\n.parquet
    Strategy string
    Filename generation strategy. Available values: "serial", "uuid", "uuidV7", "ulid".
    Suffix string
    This will overwrite the default file suffix. i.e .parquet, use with caution
    prefix String
    The prefix to use in file name. i.e prefix-\n\n.parquet
    strategy String
    Filename generation strategy. Available values: "serial", "uuid", "uuidV7", "ulid".
    suffix String
    This will overwrite the default file suffix. i.e .parquet, use with caution
    prefix string
    The prefix to use in file name. i.e prefix-\n\n.parquet
    strategy string
    Filename generation strategy. Available values: "serial", "uuid", "uuidV7", "ulid".
    suffix string
    This will overwrite the default file suffix. i.e .parquet, use with caution
    prefix str
    The prefix to use in file name. i.e prefix-\n\n.parquet
    strategy str
    Filename generation strategy. Available values: "serial", "uuid", "uuidV7", "ulid".
    suffix str
    This will overwrite the default file suffix. i.e .parquet, use with caution
    prefix String
    The prefix to use in file name. i.e prefix-\n\n.parquet
    strategy String
    Filename generation strategy. Available values: "serial", "uuid", "uuidV7", "ulid".
    suffix String
    This will overwrite the default file suffix. i.e .parquet, use with caution

    GetPipelineSinksResultConfigPartitioning

    TimePattern string
    The pattern of the date string
    TimePattern string
    The pattern of the date string
    timePattern String
    The pattern of the date string
    timePattern string
    The pattern of the date string
    time_pattern str
    The pattern of the date string
    timePattern String
    The pattern of the date string

    GetPipelineSinksResultConfigRollingPolicy

    FileSizeBytes int
    Files will be rolled after reaching this number of bytes
    InactivitySeconds int
    Number of seconds of inactivity to wait before rolling over to a new file
    IntervalSeconds int
    Number of seconds to wait before rolling over to a new file
    FileSizeBytes int
    Files will be rolled after reaching this number of bytes
    InactivitySeconds int
    Number of seconds of inactivity to wait before rolling over to a new file
    IntervalSeconds int
    Number of seconds to wait before rolling over to a new file
    fileSizeBytes Integer
    Files will be rolled after reaching this number of bytes
    inactivitySeconds Integer
    Number of seconds of inactivity to wait before rolling over to a new file
    intervalSeconds Integer
    Number of seconds to wait before rolling over to a new file
    fileSizeBytes number
    Files will be rolled after reaching this number of bytes
    inactivitySeconds number
    Number of seconds of inactivity to wait before rolling over to a new file
    intervalSeconds number
    Number of seconds to wait before rolling over to a new file
    file_size_bytes int
    Files will be rolled after reaching this number of bytes
    inactivity_seconds int
    Number of seconds of inactivity to wait before rolling over to a new file
    interval_seconds int
    Number of seconds to wait before rolling over to a new file
    fileSizeBytes Number
    Files will be rolled after reaching this number of bytes
    inactivitySeconds Number
    Number of seconds of inactivity to wait before rolling over to a new file
    intervalSeconds Number
    Number of seconds to wait before rolling over to a new file

    GetPipelineSinksResultFormat

    Compression string
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    DecimalEncoding string
    Available values: "number", "string", "bytes".
    RowGroupBytes int
    TimestampFormat string
    Available values: "rfc3339", "unixMillis".
    Type string
    Available values: "json", "parquet".
    Unstructured bool
    Compression string
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    DecimalEncoding string
    Available values: "number", "string", "bytes".
    RowGroupBytes int
    TimestampFormat string
    Available values: "rfc3339", "unixMillis".
    Type string
    Available values: "json", "parquet".
    Unstructured bool
    compression String
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    decimalEncoding String
    Available values: "number", "string", "bytes".
    rowGroupBytes Integer
    timestampFormat String
    Available values: "rfc3339", "unixMillis".
    type String
    Available values: "json", "parquet".
    unstructured Boolean
    compression string
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    decimalEncoding string
    Available values: "number", "string", "bytes".
    rowGroupBytes number
    timestampFormat string
    Available values: "rfc3339", "unixMillis".
    type string
    Available values: "json", "parquet".
    unstructured boolean
    compression str
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    decimal_encoding str
    Available values: "number", "string", "bytes".
    row_group_bytes int
    timestamp_format str
    Available values: "rfc3339", "unixMillis".
    type str
    Available values: "json", "parquet".
    unstructured bool
    compression String
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    decimalEncoding String
    Available values: "number", "string", "bytes".
    rowGroupBytes Number
    timestampFormat String
    Available values: "rfc3339", "unixMillis".
    type String
    Available values: "json", "parquet".
    unstructured Boolean

    GetPipelineSinksResultSchema

    GetPipelineSinksResultSchemaField

    MetadataKey string
    Name string
    Required bool
    SqlName string
    Type string
    Available values: "int32", "int64", "float32", "float64", "bool", "string", "binary", "timestamp", "json".
    Unit string
    Available values: "second", "millisecond", "microsecond", "nanosecond".
    MetadataKey string
    Name string
    Required bool
    SqlName string
    Type string
    Available values: "int32", "int64", "float32", "float64", "bool", "string", "binary", "timestamp", "json".
    Unit string
    Available values: "second", "millisecond", "microsecond", "nanosecond".
    metadataKey String
    name String
    required Boolean
    sqlName String
    type String
    Available values: "int32", "int64", "float32", "float64", "bool", "string", "binary", "timestamp", "json".
    unit String
    Available values: "second", "millisecond", "microsecond", "nanosecond".
    metadataKey string
    name string
    required boolean
    sqlName string
    type string
    Available values: "int32", "int64", "float32", "float64", "bool", "string", "binary", "timestamp", "json".
    unit string
    Available values: "second", "millisecond", "microsecond", "nanosecond".
    metadata_key str
    name str
    required bool
    sql_name str
    type str
    Available values: "int32", "int64", "float32", "float64", "bool", "string", "binary", "timestamp", "json".
    unit str
    Available values: "second", "millisecond", "microsecond", "nanosecond".
    metadataKey String
    name String
    required Boolean
    sqlName String
    type String
    Available values: "int32", "int64", "float32", "float64", "bool", "string", "binary", "timestamp", "json".
    unit String
    Available values: "second", "millisecond", "microsecond", "nanosecond".

    GetPipelineSinksResultSchemaFormat

    Compression string
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    DecimalEncoding string
    Available values: "number", "string", "bytes".
    RowGroupBytes int
    TimestampFormat string
    Available values: "rfc3339", "unixMillis".
    Type string
    Available values: "json", "parquet".
    Unstructured bool
    Compression string
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    DecimalEncoding string
    Available values: "number", "string", "bytes".
    RowGroupBytes int
    TimestampFormat string
    Available values: "rfc3339", "unixMillis".
    Type string
    Available values: "json", "parquet".
    Unstructured bool
    compression String
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    decimalEncoding String
    Available values: "number", "string", "bytes".
    rowGroupBytes Integer
    timestampFormat String
    Available values: "rfc3339", "unixMillis".
    type String
    Available values: "json", "parquet".
    unstructured Boolean
    compression string
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    decimalEncoding string
    Available values: "number", "string", "bytes".
    rowGroupBytes number
    timestampFormat string
    Available values: "rfc3339", "unixMillis".
    type string
    Available values: "json", "parquet".
    unstructured boolean
    compression str
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    decimal_encoding str
    Available values: "number", "string", "bytes".
    row_group_bytes int
    timestamp_format str
    Available values: "rfc3339", "unixMillis".
    type str
    Available values: "json", "parquet".
    unstructured bool
    compression String
    Available values: "uncompressed", "snappy", "gzip", "zstd", "lz4".
    decimalEncoding String
    Available values: "number", "string", "bytes".
    rowGroupBytes Number
    timestampFormat String
    Available values: "rfc3339", "unixMillis".
    type String
    Available values: "json", "parquet".
    unstructured Boolean

    Package Details

    Repository
    Cloudflare pulumi/pulumi-cloudflare
    License
    Apache-2.0
    Notes
    This Pulumi package is based on the cloudflare Terraform Provider.
    cloudflare logo
    Viewing docs for Cloudflare v6.15.0
    published on Saturday, May 2, 2026 by Pulumi
    Schema (JSON)
    pulumi/pulumi-cloudflare
      Try Pulumi Cloud free. Your team will thank you.