Salesforceの連絡先情報をJavaScriptで検証し、Snowflakeにアップサートするレシピ ​

作成 > コネクションをクリックするか、Cを2回押します。

新規コネクションページでSalesforceを検索して選択します。

コネクション名フィールドにコネクションの名前を入力します。

Salesforceコネクションのセットアップ

ロケーションドロップダウンメニューを使用して、コネクションを保存するプロジェクトを選択します。

Auth typeドロップダウンメニューを使用して認証方法を選択します。デフォルトはOAuth 2.0です。

サンドボックスドロップダウンメニューを使用して、Salesforceアカウントがサンドボックスアカウントかどうかを指定します。

任意です。詳細設定を展開して、高度なコネクションオプションを設定します。

任意です。 Custom OAuth profileドロップダウンメニューを使用して、コネクション用のCustom OAuth profileを選択します。

• このCustom OAuth profileにより、コネクションは、そのプロファイルを使用するすべてのユーザーに対して選択した同じスコープセットに制限され、認証フローではCustom OAuth profileにリンクされたクライアントアプリが使用されます。

接続をクリックします。

Salesforceアカウントの認証情報を入力し、Log Inをクリックします。

Salesforceアカウントにログインする

作成 > コネクションをクリックするか、Cを2回押します。

新規コネクションページでSnowflakeを検索して選択します。

コネクション名フィールドにコネクションの名前を入力します。

Snowflakeコネクションのセットアップ

ロケーションドロップダウンメニューを使用して、コネクションを保存するプロジェクトを選択します。

アカウント識別子フィールドにアカウント識別子を入力します。 Snowflakeには、アカウントを識別する複数の方法があります。 Workatoはすべての方法をサポートしています:

• アカウント名: https://{org.name}-{account_name}
• コネクション名: https://{org.name}-{connectionname}
• アカウントロケーター: https://{account.locator}.{region}.{cloud}

アカウントロケーターを使用している場合、{region}と{cloud}は特定のロケーションでのみ必要であることに注意してください。例:

• アカウントがAWS US West（Oregon）でホストされている場合は、your-account-locatorを使用します。
• アカウントがAWS US East（Ohio）でホストされている場合は、your-account-locator.us-east-2を使用します。
• アカウントがAzure West Europeでホストされている場合は、your-account-locator.west-europe.azureを使用します。

ウェアハウスフィールドに、このコネクションのすべてのオペレーションを実行する予定のウェアハウスのフルネームを入力します。例: compute_wh。

データベース名フィールドに、レシピコネクションで使用する予定のデータベースを入力します。

認証タイプドロップダウンメニューを使用して、認証タイプを選択します。

• ユーザー名/パスワード: このオプションを選択した場合は、ユーザー名とパスワードを入力します。
• OAuth 2.0: このオプションを選択した場合は、Client IDとClient Secretを入力します。

接続をクリックします。

Salesforceを検索し、アプリとして選択します。

Salesforceを選択

New recordsトリガーを選択します。

New recordsバッチトリガーを選択

前の手順で作成したSalesforceコネクションを選択します。

Objectドロップダウンメニューを使用して、新しいレコードを監視するSalesforceオブジェクトとしてContactを選択します。

任意です。 Fields to retrieveドロップダウンメニューを使用して、取得するフィールドを指定します。この例では、次のフィールドを選択します。

• 連絡先ID
• アカウントID
• 姓
• 名
• 勤務先電話
• メール

取得するフィールドを指定

Batch sizeフィールドにバッチサイズを入力します。デフォルトは100で、最大値はバッチあたり2000レコードです。

任意です。 Show optional fieldsをクリックし、Trigger poll intervalを選択して、Apply changesをクリックします。

Trigger poll intervalを設定

任意です。 Trigger poll intervalドロップダウンメニューを使用して、このレシピがSalesforceの新しい連絡先をチェックする頻度を指定します。この例では1 dayを選択します。

