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

cloudflare.getPipelineStream

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 examplePipelineStream = cloudflare.getPipelineStream({
    accountId: "0123105f4ecef8ad9ca31a8372d0c353",
    streamId: "033e105f4ecef8ad9ca31a8372d0c353",
});

    import pulumi
import pulumi_cloudflare as cloudflare

example_pipeline_stream = cloudflare.get_pipeline_stream(account_id="0123105f4ecef8ad9ca31a8372d0c353",
    stream_id="033e105f4ecef8ad9ca31a8372d0c353")

    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.GetPipelineStream(ctx, &cloudflare.LookupPipelineStreamArgs{
			AccountId: pulumi.StringRef("0123105f4ecef8ad9ca31a8372d0c353"),
			StreamId:  pulumi.StringRef("033e105f4ecef8ad9ca31a8372d0c353"),
		}, 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 examplePipelineStream = Cloudflare.Index.GetPipelineStream.Invoke(new()
    {
        AccountId = "0123105f4ecef8ad9ca31a8372d0c353",
        StreamId = "033e105f4ecef8ad9ca31a8372d0c353",
    });

});

    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.GetPipelineStreamArgs;
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 examplePipelineStream = CloudflareFunctions.getPipelineStream(GetPipelineStreamArgs.builder()
            .accountId("0123105f4ecef8ad9ca31a8372d0c353")
            .streamId("033e105f4ecef8ad9ca31a8372d0c353")
            .build());

    }
}

    variables:
  examplePipelineStream:
    fn::invoke:
      function: cloudflare:getPipelineStream
      arguments:
        accountId: 0123105f4ecef8ad9ca31a8372d0c353
        streamId: 033e105f4ecef8ad9ca31a8372d0c353

    Using getPipelineStream

    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 getPipelineStream(args: GetPipelineStreamArgs, opts?: InvokeOptions): Promise<GetPipelineStreamResult>
function getPipelineStreamOutput(args: GetPipelineStreamOutputArgs, opts?: InvokeOptions): Output<GetPipelineStreamResult>
    def get_pipeline_stream(account_id: Optional[str] = None,
                        filter: Optional[GetPipelineStreamFilter] = None,
                        stream_id: Optional[str] = None,
                        opts: Optional[InvokeOptions] = None) -> GetPipelineStreamResult
def get_pipeline_stream_output(account_id: Optional[pulumi.Input[str]] = None,
                        filter: Optional[pulumi.Input[GetPipelineStreamFilterArgs]] = None,
                        stream_id: Optional[pulumi.Input[str]] = None,
                        opts: Optional[InvokeOptions] = None) -> Output[GetPipelineStreamResult]
    func LookupPipelineStream(ctx *Context, args *LookupPipelineStreamArgs, opts ...InvokeOption) (*LookupPipelineStreamResult, error)
func LookupPipelineStreamOutput(ctx *Context, args *LookupPipelineStreamOutputArgs, opts ...InvokeOption) LookupPipelineStreamResultOutput

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

    public static class GetPipelineStream 
{
    public static Task<GetPipelineStreamResult> InvokeAsync(GetPipelineStreamArgs args, InvokeOptions? opts = null)
    public static Output<GetPipelineStreamResult> Invoke(GetPipelineStreamInvokeArgs args, InvokeOptions? opts = null)
}
    public static CompletableFuture<GetPipelineStreamResult> getPipelineStream(GetPipelineStreamArgs args, InvokeOptions options)
