Skip to content

Pipeline

Source code in docs_src/capo_osis/types/pipeline.py
class Pipeline(TypedDict, closed=True):
    pipeline_name: NotRequired["capo_osis.types.string.String"]
    """<p>The name of the pipeline.</p>"""
    pipeline_arn: NotRequired["capo_osis.types.string.String"]
    """<p>The Amazon Resource Name (ARN) of the pipeline.</p>"""
    min_units: "capo_osis.types.integer.Integer"
    """<p>The minimum pipeline capacity, in Ingestion Compute Units (ICUs).</p>"""
    max_units: "capo_osis.types.integer.Integer"
    """<p>The maximum pipeline capacity, in Ingestion Compute Units (ICUs).</p>"""
    status: NotRequired["capo_osis.types.pipeline_status.PipelineStatus"]
    """<p>The current status of the pipeline.</p>"""
    status_reason: NotRequired[
        "capo_osis.types.pipeline_status_reason.PipelineStatusReason"
    ]
    """<p>The reason for the current status of the pipeline.</p>"""
    pipeline_configuration_body: NotRequired["capo_osis.types.string.String"]
    """<p>The Data Prepper pipeline configuration in YAML format.</p>"""
    created_at: NotRequired["capo_osis.types.timestamp.Timestamp"]
    """<p>The date and time when the pipeline was created.</p>"""
    last_updated_at: NotRequired["capo_osis.types.timestamp.Timestamp"]
    """<p>The date and time when the pipeline was last updated.</p>"""
    ingest_endpoint_urls: NotRequired[
        "capo_osis.types.ingest_endpoint_urls_list.IngestEndpointUrlsList"
    ]
    """<p>The ingestion endpoints for the pipeline, which you can send data to.</p>"""
    log_publishing_options: NotRequired[
        "capo_osis.types.log_publishing_options.LogPublishingOptions"
    ]
    """<p>Key-value pairs that represent log publishing settings.</p>"""
    vpc_endpoints: NotRequired["capo_osis.types.vpc_endpoints_list.VpcEndpointsList"]
    """<p>The VPC interface endpoints that have access to the pipeline.</p>"""
    buffer_options: NotRequired["capo_osis.types.buffer_options.BufferOptions"]
    encryption_at_rest_options: NotRequired[
        "capo_osis.types.encryption_at_rest_options.EncryptionAtRestOptions"
    ]
    vpc_endpoint_service: NotRequired["capo_osis.types.string.String"]
    """<p>The VPC endpoint service name for the pipeline.</p>"""
    service_vpc_endpoints: NotRequired[
        "capo_osis.types.service_vpc_endpoints_list.ServiceVpcEndpointsList"
    ]
    """<p>A list of VPC endpoints that OpenSearch Ingestion has created to other Amazon Web Services services.</p>"""
    destinations: NotRequired[
        "capo_osis.types.pipeline_destination_list.PipelineDestinationList"
    ]
    """<p>Destinations to which the pipeline writes data.</p>"""
    tags: NotRequired["capo_osis.types.tag_list.TagList"]
    """<p>A list of tags associated with the given pipeline.</p>"""
    pipeline_role_arn: NotRequired["capo_osis.types.pipeline_role_arn.PipelineRoleArn"]
    """<p>The Amazon Resource Name (ARN) of the IAM role that the pipeline uses to access AWS resources.</p>"""

buffer_options instance-attribute

buffer_options: NotRequired[BufferOptions]

created_at instance-attribute

created_at: NotRequired[Timestamp]

The date and time when the pipeline was created.

destinations instance-attribute

destinations: NotRequired[PipelineDestinationList]

Destinations to which the pipeline writes data.

encryption_at_rest_options instance-attribute

encryption_at_rest_options: NotRequired[EncryptionAtRestOptions]

ingest_endpoint_urls instance-attribute

ingest_endpoint_urls: NotRequired[IngestEndpointUrlsList]

The ingestion endpoints for the pipeline, which you can send data to.

last_updated_at instance-attribute

last_updated_at: NotRequired[Timestamp]

The date and time when the pipeline was last updated.

log_publishing_options instance-attribute

log_publishing_options: NotRequired[LogPublishingOptions]

Key-value pairs that represent log publishing settings.

max_units instance-attribute

max_units: Integer

The maximum pipeline capacity, in Ingestion Compute Units (ICUs).

min_units instance-attribute

min_units: Integer

The minimum pipeline capacity, in Ingestion Compute Units (ICUs).

pipeline_arn instance-attribute

pipeline_arn: NotRequired[String]

The Amazon Resource Name (ARN) of the pipeline.

pipeline_configuration_body instance-attribute

pipeline_configuration_body: NotRequired[String]

The Data Prepper pipeline configuration in YAML format.

pipeline_name instance-attribute

pipeline_name: NotRequired[String]

The name of the pipeline.

pipeline_role_arn instance-attribute

pipeline_role_arn: NotRequired[PipelineRoleArn]

The Amazon Resource Name (ARN) of the IAM role that the pipeline uses to access AWS resources.

service_vpc_endpoints instance-attribute

service_vpc_endpoints: NotRequired[ServiceVpcEndpointsList]

A list of VPC endpoints that OpenSearch Ingestion has created to other Amazon Web Services services.

status instance-attribute

status: NotRequired[PipelineStatus]

The current status of the pipeline.

status_reason instance-attribute

status_reason: NotRequired[PipelineStatusReason]

The reason for the current status of the pipeline.

tags instance-attribute

tags: NotRequired[TagList]

A list of tags associated with the given pipeline.

vpc_endpoint_service instance-attribute

vpc_endpoint_service: NotRequired[String]

The VPC endpoint service name for the pipeline.

vpc_endpoints instance-attribute

vpc_endpoints: NotRequired[VpcEndpointsList]

The VPC interface endpoints that have access to the pipeline.