保存をクリックします。

JavaScript snippets by Workatoを検索し、アプリとして選択します。

JavaScript snippets by Workatoを選択

Execute codeアクションを選択します。

Execute codeアクションを選択

NameフィールドにValidate contactsと入力します。これにより、レシピエディター内のアクション名が変更されます。

Nameフィールドを設定

Input fieldsに移動し、Add fieldを選択します。

ContactsフィールドをFormulaモードに切り替えます。

Salesforceの連絡先ステップ 1リストデータピルをContactsフィールドにマッピングします。 ContactsフィールドをFormulaモードに切り替えない限り、このデータピルはマッピングできません。

連絡先ステップ 1データピルをマッピング

Output fieldsに移動し、プレースホルダーフィールドを作成します。

Edit schemaをクリックします。

次のJSONスキーマをコピーして貼り付け、既存のスキーマを置き換えます:

[
  {
    "name": "val_contacts",
    "type": "array",
    "of": "object",
    "label": "Val contacts",
    "properties": [
      {
        "properties": [
          {
            "control_type": "text",
            "label": "Type",
            "type": "string",
            "name": "type"
          },
          {
            "control_type": "text",
            "label": "URL",
            "type": "string",
            "name": "url"
          }
        ],
        "label": "Attributes",
        "type": "object",
        "name": "attributes"
      },
      {
        "control_type": "text",
        "label": "Account ID",
        "type": "string",
        "name": "AccountId"
      },
      {
        "control_type": "text",
        "label": "Phone",
        "type": "string",
        "name": "Phone"
      },
      {
        "control_type": "text",
        "label": "ID",
        "type": "string",
        "name": "Id"
      },
      {
        "control_type": "text",
        "label": "Email",
        "type": "string",
        "name": "Email"
      },
      {
        "control_type": "text",
        "label": "First name",
        "type": "string",
        "name": "FirstName"
      },
      {
        "control_type": "text",
        "label": "Last name",
        "type": "string",
        "name": "LastName"
      },
      {
        "control_type": "text",
        "label": "Valid",
        "render_input": {},
        "parse_output": {},
        "toggle_hint": "Select from option list",
        "toggle_field": {
          "label": "Valid",
          "control_type": "text",
          "toggle_hint": "Use custom value",
          "type": "boolean",
          "name": "valid"
        },
        "type": "boolean",
        "name": "valid"
      }
    ]
  },
  {
    "name": "bad_contacts",
    "type": "array",
    "of": "object",
    "label": "Bad contacts",
    "properties": [
      {
        "properties": [
          {
            "control_type": "text",
            "label": "Type",
            "type": "string",
            "name": "type"
          },
          {
            "control_type": "text",
            "label": "URL",
            "type": "string",
            "name": "url"
          }
        ],
        "label": "Attributes",
        "type": "object",
        "name": "attributes"
      },
      {
        "control_type": "text",
        "label": "Account ID",
        "type": "string",
        "name": "AccountId"
      },
      {
        "control_type": "text",
        "label": "Phone",
        "type": "string",
        "name": "Phone"
      },
      {
        "control_type": "text",
        "label": "ID",
        "type": "string",
        "name": "Id"
      },
      {
        "control_type": "text",
        "label": "Email",
        "type": "string",
        "name": "Email"
      },
      {
        "control_type": "text",
        "label": "First name",
        "type": "string",
        "name": "FirstName"
      },
      {
        "control_type": "text",
        "label": "Last name",
        "type": "string",
        "name": "LastName"
      },
      {
        "control_type": "text",
        "label": "Valid",
        "render_input": {},
        "parse_output": {},
        "toggle_hint": "Select from option list",
        "toggle_field": {
          "label": "Valid",
          "control_type": "text",
          "toggle_hint": "Use custom value",
          "type": "boolean",
          "name": "valid"
        },
        "type": "boolean",
        "name": "valid"
      }
    ]
  },
  {
    "control_type": "text",
    "label": "Log",
    "type": "string",
    "name": "log"
  }
]

