Inputs - List By Streaming Job

Služba:

Stream Analytics

Verze rozhraní API:

2020-03-01

Seznamy všechny vstupy v rámci zadané úlohy streamování.

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

S volitelnými parametry:

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

Parametry identifikátoru URI

Name	V	Vyžadováno	Typ	Description
jobName	path	True	string	Název úlohy streamování.
resourceGroupName	path	True	string	Název skupiny prostředků. V názvu se rozlišují malá a velká písmena. Vzor regulárního výrazu: ^[-\w\._\(\)]+$
subscriptionId	path	True	string	ID cílového předplatného.
api-version	query	True	string	Verze rozhraní API, která se má použít pro tuto operaci.
$select	query		string	Parametr dotazu $select OData. Jedná se o seznam vlastností struktury oddělených čárkami, které se mají zahrnout do odpovědi, nebo "" pro zahrnutí všech vlastností. Ve výchozím nastavení se vrátí všechny vlastnosti s výjimkou diagnostiky. V současné době přijímá pouze '' jako platnou hodnotu.

Odpovědi

Name	Typ	Description
200 OK	InputListResult	Pod zadanou úlohou streamování se úspěšně vypsaly vstupy.
Other Status Codes	Error	Chyba

Zabezpečení

azure_auth

Tok Azure Active Directory OAuth2

Typ: oauth2
Tok: implicit
URL autorizace: https://login.microsoftonline.com/common/oauth2/authorize

Rozsahy

Name	Description
user_impersonation	zosobnění uživatelského účtu

Příklady

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

Ukázkový požadavek

HTTP

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

Java

import com.azure.core.util.Context;

