Inputs - List By Streaming Job

Referentie

Service:: Stream Analytics

API-versie:: 2020-03-01

Lijsten alle invoerwaarden onder de opgegeven streamingtaak.

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

Met optionele parameters:

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

URI-parameters

Name	In	Vereist	Type	Description
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.
$select	query		string	De $select OData-queryparameter. Dit is een door komma's gescheiden lijst met structurele eigenschappen die moeten worden opgenomen in het antwoord of '' om alle eigenschappen op te nemen. Standaard worden alle eigenschappen geretourneerd, behalve diagnostische gegevens. Accepteert momenteel alleen '' als een geldige waarde.

Antwoorden

Name	Type	Description
200 OK	InputListResult	De invoer is vermeld onder de opgegeven streamingtaak.
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

List all inputs in a streaming job

List all inputs in a streaming job and include diagnostic information using the $select OData query parameter

List all inputs in a streaming job

Voorbeeldaanvraag

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


/**
 * Samples for Inputs ListByStreamingJob.
 */
public final class Main {
    /*
     * x-ms-original-file:
     * specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/
     * Input_ListByStreamingJob.json
     */
    /**
     * Sample code: List all inputs in a streaming job.
     * 
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void
        listAllInputsInAStreamingJob(com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager.inputs().listByStreamingJob("sjrg8440", "sj9597", null, 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_ListByStreamingJob.json
func ExampleInputsClient_NewListByStreamingJobPager_listAllInputsInAStreamingJob() {
	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)
	}
	pager := clientFactory.NewInputsClient().NewListByStreamingJobPager("sjrg8440", "sj9597", &armstreamanalytics.InputsClientListByStreamingJobOptions{Select: nil})
	for pager.More() {
		page, err := pager.NextPage(ctx)
		if err != nil {
			log.Fatalf("failed to advance page: %v", err)
		}
		for _, v := range page.Value {
			// You could use page here. We use blank identifier for just demo purposes.
			_ = v
		}
		// If the HTTP response code is 200 as defined in example definition, your page structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
		// page.InputListResult = armstreamanalytics.InputListResult{
		// 	Value: []*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"),
		// 				Etag: to.Ptr("a4ceb697-1c8f-40c8-b951-fb5ee4757437"),
		// 				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("differentContainer"),
		// 						DateFormat: to.Ptr("yyyy/MM/dd"),
		// 						PathPattern: to.Ptr("{date}/{time}"),
		// 						StorageAccounts: []*armstreamanalytics.StorageAccount{
		// 							{
		// 								AccountName: to.Ptr("someAccountName"),
		// 						}},
		// 						TimeFormat: to.Ptr("HH"),
		// 					},
		// 				},
		// 			},
		// 		},
		// 		{
		// 			Name: to.Ptr("input8899"),
		// 			Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
		// 			ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input8899"),
		// 			Properties: &armstreamanalytics.StreamInputProperties{
		// 				Type: to.Ptr("Stream"),
		// 				Etag: to.Ptr("3b35d57c-02f4-4b41-8e1d-af02a86c2fa1"),
		// 				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](32),
		// 					},
		// 				},
		// 			},
		// 		},
		// 		{
		// 			Name: to.Ptr("input7425"),
		// 			Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
		// 			ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7425"),
		// 			Properties: &armstreamanalytics.StreamInputProperties{
		// 				Type: to.Ptr("Stream"),
		// 				Etag: to.Ptr("7548f259-81b5-4ea7-b896-25c6717d98ba"),
		// 				Serialization: &armstreamanalytics.AvroSerialization{
		// 					Type: to.Ptr(armstreamanalytics.EventSerializationTypeAvro),
		// 					Properties: map[string]any{
		// 					},
		// 				},
		// 				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("differentConsumerGroupName"),
		// 					},
		// 				},
		// 			},
		// 		},
		// 		{
		// 			Name: to.Ptr("input7970"),
		// 			Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
		// 			ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7970"),
		// 			Properties: &armstreamanalytics.StreamInputProperties{
		// 				Type: to.Ptr("Stream"),
		// 				Etag: to.Ptr("e2d847e0-c95b-48ef-9e14-1afc1f2270cb"),
		// 				Serialization: &armstreamanalytics.CSVSerialization{
		// 					Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
		// 					Properties: &armstreamanalytics.CSVSerializationProperties{
		// 						Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
		// 						FieldDelimiter: to.Ptr("|"),
		// 					},
		// 				},
		// 				Datasource: &armstreamanalytics.IoTHubStreamInputDataSource{
		// 					Type: to.Ptr("Microsoft.Devices/IotHubs"),
		// 					Properties: &armstreamanalytics.IoTHubStreamInputDataSourceProperties{
		// 						ConsumerGroupName: to.Ptr("sdkconsumergroup"),
		// 						Endpoint: to.Ptr("messages/operationsMonitoringEvents"),
		// 						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 Lists all of the inputs under the specified streaming job.
 *
 * @summary Lists all of the inputs under the specified streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_ListByStreamingJob.json
 */
async function listAllInputsInAStreamingJob() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg8440";
  const jobName = "sj9597";
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const resArray = new Array();
  for await (let item of client.inputs.listByStreamingJob(resourceGroupName, jobName)) {
    resArray.push(item);
  }
  console.log(resArray);
}

