Inputs - Get

Dienst:

Stream Analytics

API-Version:

2020-03-01

Ruft Details zur angegebenen Eingabe ab.

GET https://management.azure.com/subscriptions/{subscriptionId}/resourcegroups/{resourceGroupName}/providers/Microsoft.StreamAnalytics/streamingjobs/{jobName}/inputs/{inputName}?api-version=2020-03-01

URI-Parameter

Name	In	Erforderlich	Typ	Beschreibung
inputName	path	True	string	Der Name der Eingabe.
jobName	path	True	string	Der Name des Streamingauftrags.
resourceGroupName	path	True	string minLength: 1 maxLength: 90 pattern: ^[-\w\._\(\)]+$	Der Name der Ressourcengruppe. Bei dem Namen wird die Groß-/Kleinschreibung nicht beachtet.
subscriptionId	path	True	string minLength: 1	Die ID des Zielabonnements.
api-version	query	True	string minLength: 1	Die API-Version, die für diesen Vorgang verwendet werden soll.

Antworten

Name	Typ	Beschreibung
200 OK	Input	Die angegebene Eingabe wurde erfolgreich abgerufen. Header ETag: string
Other Status Codes	Error	Fehler.

Sicherheit

azure_auth

Azure Active Directory OAuth2-Fluss

Typ: oauth2
Ablauf: implicit
Autorisierungs-URL: https://login.microsoftonline.com/common/oauth2/authorize

Bereiche

Name	Beschreibung
user_impersonation	Identitätswechsel ihres Benutzerkontos

Beispiele

Get a reference blob input with CSV serialization

Get a stream blob input with CSV serialization

Get a stream Event Hub input with JSON serialization

Get a stream IoT Hub input with Avro serialization

Get a reference blob input with CSV serialization

Beispielanforderung

HTTP

GET https://management.azure.com/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourcegroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7225?api-version=2020-03-01

Java

/**
 * Samples for Inputs Get.
 */
public final class Main {
    /*
     * x-ms-original-file:
     * specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/
     * Input_Get_Reference_Blob_CSV.json
     */
    /**
     * Sample code: Get a reference blob input with CSV serialization.
     * 
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void getAReferenceBlobInputWithCSVSerialization(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager.inputs().getWithResponse("sjrg8440", "sj9597", "input7225", 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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Get_Reference_Blob_CSV.json
func ExampleInputsClient_Get_getAReferenceBlobInputWithCsvSerialization() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armstreamanalytics.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewInputsClient().Get(ctx, "sjrg8440", "sj9597", "input7225", nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %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.Input = armstreamanalytics.Input{
	// 	Name: to.Ptr("input7225"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7225"),
	// 	Properties: &armstreamanalytics.ReferenceInputProperties{
	// 		Type: to.Ptr("Reference"),
	// 		Serialization: &armstreamanalytics.CSVSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
	// 			Properties: &armstreamanalytics.CSVSerializationProperties{
	// 				Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
	// 				FieldDelimiter: to.Ptr(","),
	// 			},
	// 		},
	// 		Datasource: &armstreamanalytics.BlobReferenceInputDataSource{
	// 			Type: to.Ptr("Microsoft.Storage/Blob"),
	// 			Properties: &armstreamanalytics.BlobReferenceInputDataSourceProperties{
	// 				Container: to.Ptr("state"),
	// 				DateFormat: to.Ptr("yyyy/MM/dd"),
	// 				PathPattern: to.Ptr("{date}/{time}"),
	// 				StorageAccounts: []*armstreamanalytics.StorageAccount{
	// 					{
	// 						AccountName: to.Ptr("someAccountName"),
	// 				}},
	// 				TimeFormat: to.Ptr("HH"),
	// 			},
	// 		},
	// 	},
	// }
}

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

JavaScript

const { StreamAnalyticsManagementClient } = require("@azure/arm-streamanalytics");
const { DefaultAzureCredential } = require("@azure/identity");

/**
 * This sample demonstrates how to Gets details about the specified input.
 *
 * @summary Gets details about the specified input.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Get_Reference_Blob_CSV.json
 */
async function getAReferenceBlobInputWithCsvSerialization() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg8440";
  const jobName = "sj9597";
  const inputName = "input7225";
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.get(resourceGroupName, jobName, inputName);
  console.log(result);
}

getAReferenceBlobInputWithCsvSerialization().catch(console.error);

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

Beispiel für eine Antwort

Statuscode:

