Inputs - Get

Referentie

Service:: Stream Analytics

API-versie:: 2020-03-01

Hiermee haalt u details op over de opgegeven invoer.

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

URI-parameters

Name	In	Vereist	Type	Description
inputName	path	True	string	De naam van de invoer.
jobName	path	True	string	De naam van de streamingtaak.
resourceGroupName	path	True	string	De naam van de resourcegroep. De naam is niet hoofdlettergevoelig. Regex-patroon: `^[-\w\._]+$`
subscriptionId	path	True	string	De id van het doelabonnement.
api-version	query	True	string	De API-versie die voor deze bewerking moet worden gebruikt.

Antwoorden

Name	Type	Description
200 OK	Input	De opgegeven invoer is opgehaald. Kopteksten ETag: string
Other Status Codes	Error	Fout.

Name

Type

Description

200 OK

Input

De opgegeven invoer is opgehaald.

Kopteksten

ETag: string

Other Status Codes

Error

Fout.

Beveiliging

azure_auth

Azure Active Directory OAuth2-stroom

Type: oauth2
Stroom: implicit
Autorisatie-URL: https://login.microsoftonline.com/common/oauth2/authorize

Bereiken

Name	Description
user_impersonation	uw gebruikersaccount imiteren

Voorbeelden

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

Voorbeeldaanvraag

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


