SnowflakeとFivetranをAPI連携する方法をまとめました。

FivetranにDestinationを作成します。
接続先はSnowflakeです。

Bashスクリプトを作成しました。

# FivetranのAPIキーとシークレットを設定
API_KEY=$FIVETRAN_API_KEY
API_SECRET_KEY=$FIVETRAN_API_SECRET_KEY

# APIエンドポイント
URL="https://api.fivetran.com/v1/destinations"

# リクエストボディ
BODY='{
    "group_id": "conserve_syringe",
    "service": "snowflake",
    "region":"AZURE_JAPANEAST",
    "time_zone_offset":"-9",
    "config": {
        "host":"<組織名>.<リージョン>.snowflakecomputing.com",
        "port":443,
        "database":"SNOWFLAKE_DEV",
        "auth":"PASSWORD",
        "user":"RyutoS",
        "password":"xxxxxxxxxxx"
    }
}'

# APIリクエストの実行
curl -X POST "$URL" \
     -u "$API_KEY:$API_SECRET_KEY" \
     -H "Content-Type: application/json" \
     -d "$BODY" | jq

group_idはDestinationから確認できます。

実行結果

~# ./post-destination.sh 
  % Total    % Received % Xferd  Average Speed   Time    Time     Time  Current
                                 Dload  Upload   Total   Spent    Left  Speed
100  1276  100   911  100   365     51     20  0:00:18  0:00:17  0:00:01   239
{
  "code": "Success",
  "message": "Destination has been created",
  ...

Fivetranを確認するとSnowflakeに接続されたDestinationが作成されているのが分かりますね。

まとめ

今回はAPIを使ってFivetranとSnowflakeを連携する方法を紹介しました。

Destinationの連携はAPIだけでなくダッシュボードでもできます。
詳しい設定方法はFivetranとSnowflakeを連携するには？ダッシュボードとAPIそれぞれ手順を紹介で紹介しているのでぜひご覧ください！