GitHub
10/30/2025, 11:11 AMdatabase_records stream, where the records in that stream have a namespace object with a database and collection property (”namespace”: {“database”: “customer_service”, “collection”: “Customer”} for example), I'd like to dynamically split the database_records stream into many streams, one for each namespace.database and namespace.collection value. For the example record with ”namespace”: {“database”: “customer_service”, “collection”: “Customer”} that should be mapped to a new stream with stream_id customer_service-Customer here (as the hyphenating will let us take advantage of handling in the target to write this record to a specific table).
meltano/sdkGitHub
10/30/2025, 11:11 AM