How danielptv/tap-db2 works
Tap-DB2 is a Singer extraction tap for IBM DB2, runnable directly or through Meltano. Its main workflow discovers DB2 tables and views into a Singer catalog, then reads selected streams, applying configured filters and optional query partitioning, and emits records for a Singer consumer. The sampled code shows tap configuration, stream query logic, and connector behavior; SDK internals and the exact runtime dispatch between them are not shown, so those links are limited to explicit class configuration and calls.
Main entry points: stream.py DB2 stream · connector.py DB2 connector · tap.py TapDB2
Components 9
Tap runtime
- TapDB2
tap_db2/tap.py - Stream maps
tap_db2/tap.py
Discovery and extraction
- DB2 stream
tap_db2/stream.py - Singer catalog
tap_db2/connector.py
DB2 connectivity
- DB2 connector
tap_db2/connector.py - SQLAlchemy
Other components
- Tap operator
- IBM DB2
- Singer consumer
Connections 10
- Tap operator → TapDB2: runs
- TapDB2 → DB2 stream: sets default class
- TapDB2 → Stream maps: configures
- DB2 stream → DB2 connector: requests table
- DB2 connector → SQLAlchemy: creates engine
- SQLAlchemy → IBM DB2: connects
- DB2 connector → SQLAlchemy: inspects schema
- DB2 connector → Singer catalog: builds entries
- DB2 stream → IBM DB2: queries records
- DB2 stream → Singer consumer: emits records