200

ETag: c987701d-4039-47aa-a115-ad84f67d07c5

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7225",
  "name": "input7225",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Reference",
    "datasource": {
      "type": "Microsoft.Storage/Blob",
      "properties": {
        "storageAccounts": [
          {
            "accountName": "someAccountName"
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

Get a stream blob input with CSV serialization

Beispielanforderung

HTTP

GET https://management.azure.com/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourcegroups/sjrg8161/providers/Microsoft.StreamAnalytics/streamingjobs/sj6695/inputs/input8899?api-version=2020-03-01

Java

/**
 * Samples for Inputs Get.
 */
public final class Main {
    /*
     * x-ms-original-file:
     * specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/
     * Input_Get_Stream_Blob_CSV.json
     */
    /**
     * Sample code: Get a stream blob input with CSV serialization.
     * 
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void getAStreamBlobInputWithCSVSerialization(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager.inputs().getWithResponse("sjrg8161", "sj6695", "input8899", 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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Get_Stream_Blob_CSV.json
func ExampleInputsClient_Get_getAStreamBlobInputWithCsvSerialization() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armstreamanalytics.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewInputsClient().Get(ctx, "sjrg8161", "sj6695", "input8899", nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %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.Input = armstreamanalytics.Input{
	// 	Name: to.Ptr("input8899"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8161/providers/Microsoft.StreamAnalytics/streamingjobs/sj6695/inputs/input8899"),
	// 	Properties: &armstreamanalytics.StreamInputProperties{
	// 		Type: to.Ptr("Stream"),
	// 		Serialization: &armstreamanalytics.CSVSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
	// 			Properties: &armstreamanalytics.CSVSerializationProperties{
	// 				Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
	// 				FieldDelimiter: to.Ptr(","),
	// 			},
	// 		},
	// 		Datasource: &armstreamanalytics.BlobStreamInputDataSource{
	// 			Type: to.Ptr("Microsoft.Storage/Blob"),
	// 			Properties: &armstreamanalytics.BlobStreamInputDataSourceProperties{
	// 				Container: to.Ptr("state"),
	// 				DateFormat: to.Ptr("yyyy/MM/dd"),
	// 				PathPattern: to.Ptr("{date}/{time}"),
	// 				StorageAccounts: []*armstreamanalytics.StorageAccount{
	// 					{
	// 						AccountName: to.Ptr("someAccountName"),
	// 				}},
	// 				TimeFormat: to.Ptr("HH"),
	// 				SourcePartitionCount: to.Ptr[int32](16),
	// 			},
	// 		},
	// 	},
	// }
}

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

JavaScript

const { StreamAnalyticsManagementClient } = require("@azure/arm-streamanalytics");
const { DefaultAzureCredential } = require("@azure/identity");

/**
 * This sample demonstrates how to Gets details about the specified input.
 *
 * @summary Gets details about the specified input.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Get_Stream_Blob_CSV.json
 */
async function getAStreamBlobInputWithCsvSerialization() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg8161";
  const jobName = "sj6695";
  const inputName = "input8899";
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.get(resourceGroupName, jobName, inputName);
  console.log(result);
}

getAStreamBlobInputWithCsvSerialization().catch(console.error);

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

Beispiel für eine Antwort

Statuscode:

200

ETag: 475074b8-c957-4b1f-a219-12b8399c3d4c

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8161/providers/Microsoft.StreamAnalytics/streamingjobs/sj6695/inputs/input8899",
  "name": "input8899",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.Storage/Blob",
      "properties": {
        "sourcePartitionCount": 16,
        "storageAccounts": [
          {
            "accountName": "someAccountName"
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

Get a stream Event Hub input with JSON serialization

Beispielanforderung

HTTP

GET https://management.azure.com/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourcegroups/sjrg3139/providers/Microsoft.StreamAnalytics/streamingjobs/sj197/inputs/input7425?api-version=2020-03-01

Java

/**
 * Samples for Inputs Get.
 */
public final class Main {
    /*
     * x-ms-original-file:
     * specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/
     * Input_Get_Stream_EventHub_JSON.json
     */
    /**
     * Sample code: Get a stream Event Hub input with JSON serialization.
     * 
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void getAStreamEventHubInputWithJSONSerialization(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager.inputs().getWithResponse("sjrg3139", "sj197", "input7425", 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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Get_Stream_EventHub_JSON.json
func ExampleInputsClient_Get_getAStreamEventHubInputWithJsonSerialization() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armstreamanalytics.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewInputsClient().Get(ctx, "sjrg3139", "sj197", "input7425", nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %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.Input = armstreamanalytics.Input{
	// 	Name: to.Ptr("input7425"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3139/providers/Microsoft.StreamAnalytics/streamingjobs/sj197/inputs/input7425"),
	// 	Properties: &armstreamanalytics.StreamInputProperties{
	// 		Type: to.Ptr("Stream"),
	// 		Serialization: &armstreamanalytics.JSONSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
	// 			Properties: &armstreamanalytics.JSONSerializationProperties{
	// 				Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
	// 			},
	// 		},
	// 		Datasource: &armstreamanalytics.EventHubStreamInputDataSource{
	// 			Type: to.Ptr("Microsoft.ServiceBus/EventHub"),
	// 			Properties: &armstreamanalytics.EventHubStreamInputDataSourceProperties{
	// 				ServiceBusNamespace: to.Ptr("sdktest"),
	// 				SharedAccessPolicyName: to.Ptr("RootManageSharedAccessKey"),
	// 				EventHubName: to.Ptr("sdkeventhub"),
	// 				ConsumerGroupName: to.Ptr("sdkconsumergroup"),
	// 			},
	// 		},
	// 	},
	// }
}

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

JavaScript

const { StreamAnalyticsManagementClient } = require("@azure/arm-streamanalytics");
const { DefaultAzureCredential } = require("@azure/identity");

/**
 * This sample demonstrates how to Gets details about the specified input.
 *
 * @summary Gets details about the specified input.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Get_Stream_EventHub_JSON.json
 */
async function getAStreamEventHubInputWithJsonSerialization() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg3139";
  const jobName = "sj197";
  const inputName = "input7425";
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.get(resourceGroupName, jobName, inputName);
  console.log(result);
}

getAStreamEventHubInputWithJsonSerialization().catch(console.error);

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

Beispiel für eine Antwort

Statuscode:

200

ETag: afd0d184-37e9-4370-9e55-32501bc4de3a

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3139/providers/Microsoft.StreamAnalytics/streamingjobs/sj197/inputs/input7425",
  "name": "input7425",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.ServiceBus/EventHub",
      "properties": {
        "eventHubName": "sdkeventhub",
        "consumerGroupName": "sdkconsumergroup",
        "serviceBusNamespace": "sdktest",
        "sharedAccessPolicyName": "RootManageSharedAccessKey"
      }
    },
    "serialization": {
      "type": "Json",
      "properties": {
        "encoding": "UTF8"
      }
    }
  }
}

Get a stream IoT Hub input with Avro serialization

Beispielanforderung

HTTP

GET https://management.azure.com/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourcegroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970?api-version=2020-03-01

Java

/**
 * Samples for Inputs Get.
 */
public final class Main {
    /*
     * x-ms-original-file:
     * specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/
     * Input_Get_Stream_IoTHub_Avro.json
     */
    /**
     * Sample code: Get a stream IoT Hub input with Avro serialization.
     * 
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void getAStreamIoTHubInputWithAvroSerialization(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager.inputs().getWithResponse("sjrg3467", "sj9742", "input7970", 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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Get_Stream_IoTHub_Avro.json
func ExampleInputsClient_Get_getAStreamIoTHubInputWithAvroSerialization() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armstreamanalytics.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewInputsClient().Get(ctx, "sjrg3467", "sj9742", "input7970", nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %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.Input = armstreamanalytics.Input{
	// 	Name: to.Ptr("input7970"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970"),
	// 	Properties: &armstreamanalytics.StreamInputProperties{
	// 		Type: to.Ptr("Stream"),
	// 		Serialization: &armstreamanalytics.AvroSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeAvro),
	// 			Properties: map[string]any{
	// 			},
	// 		},
	// 		Datasource: &armstreamanalytics.IoTHubStreamInputDataSource{
	// 			Type: to.Ptr("Microsoft.Devices/IotHubs"),
	// 			Properties: &armstreamanalytics.IoTHubStreamInputDataSourceProperties{
	// 				ConsumerGroupName: to.Ptr("sdkconsumergroup"),
	// 				Endpoint: to.Ptr("messages/events"),
	// 				IotHubNamespace: to.Ptr("iothub"),
	// 				SharedAccessPolicyName: to.Ptr("owner"),
	// 			},
	// 		},
	// 	},
	// }
}

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

JavaScript

const { StreamAnalyticsManagementClient } = require("@azure/arm-streamanalytics");
const { DefaultAzureCredential } = require("@azure/identity");

/**
 * This sample demonstrates how to Gets details about the specified input.
 *
 * @summary Gets details about the specified input.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Get_Stream_IoTHub_Avro.json
 */
async function getAStreamIoTHubInputWithAvroSerialization() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg3467";
  const jobName = "sj9742";
  const inputName = "input7970";
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.get(resourceGroupName, jobName, inputName);
  console.log(result);
}

getAStreamIoTHubInputWithAvroSerialization().catch(console.error);

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

Beispiel für eine Antwort

Statuscode:

200

ETag: bd8009b3-8165-4bd3-aad2-29a2b378dd14

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970",
  "name": "input7970",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.Devices/IotHubs",
      "properties": {
        "iotHubNamespace": "iothub",
        "sharedAccessPolicyName": "owner",
        "endpoint": "messages/events",
        "consumerGroupName": "sdkconsumergroup"
      }
    },
    "serialization": {
      "type": "Avro",
      "properties": {}
    }
  }
}

Definitionen

Name	Beschreibung
AuthenticationMode	Authentifizierungsmodus. Gültige Modi sind ConnectionString, Msi und "UserToken".
AvroSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im Avro-Format geschrieben werden.
AzureSqlReferenceInputDataSource	Beschreibt eine Azure SQL-Datenbankreferenz-Eingabedatenquelle.
BlobReferenceInputDataSource	Beschreibt eine BLOB-Eingabedatenquelle, die Referenzdaten enthält.
BlobStreamInputDataSource	Beschreibt eine BLOB-Eingabedatenquelle, die Datenstromdaten enthält.
Compression	Beschreibt, wie Eingabedaten komprimiert werden
CompressionType	Gibt den Typ der Komprimierung an, die von der Eingabe verwendet wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).
CsvSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im CSV-Format geschrieben werden.
DiagnosticCondition	Bedingung, die für die Ressource oder für den Auftrag insgesamt gilt, die die Aufmerksamkeit des Kunden garantieren.
Diagnostics	Beschreibt bedingungen, die für die Eingabe, Ausgabe oder den Auftrag insgesamt gelten, die die Aufmerksamkeit der Kunden garantieren.
Encoding	Gibt die Codierung der eingehenden Daten im Falle der Eingabe und die Codierung ausgehender Daten im Falle der Ausgabe an.
Error	Häufige Fehlerdarstellung.
EventHubStreamInputDataSource	Beschreibt eine Event Hub-Eingabedatenquelle, die Datenstromdaten enthält.
EventHubV2StreamInputDataSource	Beschreibt eine Event Hub-Eingabedatenquelle, die Datenstromdaten enthält.
EventSerializationType	Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).
FileReferenceInputDataSource	Beschreibt eine Dateieingabedatenquelle, die Referenzdaten enthält.
GatewayMessageBusStreamInputDataSource	Beschreibt eine BLOB-Eingabedatenquelle, die Datenstromdaten enthält.
Input	Ein Eingabeobjekt, das alle Informationen enthält, die der benannten Eingabe zugeordnet sind. Alle Eingaben sind unter einem Streamingauftrag enthalten.
IoTHubStreamInputDataSource	Beschreibt eine IoT Hub-Eingabedatenquelle, die Datenstromdaten enthält.
JsonOutputSerializationFormat	Gibt das Format des JSON an, in dem die Ausgabe geschrieben wird. Die derzeit unterstützten Werte sind "lineSeparated", der angibt, dass die Ausgabe formatiert wird, indem jedes JSON-Objekt durch eine neue Zeile getrennt und "Array" angegeben wird, dass die Ausgabe als Array von JSON-Objekten formatiert wird.
JsonSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im JSON-Format geschrieben werden.
ParquetSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im Parkettformat geschrieben werden.
ReferenceInputProperties	Die Eigenschaften, die einer Eingabe zugeordnet sind, die Referenzdaten enthält.
RefreshType	Gibt den Typ der Datenaktualisierungsoption an.
StorageAccount	Die Eigenschaften, die einem Azure Storage-Konto zugeordnet sind
StreamInputProperties	Die Eigenschaften, die einer Eingabe zugeordnet sind, die Datenstromdaten enthält.

