## [DEPRECATED] Create Pipeline

`pipelines.create(PipelineCreateParams**kwargs)  -> PipelineCreateResponse`

**post** `/accounts/{account_id}/pipelines`

[DEPRECATED] Create a new pipeline. Use the new /pipelines/v1/pipelines endpoint instead.

### Parameters

- `account_id: str`

  Specifies the public ID of the account.

- `destination: Destination`

  - `batch: DestinationBatch`

    - `max_bytes: Optional[int]`

      Specifies rough maximum size of files.

    - `max_duration_s: Optional[float]`

      Specifies duration to wait to aggregate batches files.

    - `max_rows: Optional[int]`

      Specifies rough maximum number of rows per file.

  - `compression: DestinationCompression`

    - `type: Optional[Literal["none", "gzip", "deflate"]]`

      Specifies the desired compression algorithm and format.

      - `"none"`

      - `"gzip"`

      - `"deflate"`

  - `credentials: DestinationCredentials`

    - `access_key_id: str`

      Specifies the R2 Bucket Access Key Id.

    - `endpoint: str`

      Specifies the R2 Endpoint.

    - `secret_access_key: str`

      Specifies the R2 Bucket Secret Access Key.

  - `format: Literal["json"]`

    Specifies the format of data to deliver.

    - `"json"`

  - `path: DestinationPath`

    - `bucket: str`

      Specifies the R2 Bucket to store files.

    - `filename: Optional[str]`

      Specifies the name pattern to for individual data files.

    - `filepath: Optional[str]`

      Specifies the name pattern for directory.

    - `prefix: Optional[str]`

      Specifies the base directory within the bucket.

  - `type: Literal["r2"]`

    Specifies the type of destination.

    - `"r2"`

- `name: str`

  Defines the name of the pipeline.

- `source: Iterable[Source]`

  - `class SourceCloudflarePipelinesWorkersPipelinesHTTPSource: …`

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

    - `format: Literal["json"]`

      Specifies the format of source data.

      - `"json"`

    - `type: str`

    - `authentication: Optional[bool]`

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

    - `cors: Optional[SourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORS]`

      - `origins: Optional[SequenceNotStr[str]]`

        Specifies allowed origins to allow Cross Origin HTTP Requests.

  - `class SourceCloudflarePipelinesWorkersPipelinesBindingSource: …`

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

    - `format: Literal["json"]`

      Specifies the format of source data.

      - `"json"`

    - `type: str`

### Returns

- `class PipelineCreateResponse: …`

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

  - `id: str`

    Specifies the pipeline identifier.

  - `destination: Destination`

    - `batch: DestinationBatch`

      - `max_bytes: int`

        Specifies rough maximum size of files.

      - `max_duration_s: float`

        Specifies duration to wait to aggregate batches files.

      - `max_rows: int`

        Specifies rough maximum number of rows per file.

    - `compression: DestinationCompression`

      - `type: Literal["none", "gzip", "deflate"]`

        Specifies the desired compression algorithm and format.

        - `"none"`

        - `"gzip"`

        - `"deflate"`

    - `format: Literal["json"]`

      Specifies the format of data to deliver.

      - `"json"`

    - `path: DestinationPath`

      - `bucket: str`

        Specifies the R2 Bucket to store files.

      - `filename: Optional[str]`

        Specifies the name pattern to for individual data files.

      - `filepath: Optional[str]`

        Specifies the name pattern for directory.

      - `prefix: Optional[str]`

        Specifies the base directory within the bucket.

    - `type: Literal["r2"]`

      Specifies the type of destination.

      - `"r2"`

  - `endpoint: str`

    Indicates the endpoint URL to send traffic.

  - `name: str`

    Defines the name of the pipeline.

  - `source: List[Source]`

    - `class SourceCloudflarePipelinesWorkersPipelinesHTTPSource: …`

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

      - `format: Literal["json"]`

        Specifies the format of source data.

        - `"json"`

      - `type: str`

      - `authentication: Optional[bool]`

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

      - `cors: Optional[SourceCloudflarePipelinesWorkersPipelinesHTTPSourceCORS]`

        - `origins: Optional[List[str]]`

          Specifies allowed origins to allow Cross Origin HTTP Requests.

    - `class SourceCloudflarePipelinesWorkersPipelinesBindingSource: …`

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

      - `format: Literal["json"]`

        Specifies the format of source data.

        - `"json"`

      - `type: str`

  - `version: float`

    Indicates the version number of last saved configuration.

### Example

```python
import os
from cloudflare import Cloudflare

client = Cloudflare(
    api_token=os.environ.get("CLOUDFLARE_API_TOKEN"),  # This is the default and can be omitted
)
pipeline = client.pipelines.create(
    account_id="0123105f4ecef8ad9ca31a8372d0c353",
    destination={
        "batch": {},
        "compression": {},
        "credentials": {
            "access_key_id": "<access key id>",
            "endpoint": "https://123f8a8258064ed892a347f173372359.r2.cloudflarestorage.com",
            "secret_access_key": "<secret key>",
        },
        "format": "json",
        "path": {
            "bucket": "bucket"
        },
        "type": "r2",
    },
    name="sample_pipeline",
    source=[{
        "format": "json",
        "type": "type",
    }],
)
print(pipeline.id)
```

#### Response

```json
{
  "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
}
```