Snowflake - Replicate rows (行の複製) アクション ​

このアクションは、Snowflake インスタンス内の選択されたテーブルを更新します。リストデータピルを入力として受け取り、それらを行として挿入または更新します。

Workato はまず、入力データと Snowflake テーブルのスキーマを検出して比較します。それらが一致しない場合、このアクションは Snowflake テーブル内に新しい列を作成します。これにより、入力スキーマに更新があった場合でも、入力のすべてのデータが Snowflake に自動的に同期されるようになります。

• スキーマの検出は、バッチ入力データの各項目の値を検査し、それを適切な列のタイプにマッピングすることで実行されます。複数のタイプが見つかった場合、精度の損失を防ぐために最も広範な列のタイプが推測されます。作成される列のタイプを指定したい場合は、Replicate Schema アクションの使用を検討してください。

• 指定した宛先のテーブルが存在しない場合は作成されます。

• このアクションでは、ソースデータに特定の列のデータが含まれなくなった場合でも、宛先のテーブル内の既存の列が削除されることはありません。

• このアクションは既存の列のデータ型を変更しません。

Replicate rows アクション

入力 ​

テーブル名のベストプラクティス ​

テーブル名をテキストで入力する場合、テーブル名では大文字と小文字が区別され、大文字のテーブル名の使用が推奨されることに留意してください。

テーブル名を二重引用符で囲むと大文字と小文字が区別されます (二重引用符で囲まれた識別子に関する説明を参照)。これにより、必要に応じてテーブル名で特殊文字を柔軟に使用できます。

クエリーを簡単にするため、テーブル名には大文字を使用することをお勧めします。そうすることで、Snowflake ユーザーは大文字と小文字を区別しない引用符なしの識別子を使用してクエリーを作成できるようになります。これは、Snowflake では識別子を大文字で格納および解決するためです。

平坦化を使用するタイミング ​

データをオブジェクトとして書式設定している場合、ネストされたデータに直接アクセスできない場合があります (JSON オブジェクト内にネストされたデータなど)。

オブジェクトを平坦化し、個々のキーと値のペアを一意の列として扱うには、[Flatten columns] のトグルを使用します。

デフォルトでは、このアクションは、ネストされたデータの1つのレベルのみを平坦化します。平坦化するレベルの数は最大50まで設定できます。

データソースの例を以下に示します。

{
  "id": 1,
  "name": "John Doe",
  "handles": {
    "github": "johndoe",
    "slack": "john"
  }
}

平坦化されていない行は以下のようになります。

平坦化された行は以下のようになります。

[Column case] (列の大文字と小文字) のオプション ​

Upcase (推奨) ​

列名は大文字にすることをお勧めします。そうすることで、Snowflake ユーザーが列の大文字と小文字を気にせずにクエリーを作成できるようになり、データのクエリー実行時のエクスペリエンスが向上します。これは、Snowflake では識別子を大文字で格納および解決するためです。

このアクションは、二重引用符で囲まれた識別子で列を作成するため、非標準の文字 (特殊文字、空白文字、ASCII など) を含む項目名が忠実に複製されます。

Preserve original ​

[Preserve original] に設定すると、SQL クエリーでは正確な大文字と小文字を使用して列を参照する必要があります (以下の例を参照)。

例 ​

# Given that source data has a key "AccountId"

# When Column_Case is "Upcase" or blank
SELECT AccountId FROM mytable;   // OK
SELECT accountid FROM mytable;   // OK
SELECT "ACCOUNTID" FROM mytable; // OK

# When Column_Case is "Preserve original"
SELECT AccountId FROM mytable;   // will fail
SELECT accountid FROM mytable;   // will fail
SELECT "AccountId" FROM mytable; // OK

出力 ​

このアクションの出力は、アップサートされた行の数です。

Workato スキーママッパー ​

各データソース (API、データベース、ファイル) には独自のスキーマがあります。一貫性を保つために、このアクションはソースの各データ型を Snowflake テーブルスキーマにマップします。このマッピングは、Snowflake テーブルを作成/更新する前に行われます。

入力データは以下で定義されるマッピングに基づいて Snowflake データ型に変換されます。