こんにちは！アステリアのショウジです。
2022年9月29日にASTERIA Warpの新しいアダプターが登場しました！その名も「Snowflakeアダプター」。
Snowflakeといえば、いま先進的なビジネスユーザーから注目を集めている「データクラウド」のSaaS製品です。「データクラウド」は、ひとことで言い換えると「クラウド版のデータウェアハウス（DWH）」。自社でサーバーを構築・運用することなく、短期間でデータ活用のプラットフォームを利用することができます。
そして、ASTERIA WarpのSnowflakeアダプターを利用すると、既存の社内システムや利用中のクラウドサービスとSnowflakeとのデータ連携を、ノーコードで手軽に実現できるようになります！
目次
Snowflakeアダプターでは3種類のコンポーネントが使えます。
 SnowflakeGet |
SnowflakeへSELECT文を発行して結果セットをストリームとして出力します。 |
 SnowflakePut |
Snowflakeのテーブルに対して更新を行います。 |
 SnowflakeSQLCall |
任意のSQLの実行を行います。 |
SnowflakeアダプターではRDBのようにSQLでデータを処理する手段を提供しているため、基本的な使い方はRDB系(RDBGet、RDBPut、SQLCall)のコンポーネントと同じです。
それでは、早速アダプターを使ってみましょう。
CSVファイルのデータを読み込んで、「SnowflakePutコンポーネント」を利用しSnowflakeのテーブルに書き込むフローを作成してみます。
読み込むCSVデータは次の内容です。POSの売上実績データのイメージで作成しました。
作成したフローは以下の通りです。通常のデータベースへデータを書き込む場合と同じような感覚でデータを連携することができますね。
SnowflakeのGUIにてデータプレビューを確認すると、データが保存できたことがわかります。
JSON形式のデータを読み込んで、「SnowflakeSQLCallコンポーネント」を利用しSnowflakeのテーブルに書き込むフローを作成してみます。SnowflakeではJSONやApache Parquetなどの「半構造化データ」をVARIANT型のフィールドに格納できるようになっています。
作成したフローは以下の通りです。ここではJSONデータをテキストファイルから読み込んで、SnowflakeのVARIANT型のフィールドへ書き込む内容としました。あわせて、作成日時をメタデータの位置づけで同じレコードに書き込むようにしています。
SnowflakeSQLCallコンポーネントは、次のように設定されています。
これで、読み込んだJSONデータをVARIANT型のフィールド(JSONDATA)に保存しつつ、同じレコードにメタデータとして作成日時(CREATED_AT)を保存することができました。
「SnowflakeGetコンポーネント」を利用しSnowflakeに保存されているデータを読み込んで、Excelファイルに書き込むフローを作成してみます。読み込むデータは、Snowflakeへのデータ書き込み（その１）でデータを保存した、POSの売上実績データです。
作成したフローは以下の通りです。
SnowflakeGetコンポーネントのSQLビルダーでは、このような設定にしました。
結果、Excelファイルはこのようになりました。
ASTERIA WarpのSnowflakeアダプターを利用すると、Snowflakeのウェアハウス内に作成したテーブルと、オンプレミスや他のクラウドにあるシステムとのデータ連携処理がノーコードで可能となります。今回ご紹介した例ではCSVファイルやExcelファイルとSnowflakeとの連携を実施していますが、データベースなどのオンプレミスに蓄積されたデータの活用や、kintoneのような各種クラウドサービスなどとの連携も同じような要領で実施できますよ。皆さんも是非活用してみてください。
ASTERIA Warpのプリセールスエンジニア。システムエンジニアや情報システム部員としての経験を活かして、ASTERIA Warpをわかりやすくお伝えできるよう日々奮闘中です。
ASTERIA Warp製品の技術情報やTips、また情報交換の場として「ADNフォーラム」をご用意しています。
ASTERIA Warpデベロッパー同士をつなげ、技術情報の共有やちょっとしたASTERIA Warpの疑問解決の場とすることを目的としたコミュニティです。