/**
 * 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

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

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

Voorbeeldrespons

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

Voorbeeldaanvraag

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


/**
 * 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

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

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

Voorbeeldrespons

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

Voorbeeldaanvraag

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


/**
 * 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

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

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

Voorbeeldrespons

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

Voorbeeldaanvraag

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


/**
 * 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

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

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

Voorbeeldrespons

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": {}
    }
  }
}

Definities

Name	Description
AuthenticationMode	Verificatiemodus. Geldige modi zijn `ConnectionString`, `Msi` en 'UserToken'.
AvroSerialization	Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in Avro-indeling worden geschreven.
AzureSqlReferenceInputDataSource	Beschrijft een Azure SQL databasereferentieinvoergegevensbron.
BlobReferenceInputDataSource	Beschrijft een blob-invoergegevensbron die referentiegegevens bevat.
BlobStreamInputDataSource	Beschrijft een blob-invoergegevensbron die stroomgegevens bevat.
Compression	Beschrijft hoe invoergegevens worden gecomprimeerd
CompressionType	Geeft het type compressie aan dat door de invoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).
CsvSerialization	Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in CSV-indeling worden geschreven.
DiagnosticCondition	Voorwaarde die van toepassing is op de resource, of op de taak in het algemeen, die de aandacht van de klant rechtvaardigt.
Diagnostics	Beschrijft voorwaarden die van toepassing zijn op de invoer, uitvoer of de taak in het algemeen, die aandacht van de klant vereisen.
Encoding	Hiermee geeft u de codering van de binnenkomende gegevens in het geval van invoer en de codering van uitgaande gegevens in het geval van uitvoer.
Error	Veelvoorkomende foutweergave.
EventHubStreamInputDataSource	Beschrijft een Event Hub-invoergegevensbron die stroomgegevens bevat.
EventHubV2StreamInputDataSource	Beschrijft een Event Hub-invoergegevensbron die stroomgegevens bevat.
EventSerializationType	Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).
FileReferenceInputDataSource	Beschrijft een bestandsinvoergegevensbron die referentiegegevens bevat.
GatewayMessageBusStreamInputDataSource	Beschrijft een blob-invoergegevensbron die stroomgegevens bevat.
Input	Een invoerobject, dat alle informatie bevat die is gekoppeld aan de benoemde invoer. Alle invoer bevindt zich onder een streamingtaak.
IoTHubStreamInputDataSource	Beschrijft een IoT Hub invoergegevensbron die stroomgegevens bevat.
JsonOutputSerializationFormat	Hiermee geeft u de indeling van de JSON op waarin de uitvoer wordt geschreven. De momenteel ondersteunde waarden zijn 'lineSeparated' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt door elk JSON-object te laten scheiden door een nieuwe regel en 'matrix' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt als een matrix van JSON-objecten.
JsonSerialization	Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in JSON-indeling worden geschreven.
ParquetSerialization	Hierin wordt beschreven hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in Parquet-indeling worden geschreven.
ReferenceInputProperties	De eigenschappen die zijn gekoppeld aan een invoer die referentiegegevens bevat.
RefreshType	Hiermee wordt het type optie voor het vernieuwen van gegevens aangegeven.
StorageAccount	De eigenschappen die zijn gekoppeld aan een Azure Storage-account
StreamInputProperties	De eigenschappen die zijn gekoppeld aan een invoer die stroomgegevens bevat.

AuthenticationMode

Verificatiemodus. Geldige modi zijn ConnectionString, Msi en 'UserToken'.

Name	Type	Description
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in Avro-indeling worden geschreven.

Name	Type	Description
type	string: Avro	Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

AzureSqlReferenceInputDataSource

Beschrijft een Azure SQL databasereferentieinvoergegevensbron.

Name	Type	Description
properties.database	string	Dit element is gekoppeld aan het gegevensbronelement. Dit is de naam van de database waarnaar uitvoer wordt geschreven.
properties.deltaSnapshotQuery	string	Dit element is gekoppeld aan het gegevensbronelement. Deze query wordt gebruikt om incrementele wijzigingen op te halen uit de SQL-database. Als u deze optie wilt gebruiken, raden we u aan tijdelijke tabellen te gebruiken in Azure SQL Database.
properties.fullSnapshotQuery	string	Dit element is gekoppeld aan het gegevensbronelement. Deze query wordt gebruikt om gegevens op te halen uit de SQL-database.
properties.password	string	Dit element is gekoppeld aan het gegevensbronelement. Dit is het wachtwoord dat wordt gebruikt om verbinding te maken met het SQL Database-exemplaar.
properties.refreshRate	string	Dit element is gekoppeld aan het gegevensbronelement. Hiermee wordt aangegeven hoe vaak de gegevens uit de database worden opgehaald. Het heeft de datum/tijd-indeling.
properties.refreshType	RefreshType	Hiermee wordt het type optie voor het vernieuwen van gegevens aangegeven.
properties.server	string	Dit element is gekoppeld aan het gegevensbronelement. Dit is de naam van de server die de database bevat waarnaar wordt geschreven.
properties.table	string	Dit element is gekoppeld aan het gegevensbronelement. De naam van de tabel in de Azure SQL database.
properties.user	string	Dit element is gekoppeld aan het gegevensbronelement. Dit is de gebruikersnaam die wordt gebruikt om verbinding te maken met het SQL Database exemplaar.
type	string: Microsoft.Sql/Server/Database	Geeft het type invoergegevensbron met referentiegegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

BlobReferenceInputDataSource

Beschrijft een blob-invoergegevensbron die referentiegegevens bevat.

Name	Type	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.container	string		De naam van een container in het gekoppelde opslagaccount. Deze container bevat de blob(s) waaruit moet worden gelezen of geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.dateFormat	string		De datumnotatie. Overal waar {date} wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als datumnotatie.
properties.pathPattern	string		Het blobpadpatroon. Geen reguliere expressie. Het vertegenwoordigt een patroon waarmee blobnamen worden vergeleken om te bepalen of ze moeten worden opgenomen als invoer of uitvoer voor de taak. Zie https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input of https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output voor een meer gedetailleerde uitleg en voorbeeld.
properties.storageAccounts	StorageAccount[]		Een lijst met een of meer Azure Storage-accounts. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.timeFormat	string		De tijdnotatie. Overal waar {time} wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de tijdnotatie.
type	string: Microsoft.Storage/Blob		Geeft het type invoergegevensbron met referentiegegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

BlobStreamInputDataSource

Beschrijft een blob-invoergegevensbron die stroomgegevens bevat.

Name	Type	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.container	string		De naam van een container in het gekoppelde opslagaccount. Deze container bevat de blob(s) waaruit moet worden gelezen of geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.dateFormat	string		De datumnotatie. Overal waar {date} wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de datumnotatie.
properties.pathPattern	string		Het blobpadpatroon. Geen reguliere expressie. Het vertegenwoordigt een patroon waarmee blobnamen worden vergeleken om te bepalen of ze moeten worden opgenomen als invoer of uitvoer voor de taak. Zie https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input of https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output voor een meer gedetailleerde uitleg en voorbeeld.
properties.sourcePartitionCount	integer		Het aantal partities van de blob-invoergegevensbron. Bereik 1 - 1024.
properties.storageAccounts	StorageAccount[]		Een lijst met een of meer Azure Storage-accounts. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.timeFormat	string		De tijdnotatie. Overal waar {time} wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de tijdnotatie.
type	string: Microsoft.Storage/Blob		Geeft het type invoergegevensbron met stroomgegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

Compression

Beschrijft hoe invoergegevens worden gecomprimeerd

Name	Type	Default value	Description
type	CompressionType	None	Geeft het type compressie aan dat door de invoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

CompressionType

Geeft het type compressie aan dat door de invoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

Name	Type	Description
Deflate	string
GZip	string
None	string

CsvSerialization

Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in CSV-indeling worden geschreven.

Name	Type	Description
properties.encoding	Encoding	Hiermee geeft u de codering van de binnenkomende gegevens in het geval van invoer en de codering van uitgaande gegevens in het geval van uitvoer. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.fieldDelimiter	string	Hiermee geeft u het scheidingsteken op dat wordt gebruikt om csv-records (door komma's gescheiden waarden) te scheiden. Zie https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input of https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output voor een lijst met ondersteunde waarden. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Csv	Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

DiagnosticCondition

Voorwaarde die van toepassing is op de resource, of op de taak in het algemeen, die de aandacht van de klant rechtvaardigt.

Name	Type	Description
code	string	De ondoorzichtige diagnostische code.
message	string	Het voor mensen leesbare bericht waarin de voorwaarde in detail wordt beschreven. Gelokaliseerd in de Accept-Language van de clientaanvraag.
since	string	Het UTC-tijdstempel van wanneer de voorwaarde is gestart. Klanten moeten rond deze tijd een bijbehorende gebeurtenis kunnen vinden in het ops-logboek.

Diagnostics

Beschrijft voorwaarden die van toepassing zijn op de invoer, uitvoer of de taak in het algemeen, die aandacht van de klant vereisen.

Name	Type	Description
conditions	DiagnosticCondition[]	Een verzameling van nul of meer voorwaarden die van toepassing zijn op de resource of op de taak in het algemeen, die aandacht van de klant vereisen.

Encoding

Hiermee geeft u de codering van de binnenkomende gegevens in het geval van invoer en de codering van uitgaande gegevens in het geval van uitvoer.

Name	Type	Description
UTF8	string

Error

Veelvoorkomende foutweergave.

Name	Type	Description
error	Error	Eigenschappen van foutdefinitie.

EventHubStreamInputDataSource

Beschrijft een Event Hub-invoergegevensbron die stroomgegevens bevat.

Name	Type	Default value	Description
authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.consumerGroupName	string		De naam van een Event Hub-consumentengroep die moet worden gebruikt om gebeurtenissen uit de Event Hub te lezen. Door afzonderlijke namen van consumentengroepen op te geven voor meerdere invoergegevens, kan elk van deze invoer dezelfde gebeurtenissen ontvangen van de Event Hub. Als dit niet is opgegeven, wordt voor de invoer de standaardconsumenergroep van de Event Hub gebruikt.
properties.eventHubName	string		De naam van de Event Hub. Vereist voor PUT-aanvragen (CreateOrReplace).
serviceBusNamespace	string		De naamruimte die is gekoppeld aan de gewenste Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
sharedAccessPolicyKey	string		De sleutel voor het gedeelde toegangsbeleid voor het opgegeven beleid voor gedeelde toegang. Vereist voor PUT-aanvragen (CreateOrReplace).
sharedAccessPolicyName	string		De naam van het beleid voor gedeelde toegang voor de Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Geeft het type invoergegevensbron met stroomgegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

EventHubV2StreamInputDataSource

Beschrijft een Event Hub-invoergegevensbron die stroomgegevens bevat.

Name	Type	Default value	Description
authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.consumerGroupName	string		De naam van een Event Hub-consumentengroep die moet worden gebruikt om gebeurtenissen uit de Event Hub te lezen. Door afzonderlijke namen van consumentengroepen op te geven voor meerdere invoergegevens, kan elk van deze invoer dezelfde gebeurtenissen ontvangen van de Event Hub. Als dit niet is opgegeven, wordt voor de invoer de standaardconsumenergroep van de Event Hub gebruikt.
properties.eventHubName	string		De naam van de Event Hub. Vereist voor PUT-aanvragen (CreateOrReplace).
serviceBusNamespace	string		De naamruimte die is gekoppeld aan de gewenste Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
sharedAccessPolicyKey	string		De sleutel voor het gedeelde toegangsbeleid voor het opgegeven beleid voor gedeelde toegang. Vereist voor PUT-aanvragen (CreateOrReplace).
sharedAccessPolicyName	string		De naam van het beleid voor gedeelde toegang voor de Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Geeft het type invoergegevensbron met stroomgegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

EventSerializationType

Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

Name	Type	Description
Avro	string
Csv	string
Json	string
Parquet	string

FileReferenceInputDataSource

Beschrijft een bestandsinvoergegevensbron die referentiegegevens bevat.

Name	Type	Description
properties.path	string	Het pad van het bestand.
type	string: File	Geeft het type invoergegevensbron met referentiegegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Beschrijft een blob-invoergegevensbron die stroomgegevens bevat.

Name	Type	Description
properties.topic	string	De naam van het Service Bus-onderwerp.
type	string: GatewayMessageBus	Hiermee wordt het type invoergegevensbron met stroomgegevens aangegeven. Vereist voor PUT-aanvragen (CreateOrReplace).

Input

Een invoerobject, dat alle informatie bevat die is gekoppeld aan de benoemde invoer. Alle invoer bevindt zich onder een streamingtaak.

Name	Type	Description
id	string	Resource-id
name	string	Resourcenaam
properties	InputProperties: ReferenceInputProperties StreamInputProperties	De eigenschappen die zijn gekoppeld aan een invoer. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string	Resourcetype

IoTHubStreamInputDataSource

Beschrijft een IoT Hub invoergegevensbron die stroomgegevens bevat.

Name	Type	Description
properties.consumerGroupName	string	De naam van een IoT Hub consumentengroep die moet worden gebruikt om gebeurtenissen uit de IoT Hub te lezen. Als dit niet is opgegeven, gebruikt de invoer de standaardconsumenergroep van de IoT Hub.
properties.endpoint	string	De IoT Hub eindpunt om verbinding mee te maken (bijvoorbeeld berichten/gebeurtenissen, berichten/bewerkingenMonitoringEvents, enzovoort).
properties.iotHubNamespace	string	De naam of de URI van de IoT Hub. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.sharedAccessPolicyKey	string	De sleutel voor het gedeelde toegangsbeleid voor het opgegeven beleid voor gedeelde toegang. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.sharedAccessPolicyName	string	De naam van het beleid voor gedeelde toegang voor de IoT Hub. Dit beleid moet ten minste de machtiging Service connect bevatten. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Geeft het type invoergegevensbron met stroomgegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

JsonOutputSerializationFormat

Hiermee geeft u de indeling van de JSON op waarin de uitvoer wordt geschreven. De momenteel ondersteunde waarden zijn 'lineSeparated' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt door elk JSON-object te laten scheiden door een nieuwe regel en 'matrix' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt als een matrix van JSON-objecten.

Name	Type	Description
Array	string
LineSeparated	string

JsonSerialization

Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in JSON-indeling worden geschreven.

Name	Type	Description
properties.encoding	Encoding	Hiermee geeft u de codering van de binnenkomende gegevens in het geval van invoer en de codering van uitgaande gegevens in het geval van uitvoer. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Deze eigenschap is alleen van toepassing op JSON-serialisatie van uitvoer. Deze is niet van toepassing op invoer. Deze eigenschap geeft de indeling op van de JSON waarin de uitvoer wordt geschreven. De momenteel ondersteunde waarden zijn 'lineSeparated' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt door elk JSON-object te laten scheiden door een nieuwe regel en 'matrix' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt als een matrix van JSON-objecten. De standaardwaarde is 'lineSeparated' als deze waarde null blijft.
type	string: Json	Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

ParquetSerialization

Hierin wordt beschreven hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in Parquet-indeling worden geschreven.

Name	Type	Description
type	string: Parquet	Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

ReferenceInputProperties

De eigenschappen die zijn gekoppeld aan een invoer die referentiegegevens bevat.

Name	Type	Description
compression	Compression	Beschrijft hoe invoergegevens worden gecomprimeerd
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Beschrijft een invoergegevensbron die referentiegegevens bevat. Vereist voor PUT-aanvragen (CreateOrReplace).
diagnostics	Diagnostics	Beschrijft voorwaarden die van toepassing zijn op de invoer, uitvoer of de taak in het algemeen, die aandacht van de klant vereisen.
etag	string	De huidige entiteitstag voor de invoer. Dit is een ondoorzichtige tekenreeks. U kunt deze gebruiken om te detecteren of de resource tussen aanvragen is gewijzigd. U kunt deze ook gebruiken in de If-Match- of If-None-Match-headers voor schrijfbewerkingen voor optimistische gelijktijdigheid.
partitionKey	string	partitionKey beschrijft een sleutel in de invoergegevens die wordt gebruikt voor het partitioneren van de invoergegevens
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer worden geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Reference	Geeft aan of de invoer een bron van referentiegegevens of stroomgegevens is. Vereist voor PUT-aanvragen (CreateOrReplace).

RefreshType

Hiermee wordt het type optie voor het vernieuwen van gegevens aangegeven.

Name	Type	Description
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

StorageAccount

De eigenschappen die zijn gekoppeld aan een Azure Storage-account

Name	Type	Description
accountKey	string	De accountsleutel voor het Azure Storage-account. Vereist voor PUT-aanvragen (CreateOrReplace).
accountName	string	De naam van het Azure Storage-account. Vereist voor PUT-aanvragen (CreateOrReplace).

StreamInputProperties

De eigenschappen die zijn gekoppeld aan een invoer die stroomgegevens bevat.

Name	Type	Description
compression	Compression	Beschrijft hoe invoergegevens worden gecomprimeerd
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Beschrijft een invoergegevensbron die stroomgegevens bevat. Vereist voor PUT-aanvragen (CreateOrReplace).
diagnostics	Diagnostics	Beschrijft voorwaarden die van toepassing zijn op de invoer, uitvoer of de taak in het algemeen, die aandacht van de klant vereisen.
etag	string	De huidige entiteitstag voor de invoer. Dit is een ondoorzichtige tekenreeks. U kunt deze gebruiken om te detecteren of de resource tussen aanvragen is gewijzigd. U kunt deze ook gebruiken in de If-Match- of If-None-Match-headers voor schrijfbewerkingen voor optimistische gelijktijdigheid.
partitionKey	string	partitionKey beschrijft een sleutel in de invoergegevens die wordt gebruikt voor het partitioneren van de invoergegevens
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer worden geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Stream	Geeft aan of de invoer een bron van referentiegegevens of stroomgegevens is. Vereist voor PUT-aanvragen (CreateOrReplace).

Delen via

Inputs - Get

URI-parameters

Antwoorden

Beveiliging

azure_auth

Bereiken

Voorbeelden

Get a reference blob input with CSV serialization

Voorbeeldaanvraag

Voorbeeldrespons

Get a stream blob input with CSV serialization

Voorbeeldaanvraag

Voorbeeldrespons

Get a stream Event Hub input with JSON serialization

Voorbeeldaanvraag

Voorbeeldrespons

Get a stream IoT Hub input with Avro serialization

Voorbeeldaanvraag

Voorbeeldrespons

Definities

AuthenticationMode

AvroSerialization

AzureSqlReferenceInputDataSource

BlobReferenceInputDataSource

BlobStreamInputDataSource

Compression

CompressionType

CsvSerialization

DiagnosticCondition

Diagnostics

Encoding

Error

EventHubStreamInputDataSource

EventHubV2StreamInputDataSource

EventSerializationType

FileReferenceInputDataSource

GatewayMessageBusStreamInputDataSource

Input

IoTHubStreamInputDataSource

JsonOutputSerializationFormat

JsonSerialization

ParquetSerialization

ReferenceInputProperties

RefreshType

StorageAccount

StreamInputProperties

Aanvullende resources