Webes tevékenység az Azure Data Factoryben és az Azure Synapse Analyticsben

A következőkre vonatkozik: Azure Data Factory Azure Synapse Analytics

A webes tevékenység segítségével meghívható egy egyéni REST-végpont egy Azure Data Factory-ból vagy Synapse-folyamatból. Az adatkészleteket és a társított szolgáltatásokat továbbíthatja a tevékenység számára felhasználásra vagy elérés céljára.

Webes tevékenység létrehozása felhasználói felülettel

Ha webes tevékenységet szeretne használni egy folyamatban, hajtsa végre a következő lépéseket:

1. Keressen webet a folyamattevékenységek panelen, és húzzon egy webes tevékenységet a folyamatvászonra.

2. Jelölje ki az új webes tevékenységet a vásznon, ha még nincs kijelölve, és a Beállítások fület a részletek szerkesztéséhez.

   

3. Adjon meg egy URL-címet, amely lehet konstans URL-sztring, vagy dinamikus kifejezések, függvények, rendszerváltozók vagy más tevékenységek kimenetei bármilyen kombinációja. Adja meg a kéréssel elküldendő egyéb adatokat.

4. Használja a tevékenység kimenetét bármely más tevékenység bemeneteként, és hivatkozzon arra a kimenetre, ahol a dinamikus tartalom támogatott a céltevékenységben.

Syntax

{
   "name":"MyWebActivity",
   "type":"WebActivity",
   "typeProperties":{
      "method":"Post",
      "url":"<URLEndpoint>",
      "httpRequestTimeout": "00:01:00"
      "connectVia": {
          "referenceName": "<integrationRuntimeName>",
          "type": "IntegrationRuntimeReference"
      }
      "headers":{
         "Content-Type":"application/json"
      },
      "authentication":{
         "type":"ClientCertificate",
         "pfx":"****",
         "password":"****"
      },
      "datasets":[
         {
            "referenceName":"<ConsumedDatasetName>",
            "type":"DatasetReference",
            "parameters":{
               ...
            }
         }
      ],
      "linkedServices":[
         {
            "referenceName":"<ConsumedLinkedServiceName>",
            "type":"LinkedServiceReference"
         }
      ]
   }
}

Típustulajdonságok

Az alábbi táblázat a JSON-tartalomra vonatkozó követelményeket mutatja be:

Hitelesítés

Az alábbiakban a webes tevékenység támogatott hitelesítési típusai találhatók.

Egyik sem

Ha nincs szükség hitelesítésre, ne tartalmazza a "authentication" tulajdonságot.

Alap

Adja meg az alapszintű hitelesítéshez használni kívánt felhasználónevet és jelszót.

"authentication":{
   "type":"Basic",
   "username":"****",
   "password":"****"
}

Ügyféltanúsítvány

Adja meg egy PFX-fájl alap64 kódolású tartalmát és a jelszót.

"authentication":{
   "type":"ClientCertificate",
   "pfx":"****",
   "password":"****"
}

A tanúsítványnak x509-tanúsítványnak kell lennie. A PFX-fájlra való konvertáláshoz használhatja a kedvenc segédprogramját. A base-64 kódoláshoz használhatja a következő PowerShell-kódrészletet.

$fileContentBytes = get-content 'enr.dev.webactivity.pfx' -AsByteStream

[System.Convert]::ToBase64String($fileContentBytes) | Out-File ‘pfx-encoded-bytes.txt’

Felügyelt identitás

Adja meg azt az erőforrás-uri-t, amelyhez a hozzáférési jogkivonatot a data factory vagy a Synapse-munkaterület példányának felügyelt identitásával kéri le a rendszer. Az Azure Resource Management API meghívásához használja a következőt https://management.azure.com/: . A felügyelt identitások működésével kapcsolatos további információkért tekintse meg az Azure-erőforrások felügyelt identitásainak áttekintési oldalát.