listAllInputsInAStreamingJob().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

{
  "value": [
    {
      "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": "differentContainer",
            "pathPattern": "{date}/{time}",
            "dateFormat": "yyyy/MM/dd",
            "timeFormat": "HH"
          }
        },
        "serialization": {
          "type": "Csv",
          "properties": {
            "fieldDelimiter": "|",
            "encoding": "UTF8"
          }
        },
        "etag": "a4ceb697-1c8f-40c8-b951-fb5ee4757437"
      }
    },
    {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input8899",
      "name": "input8899",
      "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
      "properties": {
        "type": "Stream",
        "datasource": {
          "type": "Microsoft.Storage/Blob",
          "properties": {
            "sourcePartitionCount": 32,
            "storageAccounts": [
              {
                "accountName": "someAccountName"
              }
            ],
            "container": "state",
            "pathPattern": "{date}/{time}",
            "dateFormat": "yyyy/MM/dd",
            "timeFormat": "HH"
          }
        },
        "serialization": {
          "type": "Csv",
          "properties": {
            "fieldDelimiter": "|",
            "encoding": "UTF8"
          }
        },
        "etag": "3b35d57c-02f4-4b41-8e1d-af02a86c2fa1"
      }
    },
    {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7425",
      "name": "input7425",
      "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
      "properties": {
        "type": "Stream",
        "datasource": {
          "type": "Microsoft.ServiceBus/EventHub",
          "properties": {
            "eventHubName": "sdkeventhub",
            "consumerGroupName": "differentConsumerGroupName",
            "serviceBusNamespace": "sdktest",
            "sharedAccessPolicyName": "RootManageSharedAccessKey"
          }
        },
        "serialization": {
          "type": "Avro",
          "properties": {}
        },
        "etag": "7548f259-81b5-4ea7-b896-25c6717d98ba"
      }
    },
    {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7970",
      "name": "input7970",
      "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
      "properties": {
        "type": "Stream",
        "datasource": {
          "type": "Microsoft.Devices/IotHubs",
          "properties": {
            "iotHubNamespace": "iothub",
            "sharedAccessPolicyName": "owner",
            "endpoint": "messages/operationsMonitoringEvents",
            "consumerGroupName": "sdkconsumergroup"
          }
        },
        "serialization": {
          "type": "Csv",
          "properties": {
            "fieldDelimiter": "|",
            "encoding": "UTF8"
          }
        },
        "etag": "e2d847e0-c95b-48ef-9e14-1afc1f2270cb"
      }
    }
  ]
}

List all inputs in a streaming job and include diagnostic information using the $select OData query parameter

Voorbeeldaanvraag

GET https://management.azure.com/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourcegroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/inputs?$select=*&api-version=2020-03-01


/**
 * Samples for Inputs ListByStreamingJob.
 */
public final class Main {
    /*
     * x-ms-original-file:
     * specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/
     * Input_ListByStreamingJob_Diagnostics.json
     */
    /**
     * Sample code: List all inputs in a streaming job and include diagnostic information using the $select OData query
     * parameter.
     * 
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void listAllInputsInAStreamingJobAndIncludeDiagnosticInformationUsingTheSelectODataQueryParameter(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager.inputs().listByStreamingJob("sjrg3276", "sj7804", "*", 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/azcore/to"
	"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_ListByStreamingJob_Diagnostics.json
func ExampleInputsClient_NewListByStreamingJobPager_listAllInputsInAStreamingJobAndIncludeDiagnosticInformationUsingTheSelectODataQueryParameter() {
	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)
	}
	pager := clientFactory.NewInputsClient().NewListByStreamingJobPager("sjrg3276", "sj7804", &armstreamanalytics.InputsClientListByStreamingJobOptions{Select: to.Ptr("*")})
	for pager.More() {
		page, err := pager.NextPage(ctx)
		if err != nil {
			log.Fatalf("failed to advance page: %v", err)
		}
		for _, v := range page.Value {
			// You could use page here. We use blank identifier for just demo purposes.
			_ = v
		}
		// If the HTTP response code is 200 as defined in example definition, your page structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
		// page.InputListResult = armstreamanalytics.InputListResult{
		// 	Value: []*armstreamanalytics.Input{
		// 		{
		// 			Name: to.Ptr("inputtest"),
		// 			Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
		// 			ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/inputs/inputtest"),
		// 			Properties: &armstreamanalytics.StreamInputProperties{
		// 				Type: to.Ptr("Stream"),
		// 				Diagnostics: &armstreamanalytics.Diagnostics{
		// 					Conditions: []*armstreamanalytics.DiagnosticCondition{
		// 						{
		// 							Code: to.Ptr("INP-3"),
		// 							Message: to.Ptr("Could not deserialize the input event as Json. Some possible reasons: 1) Malformed events 2) Input source configured with incorrect serialization format"),
		// 							Since: to.Ptr("2017-05-11T04:38:42.4938687Z"),
		// 					}},
		// 				},
		// 				Etag: to.Ptr("ca88f8fa-605b-4c7f-8695-46f5faa60cd0"),
		// 				Serialization: &armstreamanalytics.JSONSerialization{
		// 					Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
		// 					Properties: &armstreamanalytics.JSONSerializationProperties{
		// 						Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
		// 					},
		// 				},
		// 				Datasource: &armstreamanalytics.BlobStreamInputDataSource{
		// 					Type: to.Ptr("Microsoft.Storage/Blob"),
		// 					Properties: &armstreamanalytics.BlobStreamInputDataSourceProperties{
		// 						Container: to.Ptr("state"),
		// 						PathPattern: to.Ptr(""),
		// 						StorageAccounts: []*armstreamanalytics.StorageAccount{
		// 							{
		// 								AccountName: to.Ptr("someAccountName"),
		// 						}},
		// 					},
		// 				},
		// 			},
		// 	}},
		// }
	}
}

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 Lists all of the inputs under the specified streaming job.
 *
 * @summary Lists all of the inputs under the specified streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_ListByStreamingJob_Diagnostics.json
 */
async function listAllInputsInAStreamingJobAndIncludeDiagnosticInformationUsingTheSelectODataQueryParameter() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const select = "*";
  const resourceGroupName = "sjrg3276";
  const jobName = "sj7804";
  const options = { select };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const resArray = new Array();
  for await (let item of client.inputs.listByStreamingJob(resourceGroupName, jobName, options)) {
    resArray.push(item);
  }
  console.log(resArray);
}

