「 投稿者アーカイブ:ikuty 」 一覧
-
AirflowでEnd-To-End Pipeline Testsを行うためにAirflow APIを調べてみた話
Airflow自体にDAGの実行結果をテスト(End-To-End Pipeline Tests)する仕組みは無いようで、 以下のような地道な仕組みを自力で作る必要がありそうです。 テストデータを用意 …
-
CustomOperatorのUnitTestを理解するためGCSToBigQueryOperatorのUnitTestを読んでみた話
未知の連携先との入出力を行う際、CustomOperatorを作るという解決策があります。 CustomOperatorを自作した場合、そのテストをどう書くか、という問題が発生します。 ビルトインのG …
-
GoogleによるAirflow DAG実装のベスプラ集を読んでみた – その1
GoogleによるフルマネージドAirflow環境であるCloud Composerを使う必要があり、 いそぎでAirflow+Cloud Composerをキャッチアップすることになりました。 Go …
-
Snowpark Container Services上でWebアプリ(FastAPI/React/TypeScript)を動かしてみた
シンプルな Multi-Container App を動かしている以下の記事にインスパイアされてみました。 以下の記事では、Docker networkを前提にフロントがサーバの名前解決を行っています …
-
Azure Queue StorageとAzure Service Busを比較してみた
Azureで非同期処理を実装する必要があり、Queue StorageとService Busを比較しました。 メッセージの順序保証と消失回避をガチで追求するService Busは考慮すべき事項が大 …
-
Azure Functionsの機能まとめ(座学版)
タイトルの通り、Azure Functionsの機能をまとめてみた。 課金モデル 課金モデルが5パターンあるのではなく、運用方式が5パターンあり、それぞれ課金方式が違う。 呼称がMECEでなかったり公 …
-
External Network Accessを使ってSnowflakeとFitbitAPIを繋いでみた話
FitbitはAPIがしっかり整備されていて、OAuth2 endpoint経由でデータが取り放題。 せっかくなので、話題のExternal Network Access(2023年12月現在 PuP …
-
Deep dive into the internals of Snowflake Virtual Warehousesを読んでみた
この記事はSnowflake Advent Calendar 2023シリーズ2の19日目です。 今年はSnowProAdvanced: Architect試験に合格できました。 結局のところ資格試験 …
-
GCSとのストレージ統合を設定した話
SnowflakeはS3, Blob, GCSを外部ステージとして設定し、データをロードする機能を備えています。 Snowflakeは各クラウドストレージとの接続方法として「ストレージ統合」の使用を推 …
-
デプロイメントについて調べてみた話(端折り気味)
dbt Fundamentalsの「Deployment」のセクションについて理解した内容を言葉にしてみた。 自動化を解決するのにdbt Cloudを使用した記事となっている。この記事は前回の続き。 …