Data Connections - Create Or Update

Başvuru

Hizmet:: Azure Kusto

API Sürümü:: 2024-04-13

Veri bağlantısı oluşturur veya güncelleştirir.

PUT https://management.azure.com/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Kusto/clusters/{clusterName}/databases/{databaseName}/dataConnections/{dataConnectionName}?api-version=2024-04-13

URI Parametreleri

Name	İçinde	Gerekli	Tür	Description
clusterName	path	True	string pattern: ^.*$	Kusto kümesinin adı.
databaseName	path	True	string pattern: ^.*$	Kusto kümesindeki veritabanının adı.
dataConnectionName	path	True	string pattern: ^.*$	Veri bağlantısının adı.
resourceGroupName	path	True	string minLength: 1 maxLength: 90	Kaynak grubunun adı. Ad büyük/küçük harfe duyarsız.
subscriptionId	path	True	string minLength: 1	Hedef aboneliğin kimliği.
api-version	query	True	string minLength: 1	Bu işlem için kullanılacak API sürümü.

İstek Gövdesi

İstek gövdesi şunlardan biri olabilir:

Name	Description
CosmosDbDataConnection	CosmosDb veri bağlantısını temsil eden sınıf.
EventGridDataConnection	Event Grid veri bağlantısını temsil eden sınıf.
EventHubDataConnection	Olay hub'ı veri bağlantısını temsil eden sınıf.
IotHubDataConnection	IoT hub'ı veri bağlantısını temsil eden sınıf.

CosmosDbDataConnection

CosmosDb veri bağlantısını temsil eden sınıf.

Name	Gerekli	Tür	Description
kind	True	string: CosmosDb	Veri bağlantısı için uç nokta türü
properties.cosmosDbAccountResourceId	True	string	Veri bağlantısını oluşturmak için kullanılan Cosmos DB hesabının kaynak kimliği.
properties.cosmosDbContainer	True	string	Cosmos DB veritabanındaki mevcut bir kapsayıcının adı.
properties.cosmosDbDatabase	True	string	Cosmos DB hesabında var olan bir veritabanının adı.
properties.managedIdentityResourceId	True	string	Yönetilen sistemin veya kullanıcı tarafından atanan kimliğin kaynak kimliği. Kimlik, Cosmos DB ile kimlik doğrulaması yapmak için kullanılır.
properties.tableName	True	string	Kümenizdeki mevcut hedef tablonun büyük/küçük harfe duyarlı adı. Alınan veriler bu tabloya alınır.
location		string	Kaynak konumu.
properties.mappingRuleName		string	Alınan veriler alınırken kullanılacak mevcut eşleme kuralının adı.
properties.retrievalStartDate		string (date-time)	Opsiyonel. Tanımlanmışsa, veri bağlantısı belirtilen alma başlangıç tarihinden sonra oluşturulan veya güncelleştirilen Cosmos DB belgelerini alır.

EventGridDataConnection

Event Grid veri bağlantısını temsil eden sınıf.

Name	Gerekli	Tür	Description
kind	True	string: EventGrid	Veri bağlantısı için uç nokta türü
properties.consumerGroup	True	string	Olay hub'ı tüketici grubu.
properties.eventHubResourceId	True	string	Olay kılavuzunun olayları gönderecek şekilde yapılandırıldığı kaynak kimliği.
properties.storageAccountResourceId	True	string	Verilerin bulunduğu depolama hesabının kaynak kimliği.
location		string	Kaynak konumu.
properties.blobStorageEventType		blobStorageEventType	İşlenmek üzere blob depolama olay türünün adı.
properties.dataFormat		eventGridDataFormat	İletinin veri biçimi. İsteğe bağlı olarak, veri biçimi her iletiye eklenebilir.
properties.databaseRouting		DatabaseRouting	Veri bağlantısından veritabanı yönlendirme bilgileri için gösterge, varsayılan olarak yalnızca veritabanı yönlendirme bilgilerine izin verilir
properties.eventGridResourceId		string	Depolama hesabı olaylarına abone olan olay kılavuzunun kaynak kimliği.
properties.ignoreFirstRecord		boolean	True olarak ayarlanırsa alımın her dosyanın ilk kaydını yoksayması gerektiğini gösteren boole değeri
properties.managedIdentityResourceId		string	Olay hub'ı ve depolama hesabıyla kimlik doğrulaması yapmak için kullanılacak yönetilen kimliğin (sistem veya kullanıcı atanmış) kaynak kimliği.
properties.mappingRuleName		string	Verileri almak için kullanılacak eşleme kuralı. İsteğe bağlı olarak eşleme bilgileri her iletiye eklenebilir.
properties.tableName		string	Verilerin alınması gereken tablo. İsteğe bağlı olarak tablo bilgileri her iletiye eklenebilir.

EventHubDataConnection

Olay hub'ı veri bağlantısını temsil eden sınıf.

Name	Gerekli	Tür	Description
kind	True	string: EventHub	Veri bağlantısı için uç nokta türü
properties.consumerGroup	True	string	Olay hub'ı tüketici grubu.
properties.eventHubResourceId	True	string	Veri bağlantısı oluşturmak için kullanılacak olay hub'ının kaynak kimliği.
location		string	Kaynak konumu.
properties.compression		compression	Olay hub'ı iletileri sıkıştırma türü
properties.dataFormat		eventHubDataFormat	İletinin veri biçimi. İsteğe bağlı olarak, veri biçimi her iletiye eklenebilir.
properties.databaseRouting		DatabaseRouting	Veri bağlantısından veritabanı yönlendirme bilgileri için gösterge, varsayılan olarak yalnızca veritabanı yönlendirme bilgilerine izin verilir
properties.eventSystemProperties		string[]	Olay hub'ının sistem özellikleri
properties.managedIdentityResourceId		string	Olay hub'ı ile kimlik doğrulaması için kullanılacak yönetilen kimliğin (sistem veya kullanıcı atanmış) kaynak kimliği.
properties.mappingRuleName		string	Verileri almak için kullanılacak eşleme kuralı. İsteğe bağlı olarak eşleme bilgileri her iletiye eklenebilir.
properties.retrievalStartDate		string (date-time)	Veri bağlantısı tanımlandığında, Alma başlangıç tarihinden itibaren oluşturulan mevcut Olay hub'ı olaylarını alır. Yalnızca Olay hub'ı tarafından tutulan olayları elde tutma süresine göre alabilir.
properties.tableName		string	Verilerin alınması gereken tablo. İsteğe bağlı olarak tablo bilgileri her iletiye eklenebilir.

IotHubDataConnection

IoT hub'ı veri bağlantısını temsil eden sınıf.

Name	Gerekli	Tür	Description
kind	True	string: IotHub	Veri bağlantısı için uç nokta türü
properties.consumerGroup	True	string	iot hub tüketici grubu.
properties.iotHubResourceId	True	string	Veri bağlantısı oluşturmak için kullanılacak IoT hub'ının kaynak kimliği.
properties.sharedAccessPolicyName	True	string	Paylaşım erişim ilkesinin adı
location		string	Kaynak konumu.
properties.dataFormat		iotHubDataFormat	İletinin veri biçimi. İsteğe bağlı olarak, veri biçimi her iletiye eklenebilir.
properties.databaseRouting		DatabaseRouting	Veri bağlantısından veritabanı yönlendirme bilgileri için gösterge, varsayılan olarak yalnızca veritabanı yönlendirme bilgilerine izin verilir
properties.eventSystemProperties		string[]	iot hub'ının sistem özellikleri
properties.mappingRuleName		string	Verileri almak için kullanılacak eşleme kuralı. İsteğe bağlı olarak eşleme bilgileri her iletiye eklenebilir.
properties.retrievalStartDate		string (date-time)	Veri bağlantısı tanımlandığında, Alma başlangıç tarihinden itibaren oluşturulan mevcut Olay hub'ı olaylarını alır. Yalnızca Olay hub'ı tarafından tutulan olayları elde tutma süresine göre alabilir.
properties.tableName		string	Verilerin alınması gereken tablo. İsteğe bağlı olarak tablo bilgileri her iletiye eklenebilir.

