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