"authentication": {
	"type": "MSI",
	"resource": "https://management.azure.com/"
}

Szolgáltatásnév

Adja meg a bérlőazonosítót, a szolgáltatásnév azonosítóját és a szolgáltatásnévkulcsot az ügyfél titkos kódjának biztonságos sztringjével.

"authentication": {
            "type": "ServicePrincipal",
            "tenant": "your_tenant_id",
            "servicePrincipalId": "your_client_id",
            "servicePrincipalKey": {
                "type": "SecureString",
                "value": "your_client_secret"
            },
            "resource": "https://management.azure.com/"
}

Hasznos adatséma kérése

A POST/PUT metódus használatakor a törzstulajdonság a végpontnak küldött hasznos adatokat jelöli. A hasznos adatok részeként átadhat társított szolgáltatásokat és adatkészleteket. A hasznos adatok sémája a következő:

{
    "body": {
        "myMessage": "Sample",
        "datasets": [{
            "name": "MyDataset1",
            "properties": {
                ...
            }
        }],
        "linkedServices": [{
            "name": "MyStorageLinkedService1",
            "properties": {
                ...
            }
        }]
    }
}

Példa

Ebben a példában a folyamat webes tevékenysége REST végpontot hív meg. Átad egy Azure SQL-hez társított szolgáltatást és egy Azure SQL-adatkészletet a végpontnak. A REST-végpont az Azure SQL kapcsolati sztring használatával csatlakozik a logikai SQL-kiszolgálóhoz, és visszaadja az SQL Server-példány nevét.

Folyamatdefiníció

{
    "name": "<MyWebActivityPipeline>",
    "properties": {
        "activities": [
            {
                "name": "<MyWebActivity>",
                "type": "WebActivity",
                "typeProperties": {
                    "method": "Post",
                    "url": "@pipeline().parameters.url",
                    "headers": {
                        "Content-Type": "application/json"
                    },
                    "authentication": {
                        "type": "ClientCertificate",
                        "pfx": "*****",
                        "password": "*****"
                    },
                    "datasets": [
                        {
                            "referenceName": "MySQLDataset",
                            "type": "DatasetReference",
                            "parameters": {
                                "SqlTableName": "@pipeline().parameters.sqlTableName"
                            }
                        }
                    ],
                    "linkedServices": [
                        {
                            "referenceName": "SqlLinkedService",
                            "type": "LinkedServiceReference"
                        }
                    ]
                }
            }
        ],
        "parameters": {
            "sqlTableName": {
                "type": "String"
            },
            "url": {
                "type": "String"
            }
        }
    }
}

Folyamatparaméter-értékek

{
    "sqlTableName": "department",
    "url": "https://adftes.azurewebsites.net/api/execute/running"
}

Webszolgáltatás végpontkódja

[HttpPost]
public HttpResponseMessage Execute(JObject payload)
{
    Trace.TraceInformation("Start Execute");

    JObject result = new JObject();
    result.Add("status", "complete");

    JArray datasets = payload.GetValue("datasets") as JArray;
    result.Add("sinktable", datasets[0]["properties"]["typeProperties"]["tableName"].ToString());

    JArray linkedServices = payload.GetValue("linkedServices") as JArray;
    string connString = linkedServices[0]["properties"]["typeProperties"]["connectionString"].ToString();

    System.Data.SqlClient.SqlConnection sqlConn = new System.Data.SqlClient.SqlConnection(connString);

    result.Add("sinkServer", sqlConn.DataSource);

    Trace.TraceInformation("Stop Execute");

    return this.Request.CreateResponse(HttpStatusCode.OK, result);
}

Kapcsolódó tartalom

Lásd az egyéb támogatott vezérlési folyamatokat:

• Folyamat végrehajtása tevékenység
• Minden tevékenységhez
• Metaadatok beolvasása tevékenység
• Keresési tevékenység