Updateをクリックして、新しいJSONスキーマを適用します。 Output fieldsの下の一覧をスクロールして、新しく適用されたスキーマ出力を確認できます:

Output fields

Salesforceから取得してSnowflakeにアップサートするフィールドに基づいて、このスキーマを変更できます。

Codeフィールドの内容をクリアします。

次のJavaScriptコードをコピーして、Codeフィールドに貼り付けます:

const _ = require("lodash");

class ContactValidator {
  static validContact = (phone) => {
    return this.validPhoneNumber(phone);
  };

  static validPhoneNumber = (phone) => {
    let phone_regex = /^\(?\d{3}\)?[-.\s]?\d{3}[-.\s]?\d{4}$/;
    return phone ? phone_regex.test(phone) : false;
  };

  static validate = function(contacts) {
    const bad_contacts = [];
    const val_contacts = _.filter(contacts, (contact) => {
      let phone = _.get(contact, 'Phone');
      const isValid = this.validContact(phone);
      contact['valid'] = isValid;

      if (!isValid) {
        bad_contacts.push(contact); // Add invalid contact to the array
        return false;  // Don't include invalid contacts in val_contacts
      }
      return true;  // Include only valid contacts in val_contacts
    });

    // Create a log message based on the bad contacts
    const logMessage = bad_contacts.length > 0
      ? `The following contacts were not replicated due to invalid phone numbers: ${bad_contacts.map(c => `${c.FirstName} ${c.LastName} (${c.Phone})`).join(', ')}`
      : 'All contacts were valid and successfully replicated.';

    return { val_contacts, bad_contacts, log: logMessage };
  };
}

exports.main = ({ contacts }) => {
  return ContactValidator.validate(contacts);
};

保存をクリックします。

Snowflakeを検索し、アプリとして選択します。

Snowflakeを選択

Replicate rowsアクションを選択します。

Replicate rowsバッチアクションを選択

前の手順で作成したSnowflakeコネクションを選択します。

Tableドロップダウンメニューを使用して、行をレプリケートするSnowflakeテーブルを選択します。

行フィールドがFormulaモードに切り替わっていることを確認し、JavaScript snippets by Workatoの有効な連絡先ステップ 2データピルをマッピングします。

有効な連絡先ステップ 2データピルをマッピング

Flatten columnsドロップダウンメニューを使用して、Yesを選択します。

Flatten levelフィールドに1と入力します。

Unique keysドロップダウンメニューを使用して、重複する行を識別する1つ以上の一意キーを選択します。この例では、一意キーとしてID（連絡先ID）を選択します。

一意キーを選択

任意です。 Exclude columnsドロップダウンメニューを使用して、行のレプリケート時に除外する列を選択します。この例ではAttributesとValidを選択します。

アップサートから除外する列を選択

保存をクリックします。

Data fieldをFormulaモードに切り替えます。

JavaScript snippets by Workatoの不正な連絡先ステップ 2データピルをデータフィールドにマッピングします。

.length Formulaを追加します。

Conditionドロップダウンメニューを使用して、greater thanを選択します。

ValueフィールドをFormulaモードに切り替え、0と入力します。

IF条件を設定

保存をクリックします。

Email by Workatoを検索し、アプリとして選択します。

Email by Workatoを選択

メールを送信アクションを選択します。

Send emailアクションを選択

Toフィールドに受信者のメールアドレスを入力します。

Subjectフィールドに件名を入力します。例: Salesforce Contacts Not Replicated into Snowflake Due to Invalid Data

Email typeドロップダウンメニューを使用して、テキストを選択します。

JavaScript snippets by Workatoのログステップ 2データピルをメッセージフィールドにマッピングします。

メッセージを設定

保存をクリックします。