AuthenticationMode

Enumeration

Authentifizierungsmodus. Gültige Modi sind ConnectionString, Msi und "UserToken".

Wert	Beschreibung
ConnectionString
Msi
UserToken

AvroSerialization

Objekt

Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im Avro-Format geschrieben werden.

Name	Typ	Beschreibung
type	string: Avro	Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).

AzureSqlReferenceInputDataSource

Objekt

Beschreibt eine Azure SQL-Datenbankreferenz-Eingabedatenquelle.

Name	Typ	Beschreibung
properties.database	string	Dieses Element ist dem Datenquellenelement zugeordnet. Dies ist der Name der Datenbank, in die die Ausgabe geschrieben wird.
properties.deltaSnapshotQuery	string	Dieses Element ist dem Datenquellenelement zugeordnet. Diese Abfrage wird verwendet, um inkrementelle Änderungen aus der SQL-Datenbank abzurufen. Um diese Option zu verwenden, empfehlen wir die Verwendung zeitlicher Tabellen in der Azure SQL-Datenbank.
properties.fullSnapshotQuery	string	Dieses Element ist dem Datenquellenelement zugeordnet. Diese Abfrage wird verwendet, um Daten aus der SQL-Datenbank abzurufen.
properties.password	string	Dieses Element ist dem Datenquellenelement zugeordnet. Dies ist das Kennwort, das zum Herstellen einer Verbindung mit der SQL-Datenbankinstanz verwendet wird.
properties.refreshRate	string	Dieses Element ist dem Datenquellenelement zugeordnet. Dies gibt an, wie häufig die Daten aus der Datenbank abgerufen werden. Es ist das DateTime-Format.
properties.refreshType	RefreshType	Gibt den Typ der Datenaktualisierungsoption an.
properties.server	string	Dieses Element ist dem Datenquellenelement zugeordnet. Dies ist der Name des Servers, der die Datenbank enthält, in die geschrieben wird.
properties.table	string	Dieses Element ist dem Datenquellenelement zugeordnet. Der Name der Tabelle in der Azure SQL-Datenbank.
properties.user	string	Dieses Element ist dem Datenquellenelement zugeordnet. Dies ist der Benutzername, der zum Herstellen einer Verbindung mit der SQL-Datenbankinstanz verwendet wird.
type	string: Microsoft.Sql/Server/Database	Gibt den Typ der Eingabedatenquelle an, die Referenzdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