Yanıtlar

Name	Tür	Description
200 OK	DataConnection: EventHubDataConnection IotHubDataConnection EventGridDataConnection CosmosDbDataConnection	Veri bağlantısı başarıyla güncelleştirildi.
201 Created	DataConnection: EventHubDataConnection IotHubDataConnection EventGridDataConnection CosmosDbDataConnection	Veri bağlantısı başarıyla oluşturuldu.
202 Accepted	DataConnection: EventHubDataConnection IotHubDataConnection EventGridDataConnection CosmosDbDataConnection	Veri bağlantısı oluşturma isteği kabul edildi. Üst Bilgiler Azure-AsyncOperation: string
Other Status Codes	ErrorResponse	İşlemin neden başarısız olduğunu açıklayan hata yanıtı.

Örnekler

KustoDataConnectionsCosmosDbCreateOrUpdate

KustoDataConnectionsCreateOrUpdate

KustoDataConnectionsEventGridCreateOrUpdate

KustoDataConnectionsCosmosDbCreateOrUpdate

Örnek isteği

PUT https://management.azure.com/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Kusto/clusters/kustoCluster/databases/KustoDatabase1/dataConnections/dataConnectionTest?api-version=2024-04-13

{
  "location": "westus",
  "kind": "CosmosDb",
  "properties": {
    "tableName": "TestTable",
    "mappingRuleName": "TestMapping",
    "managedIdentityResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
    "cosmosDbAccountResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.DocumentDb/databaseAccounts/cosmosDbAccountTest1",
    "cosmosDbDatabase": "cosmosDbDatabaseTest",
    "cosmosDbContainer": "cosmosDbContainerTest",
    "retrievalStartDate": "2022-07-29T12:00:00.6554616Z"
  }
}


import com.azure.resourcemanager.kusto.models.CosmosDbDataConnection;
import java.time.OffsetDateTime;

/**
 * Samples for DataConnections CreateOrUpdate.
 */
public final class Main {
    /*
     * x-ms-original-file: specification/azure-kusto/resource-manager/Microsoft.Kusto/stable/2024-04-13/examples/
     * KustoDataConnectionsCosmosDbCreateOrUpdate.json
     */
    /**
     * Sample code: KustoDataConnectionsCosmosDbCreateOrUpdate.
     * 
     * @param manager Entry point to KustoManager.
     */
    public static void
        kustoDataConnectionsCosmosDbCreateOrUpdate(com.azure.resourcemanager.kusto.KustoManager manager) {
        manager.dataConnections().createOrUpdate("kustorptest", "kustoCluster", "KustoDatabase1", "dataConnectionTest",
            new CosmosDbDataConnection().withLocation("westus").withTableName("TestTable")
                .withMappingRuleName("TestMapping")
                .withManagedIdentityResourceId(
                    "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1")
                .withCosmosDbAccountResourceId(
                    "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.DocumentDb/databaseAccounts/cosmosDbAccountTest1")
                .withCosmosDbDatabase("cosmosDbDatabaseTest").withCosmosDbContainer("cosmosDbContainerTest")
                .withRetrievalStartDate(OffsetDateTime.parse("2022-07-29T12:00:00.6554616Z")),
            com.azure.core.util.Context.NONE);
    }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

from azure.identity import DefaultAzureCredential

from azure.mgmt.kusto import KustoManagementClient

"""
# PREREQUISITES
    pip install azure-identity
    pip install azure-mgmt-kusto
# USAGE
    python kusto_data_connections_cosmos_db_create_or_update.py

    Before run the sample, please set the values of the client ID, tenant ID and client secret
    of the AAD application as environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID,
    AZURE_CLIENT_SECRET. For more info about how to get the value, please see:
    https://docs.microsoft.com/azure/active-directory/develop/howto-create-service-principal-portal
"""


def main():
    client = KustoManagementClient(
        credential=DefaultAzureCredential(),
        subscription_id="12345678-1234-1234-1234-123456789098",
    )

