Submodules

airbyte_cdk.destinations.destination module

class airbyte_cdk.destinations.destination.Destination

Bases: airbyte_cdk.connector.Connector, abc.ABC

VALID_CMDS = {'check', 'spec', 'write'}
parse_args(args: List[str]) argparse.Namespace
Parameters

args – commandline arguments

Returns

run(args: List[str])
run_cmd(parsed_args: argparse.Namespace) Iterable[airbyte_protocol.models.airbyte_protocol.AirbyteMessage]
abstract write(config: Mapping[str, Any], configured_catalog: airbyte_protocol.models.airbyte_protocol.ConfiguredAirbyteCatalog, input_messages: Iterable[airbyte_protocol.models.airbyte_protocol.AirbyteMessage]) Iterable[airbyte_protocol.models.airbyte_protocol.AirbyteMessage]

Implement to define how the connector writes data to the destination

Module contents

class airbyte_cdk.destinations.Destination

Bases: airbyte_cdk.connector.Connector, abc.ABC

VALID_CMDS = {'check', 'spec', 'write'}
parse_args(args: List[str]) argparse.Namespace
Parameters

args – commandline arguments

Returns

run(args: List[str])
run_cmd(parsed_args: argparse.Namespace) Iterable[airbyte_protocol.models.airbyte_protocol.AirbyteMessage]
abstract write(config: Mapping[str, Any], configured_catalog: airbyte_protocol.models.airbyte_protocol.ConfiguredAirbyteCatalog, input_messages: Iterable[airbyte_protocol.models.airbyte_protocol.AirbyteMessage]) Iterable[airbyte_protocol.models.airbyte_protocol.AirbyteMessage]

Implement to define how the connector writes data to the destination