保つ Anvil.works Snowflake倉庫と連携して、 スケジュール通りに
SQL文は一度書くだけでOK。Query Streamsが5分ごとから週ごとまで、指定したスケジュールで実行し、Anvil.worksのデータテーブルにデータを書き込みます。キーで行を照合すれば、編集内容がそのまま反映され、クエリから外れた行は削除されます。もちろん、単純に行を追加することも可能です。Zapierもスクリプトもエクスポートも不要。初回は約15分で完了し、無料プランで利用できます。
最終的に手に入るもの
Snowflakeクエリが返す行を保持するAnvil.worksデータテーブル。5分ごとから週ごとまでのスケジュールに従って更新され、実行ごとに変更内容のレシートが提供されます。例:
Snowflakeは独自のクラウドにデータを保持します。チームはAnvil.worksで作業します。従来の方法は、アプリ内で手動でインポートを行い、処理が中断されることなく一度に1行ずつコピーするというものでした。Query Streams Automationはこれとは異なります。Snowflakeウェアハウスに既に配置されているエージェントが、保存済みのSQLをスケジュールに基づいて実行し、結果全体を一度にAnvil.worksに書き込みます。キーに基づいて行を照合することで、データテーブルが肥大化することなく、常に正しい状態を維持します。
必要なもの
Snowflakeはエージェントを介して接続されました
エージェントは、常時稼働している任意のコンピュータにインストールされ、Snowflakeウェアハウスがデータエージェントの接続として追加されます。まだ完了していませんか? Snowflakeを最初に接続してください。所要時間は約10分です。
Anvil.worksへのログイン
AnvilアプリのHTTPSアドレスと、querystreamsモジュールのconnector.init_connector("key")でアプリ内で設定したコネクタキーを入力してください。Query Streamsはアプリの応答を確認し、データテーブルを一覧表示します。
作業はどこで行われますか? エージェントを実行しているコンピューター上で、スケジュールに従ってクエリが実行され、結果が Anvil.works に書き込まれるため、そのコンピューターは起動したままにしておく必要があります。ブラウザは閉じても構いません。クエリ ストリーム自体は結果を保存しません。
6つのステップで設定できます
-
同期を維持したいクエリを保存します
開く クエリビルダーSnowflake接続を選択してください(まだ接続していませんか? ここから始めましょう)、Anvil.works で必要な行と列を正確に返す SELECT 文を記述します。これは、 注文 テーブル:
例:SQLSELECT order_id, customer_name, order_total FROM SALES.PUBLIC.ORDERS ORDER BY order_total DESC LIMIT 100;
実行してから セーブ 「Anvil.works の注文」のように、認識しやすい名前を付けてください。SELECT では、行ごとに一意の列を保持してください。 注文IDこれが、Full Syncが該当行をその場で更新するために使用する鍵です。後でクエリを編集して再保存すると、自動化処理は次回の実行時に変更を反映します。
-
Automationを開き、Anvil.worksを選択します。
ポータルで、 オートメーション (トップメニュー) ストリーム → スケジュール済み → 自動化)そしてクリック 新しい自動化魔法使いには5つの短いステップがあります。 ステップ1 クリック Anvil.works カード。
代わりに「始める前に」というメッセージが表示される? ウィザードは、エージェントがオンライン接続を確立し、かつ少なくとも1つの保存済みクエリが存在する場合にのみ開きます。ページには、3つの条件のうちどれが不足しているかが表示され、該当箇所へのリンクが表示されます。
-
Anvil.worksに接続します
の上 ステップ2 このページでは Anvil 側の手順を説明します: Query Streams の依存関係コードをアプリに追加します。 設定 → 依存関係 → サードパーティサーバーモジュールを作成します
クエリストリームからコネクタをインポートそしてconnector.init_connector("your key")、そしてクリック 安全な鍵を生成する そのキーを作成するには、 AnvilアプリのURL そして同じ コネクタ認証キー そしてクリック テスト接続アプリには 加速表 (設定 → データテーブル)をオンにすると、ページが自動的にそれを再確認します。 -
行が着地する場所を選択してください
の上 ステップ3 選ぶ データテーブル 行が配置される場所を指定します。空のテーブルが必要な場合は、まず Anvil アプリで作成してください。既に行がある場合は、プレビューが表示され、各同期モードがそれらにどのような影響を与えるかが説明されます。テーブルごとに 1 つの自動化が必要です。
-
クエリを選択し、行がどのように配置されるかを決定します。
の上 ステップ4 開く 保存されたクエリー ステップ1で作成したクエリを一覧表示して選択します。クエリストリームは、そのクエリを一度実行して列を読み込み、返される行数を表示し、2つの選択肢を表示します。
追加・高速追加
クエリを実行するたびに、クエリの行がデータテーブルの末尾に追加されます。更新も削除もされないため、ログ、イベント、履歴などを蓄積するのに最適な方法です。キー列は不要です。変更のない行は再度追加されず、値が変更された行は新しい行として下に追加され、古い行はそのまま残ります。
フル同期・ミラーフルシンク
行は、 鍵 注文IDなどの列。新しい行が追加され、変更された行はそのまま更新され、クエリから返されなくなった行は削除されます。これには、データテーブルに手動で入力された行も含まれるため、手動で入力された行は別のデータテーブルに保持してください。これは、在庫、パイプライン、マスターデータ、ダッシュボードに適しています。
フル同期は列ごとに設定されるため、共有データテーブルで非常に役立ちます。
- 鍵
- 行を識別する列、例えば 注文IDクエリ結果内で一意である必要があります。クエリ ストリームはそれを自動的にチェックし、重複を拒否します。
- 同期
- Snowflakeから実行されるたびに上書きされます。Anvil.worksで同期列を編集した場合、次の実行時に元の値が復元されます。
- 保存する
- 行が最初に到着したときに書き込まれ、その後は比較されないため、Snowflake で変更されても更新はトリガーされません。チームが手動で入力するメモ、担当者、フォローアップの日付については、クエリにまったく含まれていない列を使用してください。Anvil.works にのみ存在する列は、同期によって変更されることはありません。
どちらが速いですか? 追加モードでは、データテーブルを読み込むことなく書き込みが行われます。完全同期モードでは、データテーブルを読み込み、すべての行を比較し、差分のみを書き込むため、処理時間は長くなりますが、データテーブルは常にクエリと一致します。これらのモードは、自動化設定の編集パネルから後から切り替えることができます。
信頼できるデータテーブルについては、こちらをクリックしてください。 すべての列を同期として作成する次に、鍵のアイコンをクリックします。 注文ID それを実現するために 鍵クエリ ストリームは結果全体をスキャンしてキーが一意であることを確認し、一意でない場合は警告します。クエリの一部ではない列にチーム独自のメモを残してください。それらの列は決して変更されません。常に増加するログについては、ここをクリックしてください。 すべての列を保持するように作成します 代わりに、キーをスキップします。クリックします。 続く.
-
スケジュールを設定し、名前を付け、作成します
の上 ステップ5 選ぶ スケジュール通りに実行する そして選ぶ 頻度:
頻度 走る 5分ごとに 5分ごとに、最速で許可されている 15分ごとに 15分ごと 30分ごと 30分ごと 毎時間 毎時ちょうどに 毎日午前9時 毎日午前9時、デフォルト 毎日午前6時 毎日午前6時 平日午前9時 月曜日から金曜日の午前9時 毎週(月曜日午前9時) 毎週月曜日午前9時 カスタムスケジュール あなた自身の分、時間、曜日、または日付 時代は続く タイムゾーン 選択すると、ブラウザの起動時に表示されます。 マニュアルのみ そして押す 走る いつでも好きな時に実行できます。スケジュールは後から自動化の編集パネルから追加できます。スケジュールされた実行はエージェント上で実行されるため、ブラウザを閉じても実行は継続されます。実行予定時刻にエージェントを実行しているコンピュータの電源がオフになっている場合、実行されなかった分はエージェントが再起動した直後に一度だけ実行されます。
与えて 統合名「Anvil.worksへの注文、毎日」など、 創作の準備はできましたか? 概要とクリック 自動化を作成するオートメーションページに戻り、 走る スケジュールを待たずに、今すぐ最初の同期を実行してください。Anvil.worksを開くと、列ヘッダーの下に該当する行が表示されます。
それでおしまい。 今後は、データテーブルが自動的に最新の状態に保たれます。クエリが返した行データ以外はネットワークから何も送信されず、誰も何かを実行することを覚えておく必要もありません。
その後に目にするもの
の 自動化ページ すべての自動化をステータス、ソース、ターゲット、キー、スケジュール、最終同期、行数とともに一覧表示します。 処刑 タブ:トリガー(手動またはスケジュール)、実行時間、作成、更新、削除、変更された行を含むすべての実行。 パフォーマンス このタブには、7日から90日間に処理されたデータ量と成功率が表示されます。
停止した時に通知されます
すべての組織には 同期の問題 初日から適用されるアラートルール:同期が失敗した場合、アプリ内通知とメールが送信され、復旧した場合にも再度通知が送信されます。1件のインシデントにつき1つのメッセージが送信され、再試行のたびにメッセージが送信されることはありません。この機能をオフにするか、ストリーム → アラートとレポートでチャンネルを変更してください。
一時停止すべき時に一時停止する
Anvil.worksが接続を受け付けなくなった場合、またはデータコネクタが削除された場合、自動化処理は一時停止し、その理由が表示されます。再接続するか、新しいソースを選択して「再開」を押してください。その他のエラーが発生した場合は、スケジュールは継続され、該当行に表示されます。
キーは一意である必要があります
フル同期を実行する前に、Query Streams はクエリ結果のキー値が一意であることを確認し、一意でない場合は実行を拒否します。これにより、書き込み途中のデータがデータ テーブルに書き込まれるのを防ぎます。キー列は Anvil に保持してください。クエリが認識していない列は、同期によって削除されることはありません。
計画で許可されている内容
自動化機能は無料プランを含むすべてのプランで利用可能で、作成できる自動化の数に制限はありません。ただし、各プランで制限されるのは、1回の実行で1つのクエリが返すことができる行数です。
| プラン | 1回の実行あたりの行数 |
|---|---|
| 無料 | 125 |
| 個人的な核心 | 500 |
| パーソナルプラス | 1,000 |
| ビジネスコア | 2,500 |
| ビジネスプラス | 5,000 |
| ビジネスマックス | 10,000 |
| エンタープライズコア | 25,000 |
| エンタープライズプラス | 100,000 |
| エンタープライズマックス | 250,000 |
クエリがより多くのデータを返す場合、実行は途中で中断されるのではなく保留され、自動化システムはどのプランが適切か、または日付範囲などのフィルターを追加することを提案します。正常に実行された各実行は、Excel および Sheets クエリで使用されるのと同じデータ レルムの割り当て量にカウントされます。 価格ページをご覧ください 手当のために。
良い次の動き
- フィルターを追加する クエリに対して、例えば過去90日間といった条件を指定することで、データテーブルのサイズを小さく保ち、処理速度を向上させ、プランの行数制限に適合させます。
- 手書きのメモは専用の列に記入してください。クエリの外側にあるため、すべての同期で存続します。
- 自動化をグループ化する いくつか設定したら、編集パネルから「自動化」ページをグループごとにフィルタリングします。
人々が尋ねる質問
同期処理によって、私のチームがAnvil.worksに追加したメモは上書きされますか?
メモが独自の列にある場合はそうではありません。Anvil.works にのみ存在し、クエリには存在しない列は変更されないため、同期された列の横にメモまたは所有者列を追加してそこに入力してください。 同期 実行のたびに、Snowflakeの値に戻されます。 保存する 行が最初に到着したときに列にデータが入力され、その後は比較されません。
Snowflakeのデータはクエリストリームに保存されますか?
いいえ。エージェントはお客様側でクエリを実行し、暗号化されたリンクを介して行をAnvil.worksに直接送信します。Query Streamsは、構成、スケジュール、および実行ごとの行数を保持しますが、行自体は保持しません。
コンピューターは電源を入れたままにしておく必要がありますか?
エージェントを実行しているコンピューターがクエリを実行し、Anvil.worksに書き込むため、エージェントが実行されます。ご自身のノートパソコンやブラウザは閉じても構いません。実行予定時刻にコンピューターの電源が切れている場合、実行が中断されたとしても、エージェントが再起動した直後に一度だけ実行されます。
後でクエリを変更できますか?
はい。クエリビルダーで編集して保存すると、次回の実行時に自動的に新しいバージョンが使用されます。列を追加または削除した場合は、オートメーションの編集パネルを開いてマッピングしてください。
2つの自動化プロセスが同じデータテーブルに書き込むことはできますか?
いいえ、データテーブルごとに自動化は1つだけです。2つ目の自動化を別のデータテーブルに向けるか、最初の自動化の背後にあるクエリを拡張してください。
無料プランで本当にこれがカバーされるのですか?
はい。無料プランは、期限切れのトライアルではなく、継続して利用できるプランです。自動化はすべてのプランに含まれています。プランによって異なるのは、1回の実行で1つのクエリが返すことができる行数です。無料プランに含まれる内容については、 価格ページ.
関連ガイド
すべてのガイド Snowflake
Setup trouble?
- Want the Agent to sign in with a login that can only read? Create a read-only database user, with copy-paste SQL for each database → Create a read-only database user
- Agent shows Offline, or Test connection and Browse are greyed out? Check that the Agent is online → Is the Agent online?