/** 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, Context.NONE);
    }
}

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

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

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_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

JavaScript

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

Ukázková odpověď

Stavový kód:

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

Ukázkový požadavek

HTTP

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

Java

import com.azure.core.util.Context;

/** 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", "*", Context.NONE);
    }
}

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/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

JavaScript

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

Ukázková odpověď

Stavový kód:

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"
      }
    }
  ]
}

Definice

Name	Description
AuthenticationMode	Režim ověřování. Platné režimy jsou ConnectionString, Msi a 'UserToken'.
AvroSerialization	Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu Avro.
AzureSqlReferenceInputDataSource	Popisuje referenční vstupní zdroj dat Azure SQL databáze.
BlobReferenceInputDataSource	Popisuje vstupní zdroj dat objektu blob, který obsahuje referenční data.
BlobStreamInputDataSource	Popisuje vstupní zdroj dat objektu blob, který obsahuje streamová data.
Compression	Popisuje, jak se komprimují vstupní data.
CompressionType	Určuje typ komprese, kterou vstup používá. Vyžaduje se u požadavků PUT (CreateOrReplace).
CsvSerialization	Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu CSV.
DiagnosticCondition	Podmínka vztahující se na prostředek nebo celkovou úlohu, která si zaslouží pozornost zákazníka.
Diagnostics	Popisuje podmínky vztahující se na vstup, výstup nebo celkovou úlohu, které vyžadují pozornost zákazníka.
Encoding	Určuje kódování příchozích dat v případě vstupu a kódování odchozích dat v případě výstupu.
Error	Běžná reprezentace chyb
EventHubStreamInputDataSource	Popisuje vstupní zdroj dat centra událostí, který obsahuje streamová data.
EventHubV2StreamInputDataSource	Popisuje vstupní zdroj dat centra událostí, který obsahuje streamová data.
EventSerializationType	Označuje typ serializace, který používá vstup nebo výstup. Vyžaduje se u požadavků PUT (CreateOrReplace).
FileReferenceInputDataSource	Popisuje vstupní zdroj dat souboru, který obsahuje referenční data.
GatewayMessageBusStreamInputDataSource	Popisuje vstupní zdroj dat objektu blob, který obsahuje streamová data.
Input	Vstupní objekt obsahující všechny informace spojené s pojmenovaným vstupem. Všechny vstupy jsou obsažené v úloze streamování.
InputListResult	Objekt obsahující seznam vstupů v rámci úlohy streamování.
IoTHubStreamInputDataSource	Popisuje IoT Hub vstupní zdroj dat, který obsahuje streamová data.
JsonOutputSerializationFormat	Určuje formát JSON, ve kterém se bude výstup zapisovat. Aktuálně podporované hodnoty jsou lineSeparated, což znamená, že výstup bude formátován tak, že každý objekt JSON bude oddělený novým řádkem a pole, které označuje, že výstup bude formátován jako pole objektů JSON.
JsonSerialization	Popisuje, jak se serializují data ze vstupu nebo jak se data serializují při zápisu do výstupu ve formátu JSON.
ParquetSerialization	Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu Parquet.
ReferenceInputProperties	Vlastnosti, které jsou přidruženy ke vstupu obsahujícího referenční data.
RefreshType	Označuje typ možnosti aktualizace dat.
StorageAccount	Vlastnosti přidružené k účtu služby Azure Storage
StreamInputProperties	Vlastnosti, které jsou přidruženy ke vstupu obsahujícímu data datového proudu.

AuthenticationMode

Režim ověřování. Platné režimy jsou ConnectionString, Msi a 'UserToken'.

Name	Typ	Description
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu Avro.

Name	Typ	Description
type	string: Avro	Označuje typ serializace, který používá vstup nebo výstup. Vyžaduje se u požadavků PUT (CreateOrReplace).

AzureSqlReferenceInputDataSource

Popisuje referenční vstupní zdroj dat Azure SQL databáze.

Name	Typ	Description
properties.database	string	Tento prvek je přidružen k elementu zdroje dat. Toto je název databáze, do které se zapíše výstup.
properties.deltaSnapshotQuery	string	Tento prvek je přidružen k elementu zdroje dat. Tento dotaz se používá k načtení přírůstkových změn z databáze SQL. Pokud chcete použít tuto možnost, doporučujeme ve službě Azure SQL Database používat dočasné tabulky.
properties.fullSnapshotQuery	string	Tento prvek je přidružen k elementu zdroje dat. Tento dotaz se používá k načtení dat z databáze SQL.
properties.password	string	Tento prvek je přidružen k elementu zdroje dat. Toto je heslo, které se použije pro připojení k instanci SQL Database.
properties.refreshRate	string	Tento prvek je přidružen k elementu zdroje dat. To určuje, jak často se budou data načítat z databáze. Má formát DateTime.
properties.refreshType	RefreshType	Označuje typ možnosti aktualizace dat.
properties.server	string	Tento prvek je přidružen k elementu zdroje dat. Toto je název serveru, který obsahuje databázi, na kterou se bude zapisovat.
properties.table	string	Tento prvek je přidružen k elementu zdroje dat. Název tabulky v databázi Azure SQL.
properties.user	string	Tento prvek je přidružen k elementu zdroje dat. Toto je uživatelské jméno, které se použije pro připojení k instanci SQL Database.
type	string: Microsoft.Sql/Server/Database	Určuje typ vstupního zdroje dat obsahujícího referenční data. Vyžaduje se u požadavků PUT (CreateOrReplace).

BlobReferenceInputDataSource

Popisuje vstupní zdroj dat objektu blob, který obsahuje referenční data.

Name	Typ	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Režim ověřování.
properties.container	string		Název kontejneru v rámci přidruženého účtu úložiště. Tento kontejner obsahuje buď objekty blob, ze které se mají číst, nebo do které se mají zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.dateFormat	string		Formát data. Kdykoli se {date} zobrazí v pathPattern, použije se jako formát data hodnota této vlastnosti.
properties.pathPattern	string		Vzor cesty k objektu blob Nejedná se o regulární výraz. Představuje vzor, podle kterého se budou názvy objektů blob shodovat, aby bylo možné určit, jestli se mají zahrnout jako vstup nebo výstup do úlohy. Podrobnější vysvětlení a příklad najdete v tématu https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input nebo https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output .
properties.storageAccounts	StorageAccount[]		Seznam jednoho nebo více účtů Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.timeFormat	string		Formát času. Kdykoli se {time} zobrazí v pathPattern, použije se jako formát času hodnota této vlastnosti.
type	string: Microsoft.Storage/Blob		Určuje typ vstupního zdroje dat obsahujícího referenční data. Vyžaduje se u požadavků PUT (CreateOrReplace).

BlobStreamInputDataSource

Popisuje vstupní zdroj dat objektu blob, který obsahuje streamová data.

Name	Typ	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Režim ověřování.
properties.container	string		Název kontejneru v rámci přidruženého účtu úložiště. Tento kontejner obsahuje objekty blob, ze které se mají číst, nebo do které se zapisuje. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.dateFormat	string		Formát data. Kdykoli se {date} zobrazí v pathPattern, použije se jako formát data hodnota této vlastnosti.
properties.pathPattern	string		Vzor cesty k objektu blob. Nejedná se o regulární výraz. Představuje vzor, podle kterého se názvy objektů blob budou shodovat, aby bylo možné určit, jestli se mají zahrnout jako vstup nebo výstup do úlohy. Podrobnější vysvětlení a příklad najdete https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input v tématu nebo https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output .
properties.sourcePartitionCount	integer		Počet oddílů vstupního zdroje dat objektu blob. Rozsah 1 až 1024.
properties.storageAccounts	StorageAccount[]		Seznam jednoho nebo více účtů Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.timeFormat	string		Formát času. Kdykoli se {time} zobrazí v pathPattern, použije se jako formát času hodnota této vlastnosti.
type	string: Microsoft.Storage/Blob		Označuje typ vstupního zdroje dat obsahujícího streamová data. Vyžaduje se u požadavků PUT (CreateOrReplace).

Compression

Popisuje, jak se komprimují vstupní data.

Name	Typ	Default value	Description
type	CompressionType	None	Označuje typ komprese, kterou vstup používá. Vyžaduje se u požadavků PUT (CreateOrReplace).

CompressionType

Určuje typ komprese, kterou vstup používá. Vyžaduje se u požadavků PUT (CreateOrReplace).

Name	Typ	Description
Deflate	string
GZip	string
None	string

CsvSerialization

Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu CSV.

Name	Typ	Description
properties.encoding	Encoding	Určuje kódování příchozích dat v případě vstupu a kódování odchozích dat v případě výstupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.fieldDelimiter	string	Určuje oddělovač, který se použije k oddělení záznamů hodnot oddělených čárkami (CSV). Seznam podporovaných hodnot najdete https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input v tématu nebo https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output . Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Csv	Označuje typ serializace, který používá vstup nebo výstup. Vyžaduje se u požadavků PUT (CreateOrReplace).

DiagnosticCondition

Podmínka vztahující se na prostředek nebo celkovou úlohu, která si zaslouží pozornost zákazníka.

Name	Typ	Description
code	string	Neprůžný diagnostický kód.
message	string	Zpráva čitelná pro člověka, která podrobně popisuje podmínku. Lokalizované v Accept-Language požadavku klienta.
since	string	Časové razítko UTC, kdy byla podmínka spuštěna. Zákazníci by měli být schopni najít odpovídající událost v provozním protokolu přibližně v této době.

Diagnostics

Popisuje podmínky vztahující se na vstup, výstup nebo celkovou úlohu, které vyžadují pozornost zákazníka.

Name	Typ	Description
conditions	DiagnosticCondition[]	Kolekce nulových nebo více podmínek vztahujících se na prostředek nebo na celkovou úlohu, které vyžadují pozornost zákazníka.

Encoding

Určuje kódování příchozích dat v případě vstupu a kódování odchozích dat v případě výstupu.

Name	Typ	Description
UTF8	string

Error

Běžná reprezentace chyb

Name	Typ	Description
error	Error	Vlastnosti definice chyby.

EventHubStreamInputDataSource

Popisuje vstupní zdroj dat centra událostí, který obsahuje streamová data.

Name	Typ	Default value	Description
authenticationMode	AuthenticationMode	ConnectionString	Režim ověřování.
properties.consumerGroupName	string		Název skupiny příjemců centra událostí, která by se měla použít ke čtení událostí z centra událostí. Zadání jedinečných názvů skupin příjemců pro více vstupů umožní každému z těchto vstupů přijímat stejné události z centra událostí. Pokud není zadaný, vstup použije výchozí skupinu příjemců centra událostí.
properties.eventHubName	string		Název centra událostí. Vyžaduje se u požadavků PUT (CreateOrReplace).
serviceBusNamespace	string		Obor názvů přidružený k požadovanému centru událostí, frontě služby Service Bus, tématu služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Klíč zásad sdíleného přístupu pro zadané zásady sdíleného přístupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
sharedAccessPolicyName	string		Název zásad sdíleného přístupu pro centrum událostí, frontu služby Service Bus, téma služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Označuje typ vstupního zdroje dat obsahujícího streamová data. Vyžaduje se u požadavků PUT (CreateOrReplace).

EventHubV2StreamInputDataSource

Popisuje vstupní zdroj dat centra událostí, který obsahuje streamová data.

Name	Typ	Default value	Description
authenticationMode	AuthenticationMode	ConnectionString	Režim ověřování.
properties.consumerGroupName	string		Název skupiny příjemců centra událostí, která by se měla použít ke čtení událostí z centra událostí. Zadání jedinečných názvů skupin příjemců pro více vstupů umožní každému z těchto vstupů přijímat stejné události z centra událostí. Pokud není zadaný, vstup použije výchozí skupinu příjemců centra událostí.
properties.eventHubName	string		Název centra událostí. Vyžaduje se u požadavků PUT (CreateOrReplace).
serviceBusNamespace	string		Obor názvů přidružený k požadovanému centru událostí, frontě služby Service Bus, tématu služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Klíč zásad sdíleného přístupu pro zadané zásady sdíleného přístupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
sharedAccessPolicyName	string		Název zásad sdíleného přístupu pro centrum událostí, frontu služby Service Bus, téma služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Označuje typ vstupního zdroje dat obsahujícího streamová data. Vyžaduje se u požadavků PUT (CreateOrReplace).

EventSerializationType

Označuje typ serializace, který používá vstup nebo výstup. Vyžaduje se u požadavků PUT (CreateOrReplace).

Name	Typ	Description
Avro	string
Csv	string
Json	string
Parquet	string

FileReferenceInputDataSource

Popisuje vstupní zdroj dat souboru, který obsahuje referenční data.

Name	Typ	Description
properties.path	string	Cesta k souboru.
type	string: File	Určuje typ vstupního zdroje dat obsahujícího referenční data. Vyžaduje se u požadavků PUT (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Popisuje vstupní zdroj dat objektu blob, který obsahuje streamová data.

Name	Typ	Description
properties.topic	string	Název tématu služby Service Bus.
type	string: GatewayMessageBus	Označuje typ vstupního zdroje dat, který obsahuje streamová data. Vyžaduje se u požadavků PUT (CreateOrReplace).

Input

Vstupní objekt obsahující všechny informace spojené s pojmenovaným vstupem. Všechny vstupy jsou obsažené v úloze streamování.

Name	Typ	Description
id	string	ID prostředku
name	string	Název prostředku
properties	InputProperties: ReferenceInputProperties StreamInputProperties	Vlastnosti, které jsou přidruženy ke vstupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string	Typ prostředku

InputListResult

Objekt obsahující seznam vstupů v rámci úlohy streamování.

Name	Typ	Description
nextLink	string	Odkaz (url) na další stránku výsledků.
value	Input[]	Seznam vstupů v rámci úlohy streamování. Naplněno operací "List".

IoTHubStreamInputDataSource

Popisuje IoT Hub vstupní zdroj dat, který obsahuje streamová data.

Name	Typ	Description
properties.consumerGroupName	string	Název skupiny uživatelů IoT Hub, který se má použít ke čtení událostí z IoT Hub. Pokud není zadaný, vstup použije výchozí skupinu příjemců iot Hubu.
properties.endpoint	string	IoT Hub koncový bod, ke kterému se chcete připojit (tj. messages/events, messages/operationsMonitoringEvents atd.).
properties.iotHubNamespace	string	Název nebo identifikátor URI IoT Hub. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string	Klíč zásad sdíleného přístupu pro zadané zásady sdíleného přístupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string	Název zásady sdíleného přístupu pro IoT Hub. Tato zásada musí obsahovat alespoň oprávnění Připojení ke službě. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Označuje typ vstupního zdroje dat, který obsahuje streamová data. Vyžaduje se u požadavků PUT (CreateOrReplace).

JsonOutputSerializationFormat

Určuje formát JSON, ve kterém se bude výstup zapisovat. Aktuálně podporované hodnoty jsou lineSeparated, což znamená, že výstup bude formátován tak, že každý objekt JSON bude oddělený novým řádkem a pole, které označuje, že výstup bude formátován jako pole objektů JSON.

Name	Typ	Description
Array	string
LineSeparated	string

JsonSerialization

Popisuje, jak se serializují data ze vstupu nebo jak se data serializují při zápisu do výstupu ve formátu JSON.

Name	Typ	Description
properties.encoding	Encoding	Určuje kódování příchozích dat v případě vstupu a kódování odchozích dat v případě výstupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Tato vlastnost se vztahuje pouze na serializaci výstupů JSON. Nevztahuje se na vstupy. Tato vlastnost určuje formát JSON, ve kterém se bude výstup zapisovat. Aktuálně podporované hodnoty jsou lineSeparated, což znamená, že výstup bude formátován tak, že každý objekt JSON bude oddělený novým řádkem a pole, které označuje, že výstup bude formátován jako pole objektů JSON. Výchozí hodnota je lineSeparated, pokud je vlevo null.
type	string: Json	Označuje typ serializace, který používá vstup nebo výstup. Vyžaduje se u požadavků PUT (CreateOrReplace).

ParquetSerialization

Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu Parquet.

Name	Typ	Description
type	string: Parquet	Označuje typ serializace, který používá vstup nebo výstup. Vyžaduje se u požadavků PUT (CreateOrReplace).

ReferenceInputProperties

Vlastnosti, které jsou přidruženy ke vstupu obsahujícího referenční data.

Name	Typ	Description
compression	Compression	Popisuje, jak se komprimují vstupní data.
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Popisuje vstupní zdroj dat, který obsahuje referenční data. Vyžaduje se u požadavků PUT (CreateOrReplace).
diagnostics	Diagnostics	Popisuje podmínky vztahující se na vstup, výstup nebo celkovou úlohu, které vyžadují pozornost zákazníka.
etag	string	Aktuální značka entity pro vstup. Jedná se o neprůsvný řetězec. Můžete ho použít ke zjištění, jestli se prostředek mezi požadavky změnil. Můžete ho také použít v hlavičce If-Match nebo If-None-Match pro operace zápisu pro zajištění optimistické souběžnosti.
partitionKey	string	partitionKey Popisuje klíč ve vstupních datech, který se používá k dělení vstupních dat.
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Reference	Určuje, jestli je vstup zdrojem referenčních dat nebo datových proudů. Vyžaduje se u požadavků PUT (CreateOrReplace).

RefreshType

Označuje typ možnosti aktualizace dat.

Name	Typ	Description
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

StorageAccount

Vlastnosti přidružené k účtu služby Azure Storage

Name	Typ	Description
accountKey	string	Klíč účtu pro účet služby Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).
accountName	string	Název účtu služby Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).

StreamInputProperties

Vlastnosti, které jsou přidruženy ke vstupu obsahujícímu data datového proudu.

Name	Typ	Description
compression	Compression	Popisuje, jak se komprimují vstupní data.
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Popisuje vstupní zdroj dat, který obsahuje streamová data. Vyžaduje se u požadavků PUT (CreateOrReplace).
diagnostics	Diagnostics	Popisuje podmínky vztahující se na vstup, výstup nebo celkovou úlohu, které vyžadují pozornost zákazníka.
etag	string	Aktuální značka entity pro vstup. Jedná se o neprůsvný řetězec. Můžete ho použít ke zjištění, jestli se prostředek mezi požadavky změnil. Můžete ho také použít v hlavičce If-Match nebo If-None-Match pro operace zápisu pro zajištění optimistické souběžnosti.
partitionKey	string	partitionKey Popisuje klíč ve vstupních datech, který se používá k dělení vstupních dat.
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
type	string: Stream	Určuje, jestli je vstup zdrojem referenčních dat nebo datových proudů. Vyžaduje se u požadavků PUT (CreateOrReplace).