MeltanoのTransform
Meltanoでは、ELTのT（Transform）の部分はdbtで補います。この記事では、MeltanoでTransformを行う方法について紹介します。
dbtのインストール
次のコマンドでインストール可能なdbtを確認します。
$ meltano discover transformers
dbt-bigquery
dbt-postgres
dbt-redshift
dbt-snowflake
dbt
dbtをインストールすることも可能ですが、dbt-snowflakeなど特定のdbtプラグインをインストールすることが推奨されています。今回はdbt-bigqueryを利用し、Transformを実行していきます。次のコマンドでdbt-bigqueryをインストールします。
$ meltano add transformer dbt-bigquery
dbt-bigqueryのコンフィグ一覧を確認します。
$ meltano config dbt-bigquery list
または、次の公式ドキュメントで確認することができます。
次のコマンドで、dbt-bigqueryのコンフィグであるproject、dataset、auth_method、keyfileの設定を行います。（meltano.ymlファイルを直接編集することも可能です。）
$ meltano config dbt-bigquery set project "YOUR_PROJECT_ID"
$ meltano config dbt-bigquery set dataset "YOUR_DATASET"
$ meltano config dbt-bigquery set auth_method "service-account"
$ meltano config dbt-bigquery set keyfile "PATH/TO/YOUR/KEYFILE"
meltano.ymlファイルは次のようになります。
.
.
.
environments:
- name: dev
config:
plugins:
transformers:
- name: dbt-bigquery
config:
project: YOUR_PROJECT_ID
dataset: YOUR_DATASET
auth_method: service-account
keyfile: PATH/TO/YOUR/KEYFILE
dbtの処理を記述
/transformディレクトリには次のファイルが存在します。
$ ls /transform
dbt_project.yml
profile
models
/transform/models/ディレクトリにSQLを記述し、/transform/dbt_project.ymlファイルを任意で編集します。
dbtを実行
次の２種類の方法でdbtを実行することが可能です。
- ELTパイプラインとして
runコマンドを実行meltano run tap-github target-bigquery dbt-bigquery:runなど
- スタンドアローンとして
invokeコマンドを実行meltano invoke dbt-bigquery run
また、meltano.ymlファイルを次のように編集することにより、カスタムコマンドを作成することができます。
.
.
.
plugins:
transformers:
- name: dbt-bigquery
commands:
my_models:
args: run --select +YOUR_MODEL_NAME
description: Run dbt, selecting model `YOUR_MODEL_NAME` and all upstream models.
$ meltano run tap-github target-bigquery dbt-bigquery:my_models
$ meltano invoke dbt-bigquery:my_models
dbtプロジェクトを外部リポジトリから参照
/transform/ディレクトリに直接dbtのコードを記述する他に、/transform/ディレクトリにpackage.ymlファイルを作成し、次のような記述をすることでmeltanoプロジェクトとdbtプロジェクトを切り離すことができます。
packages:
- git: https://github.com/your_repo/your-dbt-project.git
revision: 1.0.0
参考
Ryusei Kakujo
Focusing on data science for mobility
Bench Press 100kg!