--- title: "[DEPRECATED] Create Pipeline" --- [Skip to content](#_top) [API Reference](https://developers.cloudflare.com/api/go) [Pipelines](https://developers.cloudflare.com/api/go/resources/pipelines) Copy Markdown Open in **Claude**Open in **ChatGPT**Open in **Cursor** --- **Copy Markdown****View as Markdown** # \[DEPRECATED] Create Pipeline Deprecated: Use create\_v1 instead. This endpoint will be removed in the future. client.Pipelines.New(ctx, params) (\*[PipelineNewResponse](), error) POST/accounts/{account\_id}/pipelines \[DEPRECATED] Create a new pipeline. Use the new /pipelines/v1/pipelines endpoint instead. ##### Security
API Token The preferred authorization scheme for interacting with the Cloudflare API. Create a token. **Example:**Authorization: Bearer Sn3lZJTBX6kkg7OdcBUAxOO963GEIyGQqnFTOFYY
API Email + API Key The previous authorization scheme for interacting with the Cloudflare API, used in conjunction with a Global API key. **Example:**X-Auth-Email: user@example.com The previous authorization scheme for interacting with the Cloudflare API. When possible, use API tokens instead of Global API keys. **Example:**X-Auth-Key: 144c9defac04969c7bfad8efaa8ea194
##### Accepted Permissions (at least one required) `Pipelines Write` ##### ParametersExpand Collapse
params PipelineNewParams AccountID param.Field\[string] Path param: Specifies the public ID of the account. Link to this property
Destination param.Field\[PipelineNewParamsDestination] Body param
Batch PipelineNewParamsDestinationBatch MaxBytes int64Optional Specifies rough maximum size of files. maximum100000000 minimum1000 Link to this property MaxDurationS float64Optional Specifies duration to wait to aggregate batches files. maximum300 minimum0.25 Link to this property MaxRows int64Optional Specifies rough maximum number of rows per file. maximum10000000 minimum100 Link to this property
Link to this property
Compression PipelineNewParamsDestinationCompression
Type PipelineNewParamsDestinationCompressionTypeOptional Specifies the desired compression algorithm and format. One of the following: const PipelineNewParamsDestinationCompressionTypeNone PipelineNewParamsDestinationCompressionType = "none" Link to this property const PipelineNewParamsDestinationCompressionTypeGzip PipelineNewParamsDestinationCompressionType = "gzip" Link to this property const PipelineNewParamsDestinationCompressionTypeDeflate PipelineNewParamsDestinationCompressionType = "deflate" Link to this property
Link to this property
Link to this property
Credentials PipelineNewParamsDestinationCredentials AccessKeyID string Specifies the R2 Bucket Access Key Id. Link to this property Endpoint string Specifies the R2 Endpoint. Link to this property SecretAccessKey string Specifies the R2 Bucket Secret Access Key. Link to this property
Link to this property Format PipelineNewParamsDestinationFormat Specifies the format of data to deliver. Link to this property
Path PipelineNewParamsDestinationPath Bucket string Specifies the R2 Bucket to store files. Link to this property Filename stringOptional Specifies the name pattern to for individual data files. Link to this property Filepath stringOptional Specifies the name pattern for directory. Link to this property Prefix stringOptional Specifies the base directory within the bucket. Link to this property
Link to this property Type PipelineNewParamsDestinationType Specifies the type of destination. Link to this property
Link to this property Name param.Field\[string] Body param: Defines the name of the pipeline. maxLength128 minLength1 Link to this property
Source param.Field\[\[]PipelineNewParamsSource] Body param
type PipelineNewParamsSourceCloudflarePipelinesWorkersPipelinesHTTPSource struct{…} \[DEPRECATED] HTTP source configuration. Use the new streams API instead. Format PipelineNewParamsSourceCloudflarePipelinesWorkersPipelinesHTTPSourceFormat Specifies the format of source data. Link to this property Type string Link to this property Authentication boolOptional Specifies whether authentication is required to send to this pipeline via HTTP. Link to this property
CORS PipelineNewParamsSourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORSOptional Origins \[]stringOptional Specifies allowed origins to allow Cross Origin HTTP Requests. Link to this property
Link to this property
Link to this property
type PipelineNewParamsSourceCloudflarePipelinesWorkersPipelinesBindingSource struct{…} \[DEPRECATED] Worker binding source configuration. Use the new streams API instead. Format PipelineNewParamsSourceCloudflarePipelinesWorkersPipelinesBindingSourceFormat Specifies the format of source data. Link to this property Type string Link to this property
Link to this property
Link to this property
[Link to this property](<#(resource)%20pipelines%20%3E%20(method)%20create%20%3E%20(params)%20default>) ##### ReturnsExpand Collapse
type PipelineNewResponse struct{…} \[DEPRECATED] Describes the configuration of a pipeline. Use the new streams/sinks/pipelines API instead. ID string Specifies the pipeline identifier. Link to this property
Destination PipelineNewResponseDestination
Batch PipelineNewResponseDestinationBatch MaxBytes int64 Specifies rough maximum size of files. maximum100000000 minimum1000 Link to this property MaxDurationS float64 Specifies duration to wait to aggregate batches files. maximum300 minimum0.25 Link to this property MaxRows int64 Specifies rough maximum number of rows per file. maximum10000000 minimum100 Link to this property
Link to this property
Compression PipelineNewResponseDestinationCompression
Type PipelineNewResponseDestinationCompressionType Specifies the desired compression algorithm and format. One of the following: const PipelineNewResponseDestinationCompressionTypeNone PipelineNewResponseDestinationCompressionType = "none" Link to this property const PipelineNewResponseDestinationCompressionTypeGzip PipelineNewResponseDestinationCompressionType = "gzip" Link to this property const PipelineNewResponseDestinationCompressionTypeDeflate PipelineNewResponseDestinationCompressionType = "deflate" Link to this property
Link to this property
Link to this property Format PipelineNewResponseDestinationFormat Specifies the format of data to deliver. Link to this property
Path PipelineNewResponseDestinationPath Bucket string Specifies the R2 Bucket to store files. Link to this property Filename stringOptional Specifies the name pattern to for individual data files. Link to this property Filepath stringOptional Specifies the name pattern for directory. Link to this property Prefix stringOptional Specifies the base directory within the bucket. Link to this property
Link to this property Type PipelineNewResponseDestinationType Specifies the type of destination. Link to this property
Link to this property Endpoint string Indicates the endpoint URL to send traffic. Link to this property Name string Defines the name of the pipeline. maxLength128 minLength1 Link to this property
Source \[]PipelineNewResponseSource One of the following:
type PipelineNewResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSource struct{…} \[DEPRECATED] HTTP source configuration. Use the new streams API instead. Format PipelineNewResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceFormat Specifies the format of source data. Link to this property Type string Link to this property Authentication boolOptional Specifies whether authentication is required to send to this pipeline via HTTP. Link to this property
CORS PipelineNewResponseSourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORSOptional Origins \[]stringOptional Specifies allowed origins to allow Cross Origin HTTP Requests. Link to this property
Link to this property
Link to this property
type PipelineNewResponseSourceCloudflarePipelinesWorkersPipelinesBindingSource struct{…} \[DEPRECATED] Worker binding source configuration. Use the new streams API instead. Format PipelineNewResponseSourceCloudflarePipelinesWorkersPipelinesBindingSourceFormat Specifies the format of source data. Link to this property Type string Link to this property
Link to this property
Link to this property Version float64 Indicates the version number of last saved configuration. Link to this property
[Link to this property](<#(resource)%20pipelines%20%3E%20(model)%20PipelineNewResponse%20%3E%20(schema)>) ### \[DEPRECATED] Create Pipeline Go HTTPTypeScriptPythonGoTerraform ``` package main import ( "context" "fmt" "github.com/cloudflare/cloudflare-go" "github.com/cloudflare/cloudflare-go/option" "github.com/cloudflare/cloudflare-go/pipelines" ) func main() { client := cloudflare.NewClient( option.WithAPIToken("Sn3lZJTBX6kkg7OdcBUAxOO963GEIyGQqnFTOFYY"), ) pipeline, err := client.Pipelines.New(context.TODO(), pipelines.PipelineNewParams{ AccountID: cloudflare.F("0123105f4ecef8ad9ca31a8372d0c353"), Destination: cloudflare.F(pipelines.PipelineNewParamsDestination{ Batch: cloudflare.F(pipelines.PipelineNewParamsDestinationBatch{ }), Compression: cloudflare.F(pipelines.PipelineNewParamsDestinationCompression{ }), Credentials: cloudflare.F(pipelines.PipelineNewParamsDestinationCredentials{ AccessKeyID: cloudflare.F(""), Endpoint: cloudflare.F("https://123f8a8258064ed892a347f173372359.r2.cloudflarestorage.com"), SecretAccessKey: cloudflare.F(""), }), Format: cloudflare.F(pipelines.PipelineNewParamsDestinationFormatJson), Path: cloudflare.F(pipelines.PipelineNewParamsDestinationPath{ Bucket: cloudflare.F("bucket"), }), Type: cloudflare.F(pipelines.PipelineNewParamsDestinationTypeR2), }), Name: cloudflare.F("sample_pipeline"), Source: cloudflare.F([]pipelines.PipelineNewParamsSourceUnion{pipelines.PipelineNewParamsSourceCloudflarePipelinesWorkersPipelinesHTTPSource{ Format: cloudflare.F(pipelines.PipelineNewParamsSourceCloudflarePipelinesWorkersPipelinesHTTPSourceFormatJson), Type: cloudflare.F("type"), }}), }) if err != nil { panic(err.Error()) } fmt.Printf("%+v\n", pipeline.ID) } ``` 200 example ``` { "result": { "id": "123f8a8258064ed892a347f173372359", "destination": { "batch": { "max_bytes": 1000, "max_duration_s": 0.25, "max_rows": 100 }, "compression": { "type": "gzip" }, "format": "json", "path": { "bucket": "bucket", "filename": "${slug}${extension}", "filepath": "${date}/${hour}", "prefix": "base" }, "type": "r2" }, "endpoint": "https://123f8a8258064ed892a347f173372359.pipelines.cloudflare.com", "name": "sample_pipeline", "source": [ { "format": "json", "type": "type", "authentication": true, "cors": { "origins": [ "*" ] } } ], "version": 2 }, "success": true } ``` ##### Returns Examples 200 example ``` { "result": { "id": "123f8a8258064ed892a347f173372359", "destination": { "batch": { "max_bytes": 1000, "max_duration_s": 0.25, "max_rows": 100 }, "compression": { "type": "gzip" }, "format": "json", "path": { "bucket": "bucket", "filename": "${slug}${extension}", "filepath": "${date}/${hour}", "prefix": "base" }, "type": "r2" }, "endpoint": "https://123f8a8258064ed892a347f173372359.pipelines.cloudflare.com", "name": "sample_pipeline", "source": [ { "format": "json", "type": "type", "authentication": true, "cors": { "origins": [ "*" ] } } ], "version": 2 }, "success": true } ```