    response = client.data_connections.begin_create_or_update(
        resource_group_name="kustorptest",
        cluster_name="kustoCluster",
        database_name="KustoDatabase1",
        data_connection_name="dataConnectionTest",
        parameters={
            "kind": "CosmosDb",
            "location": "westus",
            "properties": {
                "cosmosDbAccountResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.DocumentDb/databaseAccounts/cosmosDbAccountTest1",
                "cosmosDbContainer": "cosmosDbContainerTest",
                "cosmosDbDatabase": "cosmosDbDatabaseTest",
                "managedIdentityResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
                "mappingRuleName": "TestMapping",
                "retrievalStartDate": "2022-07-29T12:00:00.6554616Z",
                "tableName": "TestTable",
            },
        },
    ).result()
    print(response)


# x-ms-original-file: specification/azure-kusto/resource-manager/Microsoft.Kusto/stable/2024-04-13/examples/KustoDataConnectionsCosmosDbCreateOrUpdate.json
if __name__ == "__main__":
    main()

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

package armkusto_test

import (
	"context"
	"log"

	"time"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/kusto/armkusto/v2"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/b8adce17dc500f338f86f18af30aac61dcb71c5f/specification/azure-kusto/resource-manager/Microsoft.Kusto/stable/2024-04-13/examples/KustoDataConnectionsCosmosDbCreateOrUpdate.json
func ExampleDataConnectionsClient_BeginCreateOrUpdate_kustoDataConnectionsCosmosDbCreateOrUpdate() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armkusto.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	poller, err := clientFactory.NewDataConnectionsClient().BeginCreateOrUpdate(ctx, "kustorptest", "kustoCluster", "KustoDatabase1", "dataConnectionTest", &armkusto.CosmosDbDataConnection{
		Kind:     to.Ptr(armkusto.DataConnectionKindCosmosDb),
		Location: to.Ptr("westus"),
		Properties: &armkusto.CosmosDbDataConnectionProperties{
			CosmosDbAccountResourceID: to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.DocumentDb/databaseAccounts/cosmosDbAccountTest1"),
			CosmosDbContainer:         to.Ptr("cosmosDbContainerTest"),
			CosmosDbDatabase:          to.Ptr("cosmosDbDatabaseTest"),
			ManagedIdentityResourceID: to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1"),
			MappingRuleName:           to.Ptr("TestMapping"),
			RetrievalStartDate:        to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2022-07-29T12:00:00.655Z"); return t }()),
			TableName:                 to.Ptr("TestTable"),
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res = armkusto.DataConnectionsClientCreateOrUpdateResponse{
	// 	                            DataConnectionClassification: &armkusto.CosmosDbDataConnection{
	// 		Name: to.Ptr("kustoCluster/KustoDatabase1/dataConnectionTest"),
	// 		Type: to.Ptr("Microsoft.Kusto/Clusters/Databases/DataConnections"),
	// 		ID: to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Kusto/Clusters/kustoCluster/Databases/KustoDatabase1/DataConnections/dataConnectionTest"),
	// 		Kind: to.Ptr(armkusto.DataConnectionKindCosmosDb),
	// 		Location: to.Ptr("westus"),
	// 		Properties: &armkusto.CosmosDbDataConnectionProperties{
	// 			CosmosDbAccountResourceID: to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.DocumentDb/databaseAccounts/cosmosDbAccountTest1"),
	// 			CosmosDbContainer: to.Ptr("cosmosDbContainerTest"),
	// 			CosmosDbDatabase: to.Ptr("cosmosDbDatabaseTest"),
	// 			ManagedIdentityObjectID: to.Ptr("87654321-1234-1234-1234-123456789123"),
	// 			ManagedIdentityResourceID: to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1"),
	// 			MappingRuleName: to.Ptr("TestMapping"),
	// 			RetrievalStartDate: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2022-07-29T12:00:00.655Z"); return t}()),
	// 			TableName: to.Ptr("TestTable"),
	// 		},
	// 	},
	// 	                        }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

const { KustoManagementClient } = require("@azure/arm-kusto");
const { DefaultAzureCredential } = require("@azure/identity");
require("dotenv/config");

/**
 * This sample demonstrates how to Creates or updates a data connection.
 *
 * @summary Creates or updates a data connection.
 * x-ms-original-file: specification/azure-kusto/resource-manager/Microsoft.Kusto/stable/2024-04-13/examples/KustoDataConnectionsCosmosDbCreateOrUpdate.json
 */
async function kustoDataConnectionsCosmosDbCreateOrUpdate() {
  const subscriptionId =
    process.env["KUSTO_SUBSCRIPTION_ID"] || "12345678-1234-1234-1234-123456789098";
  const resourceGroupName = process.env["KUSTO_RESOURCE_GROUP"] || "kustorptest";
  const clusterName = "kustoCluster";
  const databaseName = "KustoDatabase1";
  const dataConnectionName = "dataConnectionTest";
  const parameters = {
    cosmosDbAccountResourceId:
      "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.DocumentDb/databaseAccounts/cosmosDbAccountTest1",
    cosmosDbContainer: "cosmosDbContainerTest",
    cosmosDbDatabase: "cosmosDbDatabaseTest",
    kind: "CosmosDb",
    location: "westus",
    managedIdentityResourceId:
      "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
    mappingRuleName: "TestMapping",
    retrievalStartDate: new Date("2022-07-29T12:00:00.6554616Z"),
    tableName: "TestTable",
  };
  const credential = new DefaultAzureCredential();
  const client = new KustoManagementClient(credential, subscriptionId);
  const result = await client.dataConnections.beginCreateOrUpdateAndWait(
    resourceGroupName,
    clusterName,
    databaseName,
    dataConnectionName,
    parameters,
  );
  console.log(result);
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

using Azure;
using Azure.ResourceManager;
using System;
using System.Threading.Tasks;
using Azure.Core;
using Azure.Identity;
using Azure.ResourceManager.Kusto.Models;
using Azure.ResourceManager.Kusto;

// Generated from example definition: specification/azure-kusto/resource-manager/Microsoft.Kusto/stable/2024-04-13/examples/KustoDataConnectionsCosmosDbCreateOrUpdate.json
// this example is just showing the usage of "DataConnections_CreateOrUpdate" operation, for the dependent resources, they will have to be created separately.

// get your azure access token, for more details of how Azure SDK get your access token, please refer to https://learn.microsoft.com/en-us/dotnet/azure/sdk/authentication?tabs=command-line
TokenCredential cred = new DefaultAzureCredential();
// authenticate your client
ArmClient client = new ArmClient(cred);

// this example assumes you already have this KustoDatabaseResource created on azure
// for more information of creating KustoDatabaseResource, please refer to the document of KustoDatabaseResource
string subscriptionId = "12345678-1234-1234-1234-123456789098";
string resourceGroupName = "kustorptest";
string clusterName = "kustoCluster";
string databaseName = "KustoDatabase1";
ResourceIdentifier kustoDatabaseResourceId = KustoDatabaseResource.CreateResourceIdentifier(subscriptionId, resourceGroupName, clusterName, databaseName);
KustoDatabaseResource kustoDatabase = client.GetKustoDatabaseResource(kustoDatabaseResourceId);

// get the collection of this KustoDataConnectionResource
KustoDataConnectionCollection collection = kustoDatabase.GetKustoDataConnections();

// invoke the operation
string dataConnectionName = "dataConnectionTest";
KustoDataConnectionData data = new KustoCosmosDBDataConnection
{
    TableName = "TestTable",
    MappingRuleName = "TestMapping",
    ManagedIdentityResourceId = new ResourceIdentifier("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1"),
    CosmosDBAccountResourceId = new ResourceIdentifier("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.DocumentDb/databaseAccounts/cosmosDbAccountTest1"),
    CosmosDBDatabase = "cosmosDbDatabaseTest",
    CosmosDBContainer = "cosmosDbContainerTest",
    RetrievalStartOn = DateTimeOffset.Parse("2022-07-29T12:00:00.6554616Z"),
    Location = new AzureLocation("westus"),
};
ArmOperation<KustoDataConnectionResource> lro = await collection.CreateOrUpdateAsync(WaitUntil.Completed, dataConnectionName, data);
KustoDataConnectionResource result = lro.Value;

// the variable result is a resource, you could call other operations on this instance as well
// but just for demo, we get its data from this resource instance
KustoDataConnectionData resourceData = result.Data;
// for demo we just print out the id
Console.WriteLine($"Succeeded on id: {resourceData.Id}");

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Örnek yanıt

Durum kodu:: 200

Azure-AsyncOperation: https://management.azure.com/subscriptions/12345678-1234-1234-1234-123456789098/providers/Microsoft.Kusto/locations/westus/operationResults/742bef43-608b-4b58-ba96-6f7a32ec5f0f?api-version=2022-12-29

{
  "id": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Kusto/Clusters/kustoCluster/Databases/KustoDatabase1/DataConnections/dataConnectionTest",
  "name": "kustoCluster/KustoDatabase1/dataConnectionTest",
  "type": "Microsoft.Kusto/Clusters/Databases/DataConnections",
  "location": "westus",
  "kind": "CosmosDb",
  "properties": {
    "tableName": "TestTable",
    "mappingRuleName": "TestMapping",
    "managedIdentityResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
    "managedIdentityObjectId": "87654321-1234-1234-1234-123456789123",
    "cosmosDbAccountResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.DocumentDb/databaseAccounts/cosmosDbAccountTest1",
    "cosmosDbDatabase": "cosmosDbDatabaseTest",
    "cosmosDbContainer": "cosmosDbContainerTest",
    "retrievalStartDate": "2022-07-29T12:00:00.6554616Z"
  }
}

Durum kodu:: 201

Azure-AsyncOperation: https://management.azure.com/subscriptions/12345678-1234-1234-1234-123456789098/providers/Microsoft.Kusto/locations/westus/operationResults/742bef43-608b-4b58-ba96-6f7a32ec5f0f?api-version=2022-12-29

{
  "id": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Kusto/Clusters/kustoCluster/Databases/KustoDatabase1/DataConnections/dataConnectionTest",
  "name": "kustoCluster/KustoDatabase1/dataConnectionTest",
  "type": "Microsoft.Kusto/Clusters/Databases/DataConnections",
  "location": "westus",
  "kind": "CosmosDb",
  "properties": {
    "tableName": "TestTable",
    "mappingRuleName": "TestMapping",
    "managedIdentityResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
    "managedIdentityObjectId": "87654321-1234-1234-1234-123456789123",
    "cosmosDbAccountResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.DocumentDb/databaseAccounts/cosmosDbAccountTest1",
    "cosmosDbDatabase": "cosmosDbDatabaseTest",
    "cosmosDbContainer": "cosmosDbContainerTest",
    "retrievalStartDate": "2022-07-29T12:00:00.6554616Z"
  }
}

Durum kodu:: 202

Azure-AsyncOperation: https://management.azure.com/subscriptions/12345678-1234-1234-1234-123456789098/providers/Microsoft.Kusto/locations/westus/operationResults/742bef43-608b-4b58-ba96-6f7a32ec5f0f?api-version=2022-12-29

{
  "id": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Kusto/Clusters/kustoCluster/Databases/KustoDatabase1/DataConnections/dataConnectionTest",
  "name": "kustoCluster/KustoDatabase1/dataConnectionTest",
  "type": "Microsoft.Kusto/Clusters/Databases/DataConnections",
  "location": "westus",
  "kind": "CosmosDb",
  "properties": {
    "tableName": "TestTable",
    "mappingRuleName": "TestMapping",
    "managedIdentityResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
    "managedIdentityObjectId": "87654321-1234-1234-1234-123456789123",
    "cosmosDbAccountResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.DocumentDb/databaseAccounts/cosmosDbAccountTest1",
    "cosmosDbDatabase": "cosmosDbDatabaseTest",
    "cosmosDbContainer": "cosmosDbContainerTest",
    "retrievalStartDate": "2022-07-29T12:00:00.6554616Z"
  }
}

KustoDataConnectionsCreateOrUpdate

Örnek isteği

PUT https://management.azure.com/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Kusto/clusters/kustoCluster/databases/KustoDatabase8/dataConnections/dataConnectionTest?api-version=2024-04-13

{
  "location": "westus",
  "kind": "EventHub",
  "properties": {
    "eventHubResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest1",
    "managedIdentityResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
    "consumerGroup": "testConsumerGroup1"
  }
}


import com.azure.resourcemanager.kusto.models.EventHubDataConnection;

/**
 * Samples for DataConnections CreateOrUpdate.
 */
public final class Main {
    /*
     * x-ms-original-file: specification/azure-kusto/resource-manager/Microsoft.Kusto/stable/2024-04-13/examples/
     * KustoDataConnectionsCreateOrUpdate.json
     */
    /**
     * Sample code: KustoDataConnectionsCreateOrUpdate.
     * 
     * @param manager Entry point to KustoManager.
     */
    public static void kustoDataConnectionsCreateOrUpdate(com.azure.resourcemanager.kusto.KustoManager manager) {
        manager.dataConnections().createOrUpdate("kustorptest", "kustoCluster", "KustoDatabase8", "dataConnectionTest",
            new EventHubDataConnection().withLocation("westus").withEventHubResourceId(
                "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest1")
                .withConsumerGroup("testConsumerGroup1").withManagedIdentityResourceId(
                    "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1"),
            com.azure.core.util.Context.NONE);
    }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

from azure.identity import DefaultAzureCredential

from azure.mgmt.kusto import KustoManagementClient

"""
# PREREQUISITES
    pip install azure-identity
    pip install azure-mgmt-kusto
# USAGE
    python kusto_data_connections_create_or_update.py

    Before run the sample, please set the values of the client ID, tenant ID and client secret
    of the AAD application as environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID,
    AZURE_CLIENT_SECRET. For more info about how to get the value, please see:
    https://docs.microsoft.com/azure/active-directory/develop/howto-create-service-principal-portal
"""


def main():
    client = KustoManagementClient(
        credential=DefaultAzureCredential(),
        subscription_id="12345678-1234-1234-1234-123456789098",
    )

    response = client.data_connections.begin_create_or_update(
        resource_group_name="kustorptest",
        cluster_name="kustoCluster",
        database_name="KustoDatabase8",
        data_connection_name="dataConnectionTest",
        parameters={
            "kind": "EventHub",
            "location": "westus",
            "properties": {
                "consumerGroup": "testConsumerGroup1",
                "eventHubResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest1",
                "managedIdentityResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
            },
        },
    ).result()
    print(response)


# x-ms-original-file: specification/azure-kusto/resource-manager/Microsoft.Kusto/stable/2024-04-13/examples/KustoDataConnectionsCreateOrUpdate.json
if __name__ == "__main__":
    main()

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

package armkusto_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/kusto/armkusto/v2"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/b8adce17dc500f338f86f18af30aac61dcb71c5f/specification/azure-kusto/resource-manager/Microsoft.Kusto/stable/2024-04-13/examples/KustoDataConnectionsCreateOrUpdate.json
func ExampleDataConnectionsClient_BeginCreateOrUpdate_kustoDataConnectionsCreateOrUpdate() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armkusto.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	poller, err := clientFactory.NewDataConnectionsClient().BeginCreateOrUpdate(ctx, "kustorptest", "kustoCluster", "KustoDatabase8", "dataConnectionTest", &armkusto.EventHubDataConnection{
		Kind:     to.Ptr(armkusto.DataConnectionKindEventHub),
		Location: to.Ptr("westus"),
		Properties: &armkusto.EventHubConnectionProperties{
			ConsumerGroup:             to.Ptr("testConsumerGroup1"),
			EventHubResourceID:        to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest1"),
			ManagedIdentityResourceID: to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1"),
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res = armkusto.DataConnectionsClientCreateOrUpdateResponse{
	// 	                            DataConnectionClassification: &armkusto.EventHubDataConnection{
	// 		Name: to.Ptr("kustoCluster/KustoDatabase8/dataConnectionTest"),
	// 		Type: to.Ptr("Microsoft.Kusto/Clusters/Databases/DataConnections"),
	// 		ID: to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Kusto/Clusters/kustoCluster/Databases/KustoDatabase8/DataConnections/dataConnectionTest"),
	// 		Kind: to.Ptr(armkusto.DataConnectionKindEventHub),
	// 		Location: to.Ptr("westus"),
	// 		Properties: &armkusto.EventHubConnectionProperties{
	// 			Compression: to.Ptr(armkusto.CompressionNone),
	// 			ConsumerGroup: to.Ptr("testConsumerGroup1"),
	// 			EventHubResourceID: to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest1"),
	// 			ManagedIdentityResourceID: to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1"),
	// 		},
	// 	},
	// 	                        }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

const { KustoManagementClient } = require("@azure/arm-kusto");
const { DefaultAzureCredential } = require("@azure/identity");
require("dotenv/config");

/**
 * This sample demonstrates how to Creates or updates a data connection.
 *
 * @summary Creates or updates a data connection.
 * x-ms-original-file: specification/azure-kusto/resource-manager/Microsoft.Kusto/stable/2024-04-13/examples/KustoDataConnectionsCreateOrUpdate.json
 */
async function kustoDataConnectionsCreateOrUpdate() {
  const subscriptionId =
    process.env["KUSTO_SUBSCRIPTION_ID"] || "12345678-1234-1234-1234-123456789098";
  const resourceGroupName = process.env["KUSTO_RESOURCE_GROUP"] || "kustorptest";
  const clusterName = "kustoCluster";
  const databaseName = "KustoDatabase8";
  const dataConnectionName = "dataConnectionTest";
  const parameters = {
    consumerGroup: "testConsumerGroup1",
    eventHubResourceId:
      "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest1",
    kind: "EventHub",
    location: "westus",
    managedIdentityResourceId:
      "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
  };
  const credential = new DefaultAzureCredential();
  const client = new KustoManagementClient(credential, subscriptionId);
  const result = await client.dataConnections.beginCreateOrUpdateAndWait(
    resourceGroupName,
    clusterName,
    databaseName,
    dataConnectionName,
    parameters,
  );
  console.log(result);
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

using Azure;
using Azure.ResourceManager;
using System;
using System.Threading.Tasks;
using Azure.Core;
using Azure.Identity;
using Azure.ResourceManager.Kusto.Models;
using Azure.ResourceManager.Kusto;

// Generated from example definition: specification/azure-kusto/resource-manager/Microsoft.Kusto/stable/2024-04-13/examples/KustoDataConnectionsCreateOrUpdate.json
// this example is just showing the usage of "DataConnections_CreateOrUpdate" operation, for the dependent resources, they will have to be created separately.

// get your azure access token, for more details of how Azure SDK get your access token, please refer to https://learn.microsoft.com/en-us/dotnet/azure/sdk/authentication?tabs=command-line
TokenCredential cred = new DefaultAzureCredential();
// authenticate your client
ArmClient client = new ArmClient(cred);

// this example assumes you already have this KustoDatabaseResource created on azure
// for more information of creating KustoDatabaseResource, please refer to the document of KustoDatabaseResource
string subscriptionId = "12345678-1234-1234-1234-123456789098";
string resourceGroupName = "kustorptest";
string clusterName = "kustoCluster";
string databaseName = "KustoDatabase8";
ResourceIdentifier kustoDatabaseResourceId = KustoDatabaseResource.CreateResourceIdentifier(subscriptionId, resourceGroupName, clusterName, databaseName);
KustoDatabaseResource kustoDatabase = client.GetKustoDatabaseResource(kustoDatabaseResourceId);

// get the collection of this KustoDataConnectionResource
KustoDataConnectionCollection collection = kustoDatabase.GetKustoDataConnections();

// invoke the operation
string dataConnectionName = "dataConnectionTest";
KustoDataConnectionData data = new KustoEventHubDataConnection
{
    EventHubResourceId = new ResourceIdentifier("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest1"),
    ConsumerGroup = "testConsumerGroup1",
    ManagedIdentityResourceId = new ResourceIdentifier("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1"),
    Location = new AzureLocation("westus"),
};
ArmOperation<KustoDataConnectionResource> lro = await collection.CreateOrUpdateAsync(WaitUntil.Completed, dataConnectionName, data);
KustoDataConnectionResource result = lro.Value;

// the variable result is a resource, you could call other operations on this instance as well
// but just for demo, we get its data from this resource instance
KustoDataConnectionData resourceData = result.Data;
// for demo we just print out the id
Console.WriteLine($"Succeeded on id: {resourceData.Id}");

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Örnek yanıt

Durum kodu:: 200

{
  "id": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Kusto/Clusters/kustoCluster/Databases/KustoDatabase8/DataConnections/dataConnectionTest",
  "name": "kustoCluster/KustoDatabase8/dataConnectionTest",
  "type": "Microsoft.Kusto/Clusters/Databases/DataConnections",
  "location": "westus",
  "kind": "EventHub",
  "properties": {
    "eventHubResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest1",
    "managedIdentityResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
    "consumerGroup": "testConsumerGroup1",
    "compression": "None"
  }
}

Durum kodu:: 201

{
  "id": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Kusto/Clusters/kustoCluster/Databases/KustoDatabase8/DataConnections/dataConnectionTest",
  "name": "kustoCluster/KustoDatabase8/dataConnectionTest",
  "type": "Microsoft.Kusto/Clusters/Databases/DataConnections",
  "location": "westus",
  "kind": "EventHub",
  "properties": {
    "eventHubResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest1",
    "managedIdentityResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
    "consumerGroup": "testConsumerGroup1",
    "compression": "None"
  }
}

Durum kodu:: 202

{
  "id": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Kusto/Clusters/kustoCluster/Databases/KustoDatabase8/DataConnections/dataConnectionTest",
  "name": "kustoCluster/KustoDatabase8/dataConnectionTest",
  "type": "Microsoft.Kusto/Clusters/Databases/DataConnections",
  "location": "westus",
  "kind": "EventHub",
  "properties": {
    "eventHubResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest1",
    "managedIdentityResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
    "consumerGroup": "testConsumerGroup1",
    "compression": "None"
  }
}

KustoDataConnectionsEventGridCreateOrUpdate

Örnek isteği

PUT https://management.azure.com/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Kusto/clusters/kustoCluster/databases/KustoDatabase8/dataConnections/dataConnectionTest?api-version=2024-04-13

{
  "location": "westus",
  "kind": "EventGrid",
  "properties": {
    "ignoreFirstRecord": false,
    "storageAccountResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount",
    "eventGridResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount/providers/Microsoft.EventGrid/eventSubscriptions/eventSubscriptionTest",
    "eventHubResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest2",
    "consumerGroup": "$Default",
    "tableName": "TestTable",
    "mappingRuleName": "TestMapping",
    "dataFormat": "MULTIJSON",
    "blobStorageEventType": "Microsoft.Storage.BlobCreated",
    "managedIdentityResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
    "databaseRouting": "Single"
  }
}


import com.azure.resourcemanager.kusto.models.BlobStorageEventType;
import com.azure.resourcemanager.kusto.models.DatabaseRouting;
import com.azure.resourcemanager.kusto.models.EventGridDataConnection;
import com.azure.resourcemanager.kusto.models.EventGridDataFormat;

/**
 * Samples for DataConnections CreateOrUpdate.
 */
public final class Main {
    /*
     * x-ms-original-file: specification/azure-kusto/resource-manager/Microsoft.Kusto/stable/2024-04-13/examples/
     * KustoDataConnectionsEventGridCreateOrUpdate.json
     */
    /**
     * Sample code: KustoDataConnectionsEventGridCreateOrUpdate.
     * 
     * @param manager Entry point to KustoManager.
     */
    public static void
        kustoDataConnectionsEventGridCreateOrUpdate(com.azure.resourcemanager.kusto.KustoManager manager) {
        manager.dataConnections().createOrUpdate("kustorptest", "kustoCluster", "KustoDatabase8", "dataConnectionTest",
            new EventGridDataConnection().withLocation("westus").withStorageAccountResourceId(
                "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount")
                .withEventGridResourceId(
                    "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount/providers/Microsoft.EventGrid/eventSubscriptions/eventSubscriptionTest")
                .withEventHubResourceId(
                    "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest2")
                .withConsumerGroup("$Default").withTableName("TestTable").withMappingRuleName("TestMapping")
                .withDataFormat(EventGridDataFormat.MULTIJSON).withIgnoreFirstRecord(false)
                .withBlobStorageEventType(BlobStorageEventType.MICROSOFT_STORAGE_BLOB_CREATED)
                .withManagedIdentityResourceId(
                    "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1")
                .withDatabaseRouting(DatabaseRouting.SINGLE),
            com.azure.core.util.Context.NONE);
    }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

from azure.identity import DefaultAzureCredential

from azure.mgmt.kusto import KustoManagementClient

"""
# PREREQUISITES
    pip install azure-identity
    pip install azure-mgmt-kusto
# USAGE
    python kusto_data_connections_event_grid_create_or_update.py

    Before run the sample, please set the values of the client ID, tenant ID and client secret
    of the AAD application as environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID,
    AZURE_CLIENT_SECRET. For more info about how to get the value, please see:
    https://docs.microsoft.com/azure/active-directory/develop/howto-create-service-principal-portal
"""


def main():
    client = KustoManagementClient(
        credential=DefaultAzureCredential(),
        subscription_id="12345678-1234-1234-1234-123456789098",
    )

    response = client.data_connections.begin_create_or_update(
        resource_group_name="kustorptest",
        cluster_name="kustoCluster",
        database_name="KustoDatabase8",
        data_connection_name="dataConnectionTest",
        parameters={
            "kind": "EventGrid",
            "location": "westus",
            "properties": {
                "blobStorageEventType": "Microsoft.Storage.BlobCreated",
                "consumerGroup": "$Default",
                "dataFormat": "MULTIJSON",
                "databaseRouting": "Single",
                "eventGridResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount/providers/Microsoft.EventGrid/eventSubscriptions/eventSubscriptionTest",
                "eventHubResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest2",
                "ignoreFirstRecord": False,
                "managedIdentityResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
                "mappingRuleName": "TestMapping",
                "storageAccountResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount",
                "tableName": "TestTable",
            },
        },
    ).result()
    print(response)


# x-ms-original-file: specification/azure-kusto/resource-manager/Microsoft.Kusto/stable/2024-04-13/examples/KustoDataConnectionsEventGridCreateOrUpdate.json
if __name__ == "__main__":
    main()

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

package armkusto_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/kusto/armkusto/v2"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/b8adce17dc500f338f86f18af30aac61dcb71c5f/specification/azure-kusto/resource-manager/Microsoft.Kusto/stable/2024-04-13/examples/KustoDataConnectionsEventGridCreateOrUpdate.json
func ExampleDataConnectionsClient_BeginCreateOrUpdate_kustoDataConnectionsEventGridCreateOrUpdate() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armkusto.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	poller, err := clientFactory.NewDataConnectionsClient().BeginCreateOrUpdate(ctx, "kustorptest", "kustoCluster", "KustoDatabase8", "dataConnectionTest", &armkusto.EventGridDataConnection{
		Kind:     to.Ptr(armkusto.DataConnectionKindEventGrid),
		Location: to.Ptr("westus"),
		Properties: &armkusto.EventGridConnectionProperties{
			BlobStorageEventType:      to.Ptr(armkusto.BlobStorageEventTypeMicrosoftStorageBlobCreated),
			ConsumerGroup:             to.Ptr("$Default"),
			DataFormat:                to.Ptr(armkusto.EventGridDataFormatMULTIJSON),
			DatabaseRouting:           to.Ptr(armkusto.DatabaseRoutingSingle),
			EventGridResourceID:       to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount/providers/Microsoft.EventGrid/eventSubscriptions/eventSubscriptionTest"),
			EventHubResourceID:        to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest2"),
			IgnoreFirstRecord:         to.Ptr(false),
			ManagedIdentityResourceID: to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1"),
			MappingRuleName:           to.Ptr("TestMapping"),
			StorageAccountResourceID:  to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount"),
			TableName:                 to.Ptr("TestTable"),
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res = armkusto.DataConnectionsClientCreateOrUpdateResponse{
	// 	                            DataConnectionClassification: &armkusto.EventGridDataConnection{
	// 		Name: to.Ptr("kustoCluster/KustoDatabase8/dataConnectionTest"),
	// 		Type: to.Ptr("Microsoft.Kusto/Clusters/Databases/DataConnections"),
	// 		ID: to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Kusto/Clusters/kustoCluster/Databases/KustoDatabase8/DataConnections/KustoDataConnection9"),
	// 		Kind: to.Ptr(armkusto.DataConnectionKindEventGrid),
	// 		Location: to.Ptr("westus"),
	// 		Properties: &armkusto.EventGridConnectionProperties{
	// 			BlobStorageEventType: to.Ptr(armkusto.BlobStorageEventTypeMicrosoftStorageBlobCreated),
	// 			ConsumerGroup: to.Ptr("$Default"),
	// 			DataFormat: to.Ptr(armkusto.EventGridDataFormatMULTIJSON),
	// 			DatabaseRouting: to.Ptr(armkusto.DatabaseRoutingSingle),
	// 			EventGridResourceID: to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount/providers/Microsoft.EventGrid/eventSubscriptions/eventSubscriptionTest"),
	// 			EventHubResourceID: to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest2"),
	// 			IgnoreFirstRecord: to.Ptr(false),
	// 			ManagedIdentityObjectID: to.Ptr("87654321-1234-1234-1234-123456789123"),
	// 			ManagedIdentityResourceID: to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1"),
	// 			MappingRuleName: to.Ptr("TestMapping"),
	// 			StorageAccountResourceID: to.Ptr("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount"),
	// 			TableName: to.Ptr("TestTable"),
	// 		},
	// 	},
	// 	                        }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

const { KustoManagementClient } = require("@azure/arm-kusto");
const { DefaultAzureCredential } = require("@azure/identity");
require("dotenv/config");

/**
 * This sample demonstrates how to Creates or updates a data connection.
 *
 * @summary Creates or updates a data connection.
 * x-ms-original-file: specification/azure-kusto/resource-manager/Microsoft.Kusto/stable/2024-04-13/examples/KustoDataConnectionsEventGridCreateOrUpdate.json
 */
async function kustoDataConnectionsEventGridCreateOrUpdate() {
  const subscriptionId =
    process.env["KUSTO_SUBSCRIPTION_ID"] || "12345678-1234-1234-1234-123456789098";
  const resourceGroupName = process.env["KUSTO_RESOURCE_GROUP"] || "kustorptest";
  const clusterName = "kustoCluster";
  const databaseName = "KustoDatabase8";
  const dataConnectionName = "dataConnectionTest";
  const parameters = {
    blobStorageEventType: "Microsoft.Storage.BlobCreated",
    consumerGroup: "$Default",
    dataFormat: "MULTIJSON",
    databaseRouting: "Single",
    eventGridResourceId:
      "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount/providers/Microsoft.EventGrid/eventSubscriptions/eventSubscriptionTest",
    eventHubResourceId:
      "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest2",
    ignoreFirstRecord: false,
    kind: "EventGrid",
    location: "westus",
    managedIdentityResourceId:
      "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
    mappingRuleName: "TestMapping",
    storageAccountResourceId:
      "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount",
    tableName: "TestTable",
  };
  const credential = new DefaultAzureCredential();
  const client = new KustoManagementClient(credential, subscriptionId);
  const result = await client.dataConnections.beginCreateOrUpdateAndWait(
    resourceGroupName,
    clusterName,
    databaseName,
    dataConnectionName,
    parameters,
  );
  console.log(result);
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

using Azure;
using Azure.ResourceManager;
using System;
using System.Threading.Tasks;
using Azure.Core;
using Azure.Identity;
using Azure.ResourceManager.Kusto.Models;
using Azure.ResourceManager.Kusto;

// Generated from example definition: specification/azure-kusto/resource-manager/Microsoft.Kusto/stable/2024-04-13/examples/KustoDataConnectionsEventGridCreateOrUpdate.json
// this example is just showing the usage of "DataConnections_CreateOrUpdate" operation, for the dependent resources, they will have to be created separately.

// get your azure access token, for more details of how Azure SDK get your access token, please refer to https://learn.microsoft.com/en-us/dotnet/azure/sdk/authentication?tabs=command-line
TokenCredential cred = new DefaultAzureCredential();
// authenticate your client
ArmClient client = new ArmClient(cred);

// this example assumes you already have this KustoDatabaseResource created on azure
// for more information of creating KustoDatabaseResource, please refer to the document of KustoDatabaseResource
string subscriptionId = "12345678-1234-1234-1234-123456789098";
string resourceGroupName = "kustorptest";
string clusterName = "kustoCluster";
string databaseName = "KustoDatabase8";
ResourceIdentifier kustoDatabaseResourceId = KustoDatabaseResource.CreateResourceIdentifier(subscriptionId, resourceGroupName, clusterName, databaseName);
KustoDatabaseResource kustoDatabase = client.GetKustoDatabaseResource(kustoDatabaseResourceId);

// get the collection of this KustoDataConnectionResource
KustoDataConnectionCollection collection = kustoDatabase.GetKustoDataConnections();

// invoke the operation
string dataConnectionName = "dataConnectionTest";
KustoDataConnectionData data = new KustoEventGridDataConnection
{
    StorageAccountResourceId = new ResourceIdentifier("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount"),
    EventGridResourceId = new ResourceIdentifier("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount/providers/Microsoft.EventGrid/eventSubscriptions/eventSubscriptionTest"),
    EventHubResourceId = new ResourceIdentifier("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest2"),
    ConsumerGroup = "$Default",
    TableName = "TestTable",
    MappingRuleName = "TestMapping",
    DataFormat = KustoEventGridDataFormat.MultiJson,
    IsFirstRecordIgnored = false,
    BlobStorageEventType = BlobStorageEventType.MicrosoftStorageBlobCreated,
    ManagedIdentityResourceId = new ResourceIdentifier("/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1"),
    DatabaseRouting = KustoDatabaseRouting.Single,
    Location = new AzureLocation("westus"),
};
ArmOperation<KustoDataConnectionResource> lro = await collection.CreateOrUpdateAsync(WaitUntil.Completed, dataConnectionName, data);
KustoDataConnectionResource result = lro.Value;

// the variable result is a resource, you could call other operations on this instance as well
// but just for demo, we get its data from this resource instance
KustoDataConnectionData resourceData = result.Data;
// for demo we just print out the id
Console.WriteLine($"Succeeded on id: {resourceData.Id}");

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Örnek yanıt

Durum kodu:: 200

{
  "id": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Kusto/Clusters/kustoCluster/Databases/KustoDatabase8/DataConnections/KustoDataConnection9",
  "name": "kustoCluster/KustoDatabase8/dataConnectionTest",
  "type": "Microsoft.Kusto/Clusters/Databases/DataConnections",
  "location": "westus",
  "kind": "EventGrid",
  "properties": {
    "ignoreFirstRecord": false,
    "storageAccountResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount",
    "eventGridResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount/providers/Microsoft.EventGrid/eventSubscriptions/eventSubscriptionTest",
    "eventHubResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest2",
    "consumerGroup": "$Default",
    "tableName": "TestTable",
    "mappingRuleName": "TestMapping",
    "dataFormat": "MULTIJSON",
    "blobStorageEventType": "Microsoft.Storage.BlobCreated",
    "managedIdentityResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
    "managedIdentityObjectId": "87654321-1234-1234-1234-123456789123",
    "databaseRouting": "Single"
  }
}

Durum kodu:: 201

{
  "id": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Kusto/Clusters/kustoCluster/Databases/KustoDatabase8/DataConnections/KustoDataConnection9",
  "name": "kustoCluster/KustoDatabase8/dataConnectionTest",
  "type": "Microsoft.Kusto/Clusters/Databases/DataConnections",
  "location": "westus",
  "kind": "EventGrid",
  "properties": {
    "ignoreFirstRecord": false,
    "storageAccountResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount",
    "eventGridResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount/providers/Microsoft.EventGrid/eventSubscriptions/eventSubscriptionTest",
    "eventHubResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest2",
    "consumerGroup": "$Default",
    "tableName": "TestTable",
    "mappingRuleName": "TestMapping",
    "dataFormat": "MULTIJSON",
    "blobStorageEventType": "Microsoft.Storage.BlobCreated",
    "managedIdentityResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
    "managedIdentityObjectId": "87654321-1234-1234-1234-123456789123",
    "databaseRouting": "Single"
  }
}

Durum kodu:: 202

{
  "id": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Kusto/Clusters/kustoCluster/Databases/KustoDatabase8/DataConnections/KustoDataConnection9",
  "name": "kustoCluster/KustoDatabase8/dataConnectionTest",
  "type": "Microsoft.Kusto/Clusters/Databases/DataConnections",
  "location": "westus",
  "kind": "EventGrid",
  "properties": {
    "ignoreFirstRecord": false,
    "storageAccountResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount",
    "eventGridResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.Storage/storageAccounts/teststorageaccount/providers/Microsoft.EventGrid/eventSubscriptions/eventSubscriptionTest",
    "eventHubResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.EventHub/namespaces/eventhubTestns1/eventhubs/eventhubTest2",
    "consumerGroup": "$Default",
    "tableName": "TestTable",
    "mappingRuleName": "TestMapping",
    "dataFormat": "MULTIJSON",
    "blobStorageEventType": "Microsoft.Storage.BlobCreated",
    "managedIdentityResourceId": "/subscriptions/12345678-1234-1234-1234-123456789098/resourceGroups/kustorptest/providers/Microsoft.ManagedIdentity/userAssignedIdentities/managedidentityTest1",
    "managedIdentityObjectId": "87654321-1234-1234-1234-123456789123",
    "databaseRouting": "Single"
  }
}

Tanımlar

Name	Description
blobStorageEventType	İşlenmek üzere blob depolama olay türünün adı.
compression	Olay hub'ı iletileri sıkıştırma türü
CosmosDbDataConnection	CosmosDb veri bağlantısını temsil eden sınıf.
DatabaseRouting	Veri bağlantısından veritabanı yönlendirme bilgileri için gösterge, varsayılan olarak yalnızca veritabanı yönlendirme bilgilerine izin verilir
ErrorAdditionalInfo	Kaynak yönetimi hatası ek bilgileri.
ErrorDetail	Hata ayrıntısı.
ErrorResponse	Hata yanıtı
EventGridDataConnection	Event Grid veri bağlantısını temsil eden sınıf.
eventGridDataFormat	İletinin veri biçimi. İsteğe bağlı olarak, veri biçimi her iletiye eklenebilir.
EventHubDataConnection	Olay hub'ı veri bağlantısını temsil eden sınıf.
eventHubDataFormat	İletinin veri biçimi. İsteğe bağlı olarak, veri biçimi her iletiye eklenebilir.
IotHubDataConnection	IoT hub'ı veri bağlantısını temsil eden sınıf.
iotHubDataFormat	İletinin veri biçimi. İsteğe bağlı olarak, veri biçimi her iletiye eklenebilir.
ProvisioningState	Kaynağın sağlanan durumu.

blobStorageEventType

Listeleme

İşlenmek üzere blob depolama olay türünün adı.

Değer	Description
Microsoft.Storage.BlobCreated
Microsoft.Storage.BlobRenamed

compression

Listeleme

Olay hub'ı iletileri sıkıştırma türü

Değer	Description
GZip
None

CosmosDbDataConnection

Object

CosmosDb veri bağlantısını temsil eden sınıf.

Name	Tür	Description
id	string	Kaynağın tam kaynak kimliği. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
kind	string: CosmosDb	Veri bağlantısı için uç nokta türü
location	string	Kaynak konumu.
name	string	Kaynağın adı
properties.cosmosDbAccountResourceId	string	Veri bağlantısını oluşturmak için kullanılan Cosmos DB hesabının kaynak kimliği.
properties.cosmosDbContainer	string	Cosmos DB veritabanındaki mevcut bir kapsayıcının adı.
properties.cosmosDbDatabase	string	Cosmos DB hesabında var olan bir veritabanının adı.
properties.managedIdentityObjectId	string	Yönetilen kimlik kaynağının nesne kimliği.
properties.managedIdentityResourceId	string	Yönetilen sistemin veya kullanıcı tarafından atanan kimliğin kaynak kimliği. Kimlik, Cosmos DB ile kimlik doğrulaması yapmak için kullanılır.
properties.mappingRuleName	string	Alınan veriler alınırken kullanılacak mevcut eşleme kuralının adı.
properties.provisioningState	ProvisioningState	Kaynağın sağlanan durumu.
properties.retrievalStartDate	string (date-time)	Opsiyonel. Tanımlanmışsa, veri bağlantısı belirtilen alma başlangıç tarihinden sonra oluşturulan veya güncelleştirilen Cosmos DB belgelerini alır.
properties.tableName	string	Kümenizdeki mevcut hedef tablonun büyük/küçük harfe duyarlı adı. Alınan veriler bu tabloya alınır.
type	string	Kaynağın türü. Örneğin, "Microsoft.Compute/virtualMachines" veya "Microsoft.Storage/storageAccounts"

DatabaseRouting

Listeleme

Veri bağlantısından veritabanı yönlendirme bilgileri için gösterge, varsayılan olarak yalnızca veritabanı yönlendirme bilgilerine izin verilir

Değer	Description
Multi
Single

ErrorAdditionalInfo

Object

Kaynak yönetimi hatası ek bilgileri.

Name	Tür	Description
info	object	Ek bilgiler.
type	string	Ek bilgi türü.

ErrorDetail

Object

Hata ayrıntısı.

Name	Tür	Description
additionalInfo	ErrorAdditionalInfo[]	Hata ek bilgileri.
code	string	Hata kodu.
details	ErrorDetail[]	Hata ayrıntıları.
message	string	Hata iletisi.
target	string	Hata hedefi.

ErrorResponse

Object

Hata yanıtı

Name	Tür	Description
error	ErrorDetail	Hata nesnesi.

EventGridDataConnection

Object

Event Grid veri bağlantısını temsil eden sınıf.

Name	Tür	Default value	Description
id	string		Kaynağın tam kaynak kimliği. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
kind	string: EventGrid		Veri bağlantısı için uç nokta türü
location	string		Kaynak konumu.
name	string		Kaynağın adı
properties.blobStorageEventType	blobStorageEventType		İşlenmek üzere blob depolama olay türünün adı.
properties.consumerGroup	string		Olay hub'ı tüketici grubu.
properties.dataFormat	eventGridDataFormat		İletinin veri biçimi. İsteğe bağlı olarak, veri biçimi her iletiye eklenebilir.
properties.databaseRouting	DatabaseRouting	Single	Veri bağlantısından veritabanı yönlendirme bilgileri için gösterge, varsayılan olarak yalnızca veritabanı yönlendirme bilgilerine izin verilir
properties.eventGridResourceId	string		Depolama hesabı olaylarına abone olan olay kılavuzunun kaynak kimliği.
properties.eventHubResourceId	string		Olay kılavuzunun olayları gönderecek şekilde yapılandırıldığı kaynak kimliği.
properties.ignoreFirstRecord	boolean		True olarak ayarlanırsa alımın her dosyanın ilk kaydını yoksayması gerektiğini gösteren boole değeri
properties.managedIdentityObjectId	string		managedIdentityResourceId nesne kimliği
properties.managedIdentityResourceId	string		Olay hub'ı ve depolama hesabıyla kimlik doğrulaması yapmak için kullanılacak yönetilen kimliğin (sistem veya kullanıcı atanmış) kaynak kimliği.
properties.mappingRuleName	string		Verileri almak için kullanılacak eşleme kuralı. İsteğe bağlı olarak eşleme bilgileri her iletiye eklenebilir.
properties.provisioningState	ProvisioningState		Kaynağın sağlanan durumu.
properties.storageAccountResourceId	string		Verilerin bulunduğu depolama hesabının kaynak kimliği.
properties.tableName	string		Verilerin alınması gereken tablo. İsteğe bağlı olarak tablo bilgileri her iletiye eklenebilir.
type	string		Kaynağın türü. Örneğin, "Microsoft.Compute/virtualMachines" veya "Microsoft.Storage/storageAccounts"

eventGridDataFormat

Listeleme

İletinin veri biçimi. İsteğe bağlı olarak, veri biçimi her iletiye eklenebilir.

Değer	Description
APACHEAVRO
AVRO
CSV
JSON
MULTIJSON
ORC
PARQUET
PSV
RAW
SCSV
SINGLEJSON
SOHSV
TSV
TSVE
TXT
W3CLOGFILE

EventHubDataConnection

Object

Olay hub'ı veri bağlantısını temsil eden sınıf.

Name	Tür	Default value	Description
id	string		Kaynağın tam kaynak kimliği. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
kind	string: EventHub		Veri bağlantısı için uç nokta türü
location	string		Kaynak konumu.
name	string		Kaynağın adı
properties.compression	compression	None	Olay hub'ı iletileri sıkıştırma türü
properties.consumerGroup	string		Olay hub'ı tüketici grubu.
properties.dataFormat	eventHubDataFormat		İletinin veri biçimi. İsteğe bağlı olarak, veri biçimi her iletiye eklenebilir.
properties.databaseRouting	DatabaseRouting	Single	Veri bağlantısından veritabanı yönlendirme bilgileri için gösterge, varsayılan olarak yalnızca veritabanı yönlendirme bilgilerine izin verilir
properties.eventHubResourceId	string		Veri bağlantısı oluşturmak için kullanılacak olay hub'ının kaynak kimliği.
properties.eventSystemProperties	string[]		Olay hub'ının sistem özellikleri
properties.managedIdentityObjectId	string		managedIdentityResourceId nesne kimliği
properties.managedIdentityResourceId	string		Olay hub'ı ile kimlik doğrulaması için kullanılacak yönetilen kimliğin (sistem veya kullanıcı atanmış) kaynak kimliği.
properties.mappingRuleName	string		Verileri almak için kullanılacak eşleme kuralı. İsteğe bağlı olarak eşleme bilgileri her iletiye eklenebilir.
properties.provisioningState	ProvisioningState		Kaynağın sağlanan durumu.
properties.retrievalStartDate	string (date-time)		Veri bağlantısı tanımlandığında, Alma başlangıç tarihinden itibaren oluşturulan mevcut Olay hub'ı olaylarını alır. Yalnızca Olay hub'ı tarafından tutulan olayları elde tutma süresine göre alabilir.
properties.tableName	string		Verilerin alınması gereken tablo. İsteğe bağlı olarak tablo bilgileri her iletiye eklenebilir.
type	string		Kaynağın türü. Örneğin, "Microsoft.Compute/virtualMachines" veya "Microsoft.Storage/storageAccounts"

eventHubDataFormat

Listeleme

İletinin veri biçimi. İsteğe bağlı olarak, veri biçimi her iletiye eklenebilir.

Değer	Description
APACHEAVRO
AVRO
CSV
JSON
MULTIJSON
ORC
PARQUET
PSV
RAW
SCSV
SINGLEJSON
SOHSV
TSV
TSVE
TXT
W3CLOGFILE

IotHubDataConnection

Object

IoT hub'ı veri bağlantısını temsil eden sınıf.

Name	Tür	Default value	Description
id	string		Kaynağın tam kaynak kimliği. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
kind	string: IotHub		Veri bağlantısı için uç nokta türü
location	string		Kaynak konumu.
name	string		Kaynağın adı
properties.consumerGroup	string		iot hub tüketici grubu.
properties.dataFormat	iotHubDataFormat		İletinin veri biçimi. İsteğe bağlı olarak, veri biçimi her iletiye eklenebilir.
properties.databaseRouting	DatabaseRouting	Single	Veri bağlantısından veritabanı yönlendirme bilgileri için gösterge, varsayılan olarak yalnızca veritabanı yönlendirme bilgilerine izin verilir
properties.eventSystemProperties	string[]		iot hub'ının sistem özellikleri
properties.iotHubResourceId	string		Veri bağlantısı oluşturmak için kullanılacak IoT hub'ının kaynak kimliği.
properties.mappingRuleName	string		Verileri almak için kullanılacak eşleme kuralı. İsteğe bağlı olarak eşleme bilgileri her iletiye eklenebilir.
properties.provisioningState	ProvisioningState		Kaynağın sağlanan durumu.
properties.retrievalStartDate	string (date-time)		Veri bağlantısı tanımlandığında, Alma başlangıç tarihinden itibaren oluşturulan mevcut Olay hub'ı olaylarını alır. Yalnızca Olay hub'ı tarafından tutulan olayları elde tutma süresine göre alabilir.
properties.sharedAccessPolicyName	string		Paylaşım erişim ilkesinin adı
properties.tableName	string		Verilerin alınması gereken tablo. İsteğe bağlı olarak tablo bilgileri her iletiye eklenebilir.
type	string		Kaynağın türü. Örneğin, "Microsoft.Compute/virtualMachines" veya "Microsoft.Storage/storageAccounts"

iotHubDataFormat

Listeleme

İletinin veri biçimi. İsteğe bağlı olarak, veri biçimi her iletiye eklenebilir.

Değer	Description
APACHEAVRO
AVRO
CSV
JSON
MULTIJSON
ORC
PARQUET
PSV
RAW
SCSV
SINGLEJSON
SOHSV
TSV
TSVE
TXT
W3CLOGFILE

ProvisioningState

Listeleme

Kaynağın sağlanan durumu.

Değer	Description
Canceled
Creating
Deleting
Failed
Moving
Running
Succeeded

Aracılığıyla paylaş

Data Connections - Create Or Update

URI Parametreleri

İstek Gövdesi

CosmosDbDataConnection

EventGridDataConnection

EventHubDataConnection

IotHubDataConnection

Yanıtlar

Örnekler

KustoDataConnectionsCosmosDbCreateOrUpdate

Örnek isteği

Örnek yanıt

KustoDataConnectionsCreateOrUpdate

Örnek isteği

Örnek yanıt

KustoDataConnectionsEventGridCreateOrUpdate

Örnek isteği

Örnek yanıt

Tanımlar

blobStorageEventType

compression

CosmosDbDataConnection

DatabaseRouting

ErrorAdditionalInfo

ErrorDetail

ErrorResponse

EventGridDataConnection

eventGridDataFormat

EventHubDataConnection

eventHubDataFormat

IotHubDataConnection

iotHubDataFormat

ProvisioningState

Ek kaynaklar