etlplus.connector

etlplus.connector package.

Connector configuration types and enums.

Functions

parse_connector(obj)

Dispatch to a concrete connector constructor based on type.

Classes

ConnectorApi(*, name[, type, url, method, ...])

Configuration for an API-based data connector.

ConnectorDb(*, name[, type, ...])

Configuration for a database-based data connector.

ConnectorDiagnosticPolicy()

Centralized wording for connector config diagnostics.

ConnectorFile(*, name[, type, format, path, ...])

Configuration for a file-based data connector.

ConnectorQueue(*, name[, type, service, ...])

Configuration for a queue-based data connector.

DataConnectorType(*values)

Supported data connector types.

ConnectorBase(*, name, type)

Abstract base class for connector implementations.

ConnectorProtocol(*args, **kwargs)

Structural contract for connector implementations.

ConnectorApiConfigDict

Shape accepted by ConnectorApi.from_obj() (all keys optional).

ConnectorDbConfigDict

Shape accepted by ConnectorDb.from_obj() (all keys optional).

ConnectorFileConfigDict

Shape accepted by ConnectorFile.from_obj() (all keys optional).

ConnectorQueueConfigDict

Shape accepted by ConnectorQueue.from_obj() (all keys optional).