airflow.providers.amazon.aws.datasets.s3

Module Contents

Functions

create_dataset(*, bucket, key[, extra])

sanitize_uri(uri)

convert_dataset_to_openlineage(dataset, lineage_context)

Translate Dataset with valid AIP-60 uri to OpenLineage with assistance from the hook.

airflow.providers.amazon.aws.datasets.s3.create_dataset(*, bucket, key, extra=None)[source]
airflow.providers.amazon.aws.datasets.s3.sanitize_uri(uri)[source]
airflow.providers.amazon.aws.datasets.s3.convert_dataset_to_openlineage(dataset, lineage_context)[source]

Translate Dataset with valid AIP-60 uri to OpenLineage with assistance from the hook.

Was this entry helpful?