universal_transfer_operator.constants

Module Contents

Classes

Location

Generic enumeration.

FileLocation

Generic enumeration.

IngestorSupported

Generic enumeration.

TransferMode

Generic enumeration.

FileType

Generic enumeration.

Database

Generic enumeration.

Attributes

SUPPORTED_FILE_LOCATIONS

SUPPORTED_FILE_TYPES

SUPPORTED_DATABASES

LoadExistStrategy

DEFAULT_CHUNK_SIZE

ColumnCapitalization

DEFAULT_SCHEMA

class universal_transfer_operator.constants.Location

Bases: enum.Enum

Generic enumeration.

Derive from this class to define new enumerations.

LOCAL = 'local'
GS = 'gs'
S3 = 's3'
SFTP = 'sftp'
SQLITE = 'sqlite'
BIGQUERY = 'bigquery'
SNOWFLAKE = 'snowflake'
class universal_transfer_operator.constants.FileLocation

Bases: enum.Enum

Generic enumeration.

Derive from this class to define new enumerations.

LOCAL = 'local'
GS = 'gs'
S3 = 's3'
SFTP = 'sftp'
class universal_transfer_operator.constants.IngestorSupported

Bases: enum.Enum

Generic enumeration.

Derive from this class to define new enumerations.

Fivetran = 'fivetran'
class universal_transfer_operator.constants.TransferMode

Bases: enum.Enum

Generic enumeration.

Derive from this class to define new enumerations.

NATIVE = 'native'
NONNATIVE = 'nonnative'
THIRDPARTY = 'thirdparty'
class universal_transfer_operator.constants.FileType

Bases: enum.Enum

Generic enumeration.

Derive from this class to define new enumerations.

CSV = 'csv'
JSON = 'json'
NDJSON = 'ndjson'
PARQUET = 'parquet'
class universal_transfer_operator.constants.Database

Bases: enum.Enum

Generic enumeration.

Derive from this class to define new enumerations.

SQLITE = 'sqlite'
BIGQUERY = 'bigquery'
SNOWFLAKE = 'snowflake'
universal_transfer_operator.constants.SUPPORTED_FILE_LOCATIONS
universal_transfer_operator.constants.SUPPORTED_FILE_TYPES
universal_transfer_operator.constants.SUPPORTED_DATABASES
universal_transfer_operator.constants.LoadExistStrategy
universal_transfer_operator.constants.DEFAULT_CHUNK_SIZE = 1000000
universal_transfer_operator.constants.ColumnCapitalization
universal_transfer_operator.constants.DEFAULT_SCHEMA = 'tmp_transfers'