BlobReferenceInputDataSource

Objekt

Beschreibt eine BLOB-Eingabedatenquelle, die Referenzdaten enthält.

Name	Typ	Standardwert	Beschreibung
properties.authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.container	string		Der Name eines Containers innerhalb des zugeordneten Speicherkontos. Dieser Container enthält entweder die Blobs, aus der gelesen oder geschrieben werden soll. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.dateFormat	string		Das Datumsformat. Unabhängig davon, wo {date} in pathPattern angezeigt wird, wird der Wert dieser Eigenschaft stattdessen als Datumsformat verwendet.
properties.pathPattern	string		Das Blobpfadmuster. Kein regulärer Ausdruck. Es stellt ein Muster dar, mit dem Blobnamen abgeglichen werden, um festzustellen, ob sie als Eingabe oder Ausgabe in den Auftrag eingeschlossen werden sollen. Eine ausführlichere Erläuterung und ein weiteres Beispiel finden Sie unter https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input oder https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output.
properties.storageAccounts	StorageAccount[]		Eine Liste mit einem oder mehreren Azure Storage-Konten. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.timeFormat	string		Das Zeitformat. Unabhängig davon, wo {time} in pathPattern angezeigt wird, wird der Wert dieser Eigenschaft stattdessen als Zeitformat verwendet.
type	string: Microsoft.Storage/Blob		Gibt den Typ der Eingabedatenquelle an, die Referenzdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

