ביצוע קריאת REST ל-API ציבורי

באמצעות המשימה Call REST Endpoint (קריאה לנקודת קצה של REST), מבצעים קריאה ל-https://mocktarget.apigee.net/json ושומרים את התגובה במשתנה JSON.

דוגמת קוד

{
  "triggerConfigs": [{
    "label": "API Trigger",
    "startTasks": [{
      "taskId": "1"
    }],
    "properties": {
      "Trigger name": "CallRestEndpointDemo_API_1"
    },
    "triggerType": "API",
    "triggerNumber": "1",
    "triggerId": "api_trigger/CallRestEndpointDemo_API_1"
  }],
  "taskConfigs": [{
    "task": "GenericRestV2Task",
    "taskId": "1",
    "parameters": {
      "throwError": {
        "key": "throwError",
        "value": {
          "booleanValue": true
        }
      },
      "responseBody": {
        "key": "responseBody",
        "value": {
          "stringArray": {
            "stringValues": ["$`Task_1_responseBody`$"]
          }
        }
      },
      "disableSSLValidation": {
        "key": "disableSSLValidation",
        "value": {
          "booleanValue": false
        }
      },
      "httpParams": {
        "key": "httpParams"
      },
      "responseHeader": {
        "key": "responseHeader",
        "value": {
          "stringArray": {
            "stringValues": ["$`Task_1_responseHeader`$"]
          }
        }
      },
      "userAgent": {
        "key": "userAgent",
        "value": {
          "stringValue": ""
        }
      },
      "httpMethod": {
        "key": "httpMethod",
        "value": {
          "stringValue": "GET"
        }
      },
      "responseStatus": {
        "key": "responseStatus",
        "value": {
          "stringArray": {
            "stringValues": ["$`Task_1_responseStatus`$"]
          }
        }
      },
      "url": {
        "key": "url",
        "value": {
          "stringValue": "https://mocktarget.apigee.net/json"
        }
      },
      "urlFetchingService": {
        "key": "urlFetchingService",
        "value": {
          "stringValue": "HARPOON"
        }
      },
      "useSSL": {
        "key": "useSSL",
        "value": {
          "booleanValue": false
        }
      },
      "requestorId": {
        "key": "requestorId",
        "value": {
          "stringValue": ""
        }
      },
      "urlQueryStrings": {
        "key": "urlQueryStrings"
      },
      "requestBody": {
        "key": "requestBody",
        "value": {
          "stringValue": ""
        }
      },
      "followRedirects": {
        "key": "followRedirects",
        "value": {
          "booleanValue": true
        }
      },
      "additionalHeaders": {
        "key": "additionalHeaders"
      }
    },
    "nextTasks": [{
      "taskId": "2"
    }],
    "taskExecutionStrategy": "WHEN_ALL_SUCCEED",
    "displayName": "Call REST Endpoint"
  }, {
    "task": "FieldMappingTask",
    "taskId": "2",
    "parameters": {
      "FieldMappingConfigTaskParameterKey": {
        "key": "FieldMappingConfigTaskParameterKey",
        "value": {
          "jsonValue": "{\n  \"@type\": \"type.googleapis.com/enterprise.crm.eventbus.proto.FieldMappingConfig\",\n  \"mappedFields\": [{\n    \"inputField\": {\n      \"fieldType\": \"JSON_VALUE\",\n      \"transformExpression\": {\n        \"initialValue\": {\n          \"referenceValue\": \"$`Task_1_responseBody`$\"\n        },\n        \"transformationFunctions\": [{\n          \"functionType\": {\n            \"stringFunction\": {\n              \"functionName\": \"TO_JSON\"\n            }\n          }\n        }]\n      }\n    },\n    \"outputField\": {\n      \"referenceKey\": \"$OutputJson$\",\n      \"fieldType\": \"JSON_VALUE\",\n      \"cardinality\": \"OPTIONAL\"\n    }\n  }]\n}"
        }
      }
    },
    "taskExecutionStrategy": "WHEN_ALL_SUCCEED",
    "displayName": "Data Mapping"
  }],
  "integrationParameters": [{
    "key": "`Task_1_responseHeader`",
    "dataType": "STRING_VALUE",
    "displayName": "`Task_1_responseHeader`",
    "isTransient": true,
    "producer": "1_1"
  }, {
    "key": "`Task_1_responseBody`",
    "dataType": "STRING_VALUE",
    "displayName": "`Task_1_responseBody`",
    "isTransient": true,
    "producer": "1_1"
  }, {
    "key": "`Task_1_responseStatus`",
    "dataType": "STRING_VALUE",
    "displayName": "`Task_1_responseStatus`",
    "isTransient": true,
    "producer": "1_1"
  }, {
    "key": "OutputJson",
    "dataType": "JSON_VALUE",
    "displayName": "OutputJson",
    "inputOutputType": "OUT"
  }]
}

זרימת שילוב לדוגמה

בתמונה הבאה מוצגת פריסה לדוגמה של כלי העריכה של השילוב, עבור דוגמת קוד השילוב הזו.

תמונה שמציגה את זרימת השילוב לדוגמה תמונה שמציגה את זרימת השילוב לדוגמה

העלאה והרצה של השילוב לדוגמה

כדי להעלות ולהריץ את השילוב לדוגמה:

  1. שומרים את הדוגמה לשילוב כקובץ ‎ .json במערכת.
  2. במסוף Google Cloud, עוברים לדף Application Integration.

    מעבר אל Application Integration

  3. בתפריט הניווט שמימין, לוחצים על שילובים כדי לפתוח את הדף שילובים.
  4. בוחרים שילוב קיים או יוצרים שילוב חדש באמצעות לחיצה על יצירת שילוב.

    אם יוצרים שילוב חדש:

    1. מזינים שם ותיאור בתיבת הדו-שיח יצירת שילוב.
    2. בוחרים אזור לשילוב.
    3. בוחרים חשבון שירות לאינטגרציה. אפשר לשנות או לעדכן את פרטי חשבון השירות של שילוב בכל שלב מחלונית סיכום השילוב בסרגל הכלים של השילוב.
    4. לוחצים על יצירה.

    השילוב ייפתח בכלי לעריכת שילובים.

  5. בכלי לעריכת שילובים, לוחצים על תפריט העלאה/הורדה ואז בוחרים באפשרות העלאת שילוב.
  6. בתיבת הדו-שיח של סייר הקבצים, בוחרים את הקובץ ששמרתם בשלב 1 ולוחצים על פתיחה.

    נוצרת גרסה חדשה של השילוב באמצעות הקובץ שהועלה.

  7. בעורך השילובים, לוחצים על בדיקה.
  8. לוחצים על Test integration (בדיקת השילוב). הפעולה הזו מריצה את השילוב ומציגה את תוצאת ההרצה בחלונית Test Integration.