public static Output<GetPipelineStreamResult> getPipelineStream(GetPipelineStreamArgs args, InvokeOptions options)

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

    The following arguments are supported:

    AccountId string
    Specifies the public ID of the account.
    Filter GetPipelineStreamFilter
    StreamId string
    Specifies the public ID of the stream.
    AccountId string
    Specifies the public ID of the account.
    Filter GetPipelineStreamFilter
    StreamId string
    Specifies the public ID of the stream.
    accountId String
    Specifies the public ID of the account.
    filter GetPipelineStreamFilter
    streamId String
    Specifies the public ID of the stream.
    accountId string
    Specifies the public ID of the account.
    filter GetPipelineStreamFilter
    streamId string
    Specifies the public ID of the stream.
    account_id str
    Specifies the public ID of the account.
    filter GetPipelineStreamFilter
    stream_id str
    Specifies the public ID of the stream.
    accountId String
    Specifies the public ID of the account.
    filter Property Map
    streamId String
    Specifies the public ID of the stream.

    getPipelineStream Result

    The following output properties are available:

    CreatedAt string
    Endpoint string
    Indicates the endpoint URL of this stream.
    Format GetPipelineStreamFormat
    Http GetPipelineStreamHttp
    Id string
    Specifies the public ID of the stream.
    ModifiedAt string
    Name string
    Indicates the name of the Stream.
    Schema GetPipelineStreamSchema
    Version int
    Indicates the current version of this stream.
    WorkerBinding GetPipelineStreamWorkerBinding
    AccountId string
    Specifies the public ID of the account.
    Filter GetPipelineStreamFilter
    StreamId string
    Specifies the public ID of the stream.
    CreatedAt string
    Endpoint string
    Indicates the endpoint URL of this stream.
    Format GetPipelineStreamFormat
    Http GetPipelineStreamHttp
    Id string
    Specifies the public ID of the stream.
    ModifiedAt string
    Name string
    Indicates the name of the Stream.
    Schema GetPipelineStreamSchema
    Version int
    Indicates the current version of this stream.
    WorkerBinding GetPipelineStreamWorkerBinding
    AccountId string
    Specifies the public ID of the account.
    Filter GetPipelineStreamFilter
    StreamId string
    Specifies the public ID of the stream.
    createdAt String
    endpoint String
    Indicates the endpoint URL of this stream.
    format GetPipelineStreamFormat
    http GetPipelineStreamHttp
    id String
    Specifies the public ID of the stream.
    modifiedAt String
    name String
    Indicates the name of the Stream.
    schema GetPipelineStreamSchema
    version Integer
    Indicates the current version of this stream.
    workerBinding GetPipelineStreamWorkerBinding
    accountId String
    Specifies the public ID of the account.
    filter GetPipelineStreamFilter
    streamId String
    Specifies the public ID of the stream.
    createdAt string
    endpoint string
    Indicates the endpoint URL of this stream.
    format GetPipelineStreamFormat
    http GetPipelineStreamHttp
    id string
    Specifies the public ID of the stream.
    modifiedAt string
    name string
    Indicates the name of the Stream.
    schema GetPipelineStreamSchema
    version number
    Indicates the current version of this stream.
    workerBinding GetPipelineStreamWorkerBinding
    accountId string
    Specifies the public ID of the account.
    filter GetPipelineStreamFilter
    streamId string
    Specifies the public ID of the stream.
    created_at str
    endpoint str
    Indicates the endpoint URL of this stream.
    format GetPipelineStreamFormat
    http GetPipelineStreamHttp
    id str
    Specifies the public ID of the stream.
    modified_at str
    name str
    Indicates the name of the Stream.
    schema GetPipelineStreamSchema
    version int
    Indicates the current version of this stream.
    worker_binding GetPipelineStreamWorkerBinding
    account_id str
    Specifies the public ID of the account.
    filter GetPipelineStreamFilter
    stream_id str
    Specifies the public ID of the stream.
    createdAt String
    endpoint String
    Indicates the endpoint URL of this stream.
    format Property Map
    http Property Map
    id String
    Specifies the public ID of the stream.
    modifiedAt String
    name String
    Indicates the name of the Stream.
    schema Property Map
    version Number
    Indicates the current version of this stream.
    workerBinding Property Map
    accountId String
    Specifies the public ID of the account.
    filter Property Map
    streamId String
    Specifies the public ID of the stream.

    Supporting Types

    GetPipelineStreamFilter

    PipelineId string
    Specifies the public ID of the pipeline.
    PipelineId string
    Specifies the public ID of the pipeline.
    pipelineId String
    Specifies the public ID of the pipeline.
    pipelineId string
    Specifies the public ID of the pipeline.
    pipeline_id str
    Specifies the public ID of the pipeline.
    pipelineId String
    Specifies the public ID of the pipeline.

    GetPipelineStreamFormat

    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

    GetPipelineStreamHttp

    Authentication bool
    Indicates that authentication is required for the HTTP endpoint.
    Cors GetPipelineStreamHttpCors
    Specifies the CORS options for the HTTP endpoint.
    Enabled bool
    Indicates that the HTTP endpoint is enabled.
    Authentication bool
    Indicates that authentication is required for the HTTP endpoint.
    Cors GetPipelineStreamHttpCors
    Specifies the CORS options for the HTTP endpoint.
    Enabled bool
    Indicates that the HTTP endpoint is enabled.
    authentication Boolean
    Indicates that authentication is required for the HTTP endpoint.
    cors GetPipelineStreamHttpCors
    Specifies the CORS options for the HTTP endpoint.
    enabled Boolean
    Indicates that the HTTP endpoint is enabled.
    authentication boolean
    Indicates that authentication is required for the HTTP endpoint.
    cors GetPipelineStreamHttpCors
    Specifies the CORS options for the HTTP endpoint.
    enabled boolean
    Indicates that the HTTP endpoint is enabled.
    authentication bool
    Indicates that authentication is required for the HTTP endpoint.
    cors GetPipelineStreamHttpCors
    Specifies the CORS options for the HTTP endpoint.
    enabled bool
    Indicates that the HTTP endpoint is enabled.
    authentication Boolean
    Indicates that authentication is required for the HTTP endpoint.
    cors Property Map
    Specifies the CORS options for the HTTP endpoint.
    enabled Boolean
    Indicates that the HTTP endpoint is enabled.

    GetPipelineStreamHttpCors

    Origins List<string>
    Origins []string
    origins List<String>
    origins string[]
    origins Sequence[str]
    origins List<String>

    GetPipelineStreamSchema

    GetPipelineStreamSchemaField

    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".

    GetPipelineStreamSchemaFormat

    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

    GetPipelineStreamWorkerBinding

    Enabled bool
    Indicates that the worker binding is enabled.
    Enabled bool
    Indicates that the worker binding is enabled.
    enabled Boolean
    Indicates that the worker binding is enabled.
    enabled boolean
    Indicates that the worker binding is enabled.
    enabled bool
    Indicates that the worker binding is enabled.
    enabled Boolean
    Indicates that the worker binding is enabled.

    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.