BlobStreamInputDataSource

Objekt

Beschreibt eine BLOB-Eingabedatenquelle, die Datenstromdaten enthält.

Name	Typ	Standardwert	Beschreibung
properties.authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.container	string		Der Name eines Containers innerhalb des zugeordneten Speicherkontos. Dieser Container enthält entweder die Blobs, aus der gelesen oder geschrieben werden soll. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.dateFormat	string		Das Datumsformat. Unabhängig davon, wo {date} in pathPattern angezeigt wird, wird der Wert dieser Eigenschaft stattdessen als Datumsformat verwendet.
properties.pathPattern	string		Das Blobpfadmuster. Kein regulärer Ausdruck. Es stellt ein Muster dar, mit dem Blobnamen abgeglichen werden, um festzustellen, ob sie als Eingabe oder Ausgabe in den Auftrag eingeschlossen werden sollen. Eine ausführlichere Erläuterung und ein weiteres Beispiel finden Sie unter https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input oder https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output.
properties.sourcePartitionCount	integer (int32)		Die Partitionsanzahl der BLOB-Eingabedatenquelle. Bereich 1 - 1024.
properties.storageAccounts	StorageAccount[]		Eine Liste mit einem oder mehreren Azure Storage-Konten. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.timeFormat	string		Das Zeitformat. Unabhängig davon, wo {time} in pathPattern angezeigt wird, wird der Wert dieser Eigenschaft stattdessen als Zeitformat verwendet.
type	string: Microsoft.Storage/Blob		Gibt den Typ der Eingabedatenquelle an, die Datenstromdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Compression

