tap-dbt is a Singer tap for the dbt Cloud API v2.

Built with the Singer SDK.

• Installation
• Features
• Configuration
  • Inputs
  • JSON example
  • Environment variables example
  • Meltano Example
• Usage
  • Executing the Tap Directly
  • With Meltano

pip install tap-dbt

Full stream metadata is available in the dbt Labs repository: openapi_schema

The following will be extracted by default if no catalog is used:

• Stream: accounts
• Stream: jobs
• Stream: projects
• Stream: runs

Can be enabled by setting selected in the catalog:

• Stream: connections
• Stream: environments
• Stream: repositories
• Stream: users

Ordering the query from the Runs endpoint by -finished_at, i.e. descending Run Finished Datetime, yields:

The incremental sync has been set up so that it works on replication_key = "finished_at", when an INCREMENTAL sync is run:

• If the bookmark is set, the stream is queried in reverse finished_at order.
• If the finished_at value is not set, the run is assumed to still be running so the record is included, plus the sort order implies that there should be records with populated finished_at appearing later in the stream - Repeated sync operation will yield the same records if the dbt Job Run is still underway, however this adheres to the 'at least once' delivery promise - https://sdk.meltano.com/en/latest/implementation/at_least_once.html
• Once the sync operation reaches records with populated finished_at, the values are compared with the bookmark and once the finished_at value becomes less than the bookmark the stream finishes syncing.

Visit the API docs for instructions on how to get your API key.

You can pass configuration using environment variables with the TAP_DBT_ prefix followed by the uppercased field name

tap-dbt --config=ENV

or a JSON file

tap-dbt --config=config.json

A full list of supported settings and capabilities for this tap is available by running:

tap-dbt --about --format json

{
  "api_key": "da39a3ee5e6b4b0d3255bfef95601890afd80709",
  "account_ids": ["51341"],
  "user_agent": "tap-dbt/0.1.0 Singer Tap for the dbt Cloud API",
  "base_url": "https://my-dbt-cloud-api.com",
  "page_size": 5000
}

TAP_DBT_API_KEY=da39a3ee5e6b4b0d3255bfef95601890afd80709
TAP_DBT_ACCOUNT_IDS=51341
TAP_DBT_USER_AGENT='tap-dbt/0.1.0 Singer Tap for the dbt Cloud API'
TAP_DBT_BASE_URL=https://my-dbt-cloud-api.com"
TAP_DBT_PAGE_SIZE=5000

plugins:
  extractors:
    - name: tap-dbt
      logo_url: https://hub.meltano.com/assets/logos/taps/dbt.png
      label: dbt Cloud
      docs: https://hub.meltano.com/taps/dbt
      repo: https://github.com/edgarrmondragon/tap-dbt
      namespace: dbt
      pip_url: tap-dbt
      executable: tap-dbt
      capabilities:
        - catalog
        - discover
      settings:
        - name: base_url
          label: dbt Cloud URL
          placeholder: "https://cloud.getdbt.com/api/v2"
        - name: api_key
          kind: password
          label: API Key
          docs: "https://docs.getdbt.com/dbt-cloud/api#section/Authentication"
        - name: account_ids
          kind: array
          label: Account IDs
        - name: user_agent
          label: User-Agent
          placeholder: "tap-dbt/0.1.0 Singer Tap for the dbt Cloud API"
        - name: page_size
          kind: integer
          label: Page Size

You can easily run tap-dbt with the CLI or using Meltano.

tap-dbt --version
tap-dbt --help
tap-dbt --config .secrets/example.json --discover > ./catalog/json

meltano elt tap-dbt target-snowflake --job_id dbt_snowflake