listAllInputsInAStreamingJobAndIncludeDiagnosticInformationUsingTheSelectODataQueryParameter().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

{
  "value": [
    {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/inputs/inputtest",
      "name": "inputtest",
      "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
      "properties": {
        "type": "Stream",
        "datasource": {
          "type": "Microsoft.Storage/Blob",
          "properties": {
            "storageAccounts": [
              {
                "accountName": "someAccountName"
              }
            ],
            "container": "state",
            "pathPattern": ""
          }
        },
        "serialization": {
          "type": "Json",
          "properties": {
            "encoding": "UTF8"
          }
        },
        "diagnostics": {
          "conditions": [
            {
              "since": "2017-05-11T04:38:42.4938687Z",
              "code": "INP-3",
              "message": "Could not deserialize the input event as Json. Some possible reasons: 1) Malformed events 2) Input source configured with incorrect serialization format"
            }
          ]
        },
        "etag": "ca88f8fa-605b-4c7f-8695-46f5faa60cd0"
      }
    }
  ]
}

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 databasereferentiegegevensbron.
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	Hierin wordt beschreven 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 aandacht van de klant vereist.
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.
InputListResult	Object met een lijst met invoer onder een streamingtaak.
IoTHubStreamInputDataSource	Beschrijft een IoT Hub invoergegevensbron die stroomgegevens bevat.
JsonOutputSerializationFormat	Hiermee geeft u de indeling 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.
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	Beschrijft 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	Geeft het type optie voor het vernieuwen van gegevens aan.
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 databasereferentiegegevensbron.

Name	Type	Description
properties.database	string	Dit element is gekoppeld aan het gegevensbronelement. Dit is de naam van de database waarnaar de 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. Dit geeft aan hoe vaak de gegevens uit de database worden opgehaald. Het heeft de datum/tijd-indeling.
properties.refreshType	RefreshType	Geeft het type optie voor het vernieuwen van gegevens aan.
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 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.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

Hierin wordt beschreven 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 records met door komma's gescheiden waarden (CSV) 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 aandacht van de klant vereist.

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	Geeft het type invoergegevensbron met stroomgegevens aan. 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

InputListResult

Object met een lijst met invoer onder een streamingtaak.

Name	Type	Description
nextLink	string	De koppeling (URL) naar de volgende pagina met resultaten.
value	Input[]	Een lijst met invoer onder een streamingtaak. Gevuld met een 'Lijst'-bewerking.

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 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. Dit 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 null blijft.
type	string: Json	Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

ParquetSerialization

Beschrijft 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

Geeft het type optie voor het vernieuwen van gegevens aan.

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 - List By Streaming Job

URI-parameters

Antwoorden

Beveiliging

azure_auth

Bereiken

Voorbeelden

List all inputs in a streaming job

Voorbeeldaanvraag

Voorbeeldrespons

List all inputs in a streaming job and include diagnostic information using the $select OData query parameter

Voorbeeldaanvraag

Voorbeeldrespons

Definities

AuthenticationMode

AvroSerialization

AzureSqlReferenceInputDataSource

BlobReferenceInputDataSource

BlobStreamInputDataSource

Compression

CompressionType

CsvSerialization

DiagnosticCondition

Diagnostics

Encoding

Error

EventHubStreamInputDataSource

EventHubV2StreamInputDataSource

EventSerializationType

FileReferenceInputDataSource

GatewayMessageBusStreamInputDataSource

Input

InputListResult

IoTHubStreamInputDataSource

JsonOutputSerializationFormat

JsonSerialization

ParquetSerialization

ReferenceInputProperties

RefreshType

StorageAccount

StreamInputProperties

Aanvullende resources