Objekt

Beschreibt, wie Eingabedaten komprimiert werden

Name	Typ	Standardwert	Beschreibung
type	CompressionType	None	Gibt den Typ der Komprimierung an, die von der Eingabe verwendet wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).

CompressionType

Enumeration

Gibt den Typ der Komprimierung an, die von der Eingabe verwendet wird. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Wert	Beschreibung
Deflate
GZip
None

CsvSerialization

Objekt

Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im CSV-Format geschrieben werden.

Name	Typ	Beschreibung
properties.encoding	Encoding	Gibt die Codierung der eingehenden Daten im Falle der Eingabe und die Codierung ausgehender Daten im Falle der Ausgabe an. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.fieldDelimiter	string	Gibt das Trennzeichen an, das zum Trennen von durch Trennzeichen getrennten Werten (CSV)-Datensätzen verwendet wird. Eine Liste der unterstützten Werte finden Sie unter https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input oder https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Csv	Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).

DiagnosticCondition

Objekt

Bedingung, die für die Ressource oder für den Auftrag insgesamt gilt, die die Aufmerksamkeit des Kunden garantieren.

Name	Typ	Beschreibung
code	string	Der undurchsichtige Diagnosecode.
message	string	Die lesbare Nachricht, die die Bedingung detailliert beschreibt. Lokalisiert im Accept-Language der Clientanforderung.
since	string	Der UTC-Zeitstempel, zu dem die Bedingung gestartet wurde. Kunden sollten dieses Mal in der Lage sein, ein entsprechendes Ereignis im Ops-Protokoll zu finden.

Diagnostics

Objekt

Beschreibt bedingungen, die für die Eingabe, Ausgabe oder den Auftrag insgesamt gelten, die die Aufmerksamkeit der Kunden garantieren.

Name	Typ	Beschreibung
conditions	DiagnosticCondition[]	Eine Sammlung von null oder mehr Bedingungen, die für die Ressource oder für den Auftrag insgesamt gelten, die die Aufmerksamkeit der Kunden garantieren.

Encoding

Enumeration

Gibt die Codierung der eingehenden Daten im Falle der Eingabe und die Codierung ausgehender Daten im Falle der Ausgabe an.

Wert	Beschreibung
UTF8

Error

Objekt

Häufige Fehlerdarstellung.

Name	Typ	Beschreibung
error	Error	Fehlerdefinitionseigenschaften.

EventHubStreamInputDataSource

Objekt

Beschreibt eine Event Hub-Eingabedatenquelle, die Datenstromdaten enthält.

Name	Typ	Standardwert	Beschreibung
authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.consumerGroupName	string		Der Name einer Event Hub Consumer Group, die zum Lesen von Ereignissen aus dem Event Hub verwendet werden soll. Wenn Sie unterschiedliche Consumergruppennamen für mehrere Eingaben angeben, können diese Eingaben dieselben Ereignisse vom Event Hub empfangen. Wenn nicht angegeben, verwendet die Eingabe die Standard-Consumergruppe des Event Hub.
properties.eventHubName	string		Der Name des Event Hub. Erforderlich für PUT-Anforderungen (CreateOrReplace).
serviceBusNamespace	string		Der Namespace, der dem gewünschten Event Hub, Service Bus Queue, Service Bus Topic usw. zugeordnet ist. Erforderlich für PUT-Anforderungen (CreateOrReplace).
sharedAccessPolicyKey	string		Der Schlüssel für die gemeinsame Zugriffsrichtlinie für die angegebene Richtlinie für den freigegebenen Zugriff. Erforderlich für PUT-Anforderungen (CreateOrReplace).
sharedAccessPolicyName	string		Der Name der Richtlinie für den freigegebenen Zugriff für den Event Hub, service bus queue, Service Bus Topic usw. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Gibt den Typ der Eingabedatenquelle an, die Datenstromdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

