Ian OLeary
08/19/2024, 2:16 PMmeltano invoke tap-mssql --discover
I got this huge json output to my CLI with all the different tables/columns I can access along with whether the object is a view/table. This seems expected, but how do I go from here to getting that output into a structure that I can use to filter out the databases/tables/views that I want to replicate over to my warehouse? It's the backend for an ERP system so there's hundreds if not thousands of tables which could be replicated so I obviously don't need to be pulling all of them over. I just need to pull a few tables from one of the seven or so db's within the mssql instance. Should I like get this output into yaml or something then cut it down from there? How does meltano know what the "filtered streams" are each time I run the meltano run tap-mssql target-snowflake
command for my pipeline runs? Is it all defined in the meltano.yaml or does/can it look at a json or other yaml file to get the proper list? I've only created a custom tap so haven't messed with a pre-built one yet. I'm using the @BuzzCutNorman variant in case that has any sort of implications.andrio_frizon
08/19/2024, 2:21 PMBuzzCutNorman
08/19/2024, 2:22 PMIan OLeary
08/19/2024, 2:23 PMmeltano select tap-mssql --list --all
to populate all the streams then filter from there?BuzzCutNorman
08/19/2024, 2:24 PMIan OLeary
08/19/2024, 2:27 PMIan OLeary
08/19/2024, 2:29 PMBuzzCutNorman
08/19/2024, 2:34 PMdbo.Users
to replicate. You would say meltano select tap-mssql dbo-Users '*'
In your meltano.yml you would see this in the config of tap-mssql:
select:
- 'dbo-Users.*'
Ian OLeary
08/19/2024, 2:58 PMandrio_frizon
08/19/2024, 3:01 PMIan OLeary
08/19/2024, 4:00 PMjoshua_janicas
08/21/2024, 5:55 PMplugins:
extractors:
- name: tap-mssql-bookingCustomerAddress
inherit_from: tap-mssql
config:
stream_maps:
Shopping-BookingCustomerAddress:
DescriptionLookupId: __NULL__
select:
- Shopping-BookingCustomerAddress.*
metadata:
Shopping-BookingCustomerAddress:
replication-method: INCREMENTAL
replication-key: LastEditDate