Reference

Plugin Classes

Tap(config, pathlib.PurePath, str, …)

Abstract base class for taps.

Target(config, pathlib.PurePath, str, …)

Abstract base class for targets.

InlineMapper(config, pathlib.PurePath, str, …)

Abstract base class for inline mappers.

Stream Classes

Stream(tap, schema, os.PathLike, Dict[str, …)

Abstract base class for tap streams.

RESTStream(tap, name, schema, Any], …)

Abstract base class for REST API streams.

GraphQLStream(tap, name, schema, Any], …)

Abstract base class for API-type streams.

Sink Classes

Sink(target, stream_name, schema, key_properties)

Abstract base class for target sinks.

RecordSink(target, stream_name, schema, …)

Base class for singleton record writers.

BatchSink(target, stream_name, schema, …)

Base class for batched record writers.

Authenticator Classes

authenticators.APIKeyAuthenticator(stream, …)

Implements API key authentication for REST Streams.

authenticators.BasicAuthenticator(stream, …)

Implements basic authentication for REST Streams.

authenticators.BearerTokenAuthenticator(…)

Implements bearer token authentication for REST Streams.

authenticators.OAuthAuthenticator(stream, …)

API Authenticator for OAuth 2.0 flows.

authenticators.OAuthJWTAuthenticator(stream, …)

API Authenticator for OAuth 2.0 flows which utilize a JWT refresh token.

authenticators.SimpleAuthenticator(stream, …)

DEPRECATED: Please use a more specific authenticator.

Exception Types

exceptions.ConfigValidationError

Raised when a user’s config settings fail validation.

exceptions.FatalAPIError

Exception raised when a failed request should not be considered retriable.

exceptions.InvalidStreamSortException

Exception to raise if sorting errors are found while syncing the records.

exceptions.MapExpressionError

Failed map expression evaluation.

exceptions.MaxRecordsLimitException

Exception to raise if the maximum number of allowable records is exceeded.

exceptions.RecordsWitoutSchemaException

Raised if a target receives RECORD messages prior to a SCHEMA message.

exceptions.RetriableAPIError

Exception raised when a failed request can be safely retried.

exceptions.StreamMapConfigError

Raised when a stream map has an invalid configuration.

exceptions.TapStreamConnectionFailure

Exception to raise when stream connection fails or stream is disconnected.

exceptions.TooManyRecordsException

Exception to raise when query returns more records than max_records.