EventHubV2StreamInputDataSource

Objekt

Beschreibt eine Event Hub-Eingabedatenquelle, die Datenstromdaten enthält.

Name	Typ	Standardwert	Beschreibung
authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.consumerGroupName	string		Der Name einer Event Hub Consumer Group, die zum Lesen von Ereignissen aus dem Event Hub verwendet werden soll. Wenn Sie unterschiedliche Consumergruppennamen für mehrere Eingaben angeben, können diese Eingaben dieselben Ereignisse vom Event Hub empfangen. Wenn nicht angegeben, verwendet die Eingabe die Standard-Consumergruppe des Event Hub.
properties.eventHubName	string		Der Name des Event Hub. Erforderlich für PUT-Anforderungen (CreateOrReplace).
serviceBusNamespace	string		Der Namespace, der dem gewünschten Event Hub, Service Bus Queue, Service Bus Topic usw. zugeordnet ist. Erforderlich für PUT-Anforderungen (CreateOrReplace).
sharedAccessPolicyKey	string		Der Schlüssel für die gemeinsame Zugriffsrichtlinie für die angegebene Richtlinie für den freigegebenen Zugriff. Erforderlich für PUT-Anforderungen (CreateOrReplace).
sharedAccessPolicyName	string		Der Name der Richtlinie für den freigegebenen Zugriff für den Event Hub, service bus queue, Service Bus Topic usw. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Gibt den Typ der Eingabedatenquelle an, die Datenstromdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

EventSerializationType

Enumeration

Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Wert	Beschreibung
Avro
Csv
Json
Parquet

FileReferenceInputDataSource

Objekt

Beschreibt eine Dateieingabedatenquelle, die Referenzdaten enthält.

Name	Typ	Beschreibung
properties.path	string	Der Pfad der Datei.
type	string: File	Gibt den Typ der Eingabedatenquelle an, die Referenzdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Objekt

Beschreibt eine BLOB-Eingabedatenquelle, die Datenstromdaten enthält.

Name	Typ	Beschreibung
properties.topic	string	Der Name des Themas "ServiceBus".
type	string: GatewayMessageBus	Gibt den Typ der Eingabedatenquelle an, die Datenstromdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Input

Objekt

Ein Eingabeobjekt, das alle Informationen enthält, die der benannten Eingabe zugeordnet sind. Alle Eingaben sind unter einem Streamingauftrag enthalten.

Name	Typ	Beschreibung
id	string	Ressourcen-ID
name	string	Ressourcenname
properties	InputProperties: ReferenceInputProperties StreamInputProperties	Die Eigenschaften, die einer Eingabe zugeordnet sind. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string	Ressourcentyp

IoTHubStreamInputDataSource

Objekt

Beschreibt eine IoT Hub-Eingabedatenquelle, die Datenstromdaten enthält.

Name	Typ	Beschreibung
properties.consumerGroupName	string	Der Name einer IoT Hub Consumer Group, die zum Lesen von Ereignissen aus dem IoT Hub verwendet werden soll. Wenn nicht angegeben, verwendet die Eingabe die Standard-Consumergruppe des Iot Hub.
properties.endpoint	string	Der IoT Hub-Endpunkt, mit dem eine Verbindung hergestellt werden soll (z. B. Nachrichten/Ereignisse, Nachrichten/operationsMonitoringEvents usw.).
properties.iotHubNamespace	string	Der Name oder der URI des IoT Hub. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.sharedAccessPolicyKey	string	Der Schlüssel für die gemeinsame Zugriffsrichtlinie für die angegebene Richtlinie für den freigegebenen Zugriff. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.sharedAccessPolicyName	string	Der Name der Freigegebenen Zugriffsrichtlinie für den IoT-Hub. Diese Richtlinie muss mindestens die Dienstverbindungsberechtigung enthalten. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Gibt den Typ der Eingabedatenquelle an, die Datenstromdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

JsonOutputSerializationFormat

Enumeration

Gibt das Format des JSON an, in dem die Ausgabe geschrieben wird. Die derzeit unterstützten Werte sind "lineSeparated", der angibt, dass die Ausgabe formatiert wird, indem jedes JSON-Objekt durch eine neue Zeile getrennt und "Array" angegeben wird, dass die Ausgabe als Array von JSON-Objekten formatiert wird.

Wert	Beschreibung
Array
LineSeparated

JsonSerialization

Objekt

Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im JSON-Format geschrieben werden.

Name	Typ	Beschreibung
properties.encoding	Encoding	Gibt die Codierung der eingehenden Daten im Falle der Eingabe und die Codierung ausgehender Daten im Falle der Ausgabe an. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Diese Eigenschaft gilt nur für die JSON-Serialisierung von Ausgaben. Es gilt nicht für Eingaben. Diese Eigenschaft gibt das Format des JSON an, in dem die Ausgabe geschrieben wird. Die derzeit unterstützten Werte sind "lineSeparated", der angibt, dass die Ausgabe formatiert wird, indem jedes JSON-Objekt durch eine neue Zeile getrennt und "Array" angegeben wird, dass die Ausgabe als Array von JSON-Objekten formatiert wird. Der Standardwert ist "lineSeparated", wenn links NULL ist.
type	string: Json	Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).

ParquetSerialization

Objekt

Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im Parkettformat geschrieben werden.

Name	Typ	Beschreibung
type	string: Parquet	Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).

ReferenceInputProperties

Objekt

Die Eigenschaften, die einer Eingabe zugeordnet sind, die Referenzdaten enthält.

Name	Typ	Beschreibung
compression	Compression	Beschreibt, wie Eingabedaten komprimiert werden
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Beschreibt eine Eingabedatenquelle, die Referenzdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).
diagnostics	Diagnostics	Beschreibt bedingungen, die für die Eingabe, Ausgabe oder den Auftrag insgesamt gelten, die die Aufmerksamkeit der Kunden garantieren.
etag	string	Das aktuelle Entitätstag für die Eingabe. Dies ist eine undurchsichtige Zeichenfolge. Sie können es verwenden, um zu erkennen, ob sich die Ressource zwischen Anforderungen geändert hat. Sie können sie auch in den If-Match- oder If-None-Match Headern für Schreibvorgänge für optimistische Parallelität verwenden.
partitionKey	string	partitionKey Beschreibt einen Schlüssel in den Eingabedaten, die zum Partitionieren der Eingabedaten verwendet werden
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe geschrieben werden. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Reference	Gibt an, ob es sich bei der Eingabe um eine Quelle von Referenzdaten oder Datenstromdaten handelt. Erforderlich für PUT-Anforderungen (CreateOrReplace).

RefreshType

Enumeration

Gibt den Typ der Datenaktualisierungsoption an.

Wert	Beschreibung
RefreshPeriodicallyWithDelta
RefreshPeriodicallyWithFull
Static

StorageAccount

Objekt

Die Eigenschaften, die einem Azure Storage-Konto zugeordnet sind

Name	Typ	Beschreibung
accountKey	string	Der Kontoschlüssel für das Azure Storage-Konto. Erforderlich für PUT-Anforderungen (CreateOrReplace).
accountName	string	Der Name des Azure Storage-Kontos. Erforderlich für PUT-Anforderungen (CreateOrReplace).

StreamInputProperties

Objekt

Die Eigenschaften, die einer Eingabe zugeordnet sind, die Datenstromdaten enthält.

Name	Typ	Beschreibung
compression	Compression	Beschreibt, wie Eingabedaten komprimiert werden
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Beschreibt eine Eingabedatenquelle, die Datenstrom enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).
diagnostics	Diagnostics	Beschreibt bedingungen, die für die Eingabe, Ausgabe oder den Auftrag insgesamt gelten, die die Aufmerksamkeit der Kunden garantieren.
etag	string	Das aktuelle Entitätstag für die Eingabe. Dies ist eine undurchsichtige Zeichenfolge. Sie können es verwenden, um zu erkennen, ob sich die Ressource zwischen Anforderungen geändert hat. Sie können sie auch in den If-Match- oder If-None-Match Headern für Schreibvorgänge für optimistische Parallelität verwenden.
partitionKey	string	partitionKey Beschreibt einen Schlüssel in den Eingabedaten, die zum Partitionieren der Eingabedaten verwendet werden
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe geschrieben werden. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Stream	Gibt an, ob es sich bei der Eingabe um eine Quelle von Referenzdaten oder Datenstromdaten handelt. Erforderlich für PUT-Anforderungen (CreateOrReplace).