Inputs - List By Streaming Job

リファレンス

サービス:: Stream Analytics

API バージョン:: 2020-03-01

指定したストリーミングジョブのすべての入力をListsします。

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

省略可能なパラメーターを含む:

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

URI パラメーター

名前	/	必須	型	説明
jobName	path	True	string	ストリーミングジョブの名前。
resourceGroupName	path	True	string	リソースグループの名前。名前の大文字と小文字は区別されます。正規表現パターン: `^[-\w\._]+$`
subscriptionId	path	True	string	ターゲットサブスクリプションの ID。
api-version	query	True	string	この操作に使用する API バージョン。
$select	query		string	$select OData クエリパラメーター。これは、応答に含める構造プロパティのコンマ区切りの一覧、またはすべてのプロパティを含める "" です。既定では、診断を除くすべてのプロパティが返されます。現在、有効な値として受け入れるのは '' のみです。

応答

名前	型	説明
200 OK	InputListResult	指定されたストリーミングジョブの下に入力が正常に一覧表示されました。
Other Status Codes	Error	エラー。

セキュリティ

azure_auth

Azure Active Directory OAuth2 フロー

型: oauth2
フロー: implicit
Authorization URL (承認 URL): https://login.microsoftonline.com/common/oauth2/authorize

スコープ

名前	説明
user_impersonation	ユーザーアカウントの借用

例

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

要求のサンプル

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

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

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

応答のサンプル

状態コード:: 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

要求のサンプル

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

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

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

応答のサンプル

状態コード:: 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"
      }
    }
  ]
}

定義

名前	説明
AuthenticationMode	認証モード。有効なモードは、 `ConnectionString`、 `Msi` および 'UserToken' です。
AvroSerialization	入力からのデータをシリアル化する方法、または Avro 形式で出力に書き込むときにデータをシリアル化する方法について説明します。
AzureSqlReferenceInputDataSource	Azure SQL データベース参照入力データソースについて説明します。
BlobReferenceInputDataSource	参照データを含む BLOB 入力データソースについて説明します。
BlobStreamInputDataSource	ストリームデータを含む BLOB 入力データソースについて説明します。
Compression	入力データの圧縮方法について説明します
CompressionType	入力で使用される圧縮の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
CsvSerialization	入力からのデータをシリアル化する方法、または CSV 形式で出力に書き込むときにデータをシリアル化する方法について説明します。
DiagnosticCondition	顧客の注意を必要とするリソースまたはジョブ全体に適用される条件。
Diagnostics	入力、出力、またはジョブ全体に適用できる、顧客の注意を必要とする条件について説明します。
Encoding	入力の場合の受信データのエンコードと、出力の場合の送信データのエンコードを指定します。
Error	一般的なエラー表現。
EventHubStreamInputDataSource	ストリームデータを含む Event Hub 入力データソースについて説明します。
EventHubV2StreamInputDataSource	ストリームデータを含む Event Hub 入力データソースについて説明します。
EventSerializationType	入力または出力で使用されるシリアル化の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
FileReferenceInputDataSource	参照データを含むファイル入力データソースについて説明します。
GatewayMessageBusStreamInputDataSource	ストリームデータを含む BLOB 入力データソースについて説明します。
Input	名前付き入力に関連付けられているすべての情報を含む入力オブジェクト。すべての入力はストリーミングジョブの下に含まれます。
InputListResult	ストリーミングジョブの下の入力の一覧を含むオブジェクト。
IoTHubStreamInputDataSource	ストリームデータを含むIoT Hub入力データソースについて説明します。
JsonOutputSerializationFormat	出力が書き込まれる JSON の形式を指定します。現在サポートされている値は、出力が新しい行で区切られた各 JSON オブジェクトを使用して書式設定されることを示す 'lineSeparated' と、出力が JSON オブジェクトの配列として書式設定されることを示す 'array' です。
JsonSerialization	入力からのデータをシリアル化する方法、または JSON 形式で出力に書き込むときにデータをシリアル化する方法について説明します。
ParquetSerialization	入力からのデータをシリアル化する方法、または Parquet 形式で出力に書き込むときにデータをシリアル化する方法について説明します。
ReferenceInputProperties	参照データを含む入力に関連付けられているプロパティ。
RefreshType	データ更新オプションの種類を示します。
StorageAccount	Azure Storage アカウントに関連付けられているプロパティ
StreamInputProperties	ストリームデータを含む入力に関連付けられているプロパティ。

AuthenticationMode

認証モード。有効なモードは、 ConnectionString、 Msi および 'UserToken' です。

名前	型	説明
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

入力からのデータをシリアル化する方法、または Avro 形式で出力に書き込むときにデータをシリアル化する方法について説明します。

名前	型	説明
type	string: Avro	入力または出力で使用されるシリアル化の種類を示します。 PUT (CreateOrReplace) 要求で必要です。

AzureSqlReferenceInputDataSource

Azure SQL データベース参照入力データソースについて説明します。

名前	型	説明
properties.database	string	この要素は [データソース] 要素に関連付けられています。これは出力が書き込まれるデータベースの名前です。
properties.deltaSnapshotQuery	string	この要素は [データソース] 要素に関連付けられています。このクエリは、SQL データベースから増分変更をフェッチするために使用されます。このオプションを使用するには、Azure SQL Database でテンポラルテーブルを使用することをお勧めします。
properties.fullSnapshotQuery	string	この要素は [データソース] 要素に関連付けられています。このクエリは、SQL データベースからデータをフェッチするために使用されます。
properties.password	string	この要素は [データソース] 要素に関連付けられています。これは SQL データベースインスタンスに接続するために使用されるパスワードです。
properties.refreshRate	string	この要素は [データソース] 要素に関連付けられています。これは、データベースからデータをフェッチする頻度を示します。 DateTime 形式です。
properties.refreshType	RefreshType	データ更新オプションの種類を示します。
properties.server	string	この要素は [データソース] 要素に関連付けられています。これは書き込み先のデータベース含むサーバーの名前です。
properties.table	string	この要素は [データソース] 要素に関連付けられています。 Azure SQL データベース内のテーブルの名前。
properties.user	string	この要素は [データソース] 要素に関連付けられています。これは SQL データベースインスタンスに接続するために使用されるユーザー名です。
type	string: Microsoft.Sql/Server/Database	参照データを含む入力データソースの種類を示します。 PUT (CreateOrReplace) 要求で必要です。

BlobReferenceInputDataSource

参照データを含む BLOB 入力データソースについて説明します。

名前	型	規定値	説明
properties.authenticationMode	AuthenticationMode	ConnectionString	認証モード。
properties.container	string		関連付けられたストレージアカウント内のコンテナーの名前。このコンテナーには、読み取りまたは書き込み対象の BLOB が含まれています。 PUT (CreateOrReplace) 要求で必要です。
properties.dateFormat	string		日付の形式。 {date} が pathPattern に表示される場合は、このプロパティの値が代わりに日付形式として使用されます。
properties.pathPattern	string		BLOB パスパターン。正規表現ではありません。これは、BLOB 名を照合して、ジョブへの入力または出力として含めるかどうかを判断するパターンを表します。詳細な説明と例については、または https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output を参照https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-inputしてください。
properties.storageAccounts	StorageAccount[]		1 つ以上の Azure Storage アカウントの一覧。 PUT (CreateOrReplace) 要求で必要です。
properties.timeFormat	string		時刻の形式。 {time} が pathPattern に表示される場合は、このプロパティの値が代わりに時刻形式として使用されます。
type	string: Microsoft.Storage/Blob		参照データを含む入力データソースの種類を示します。 PUT (CreateOrReplace) 要求で必要です。

BlobStreamInputDataSource

ストリームデータを含む BLOB 入力データソースについて説明します。

名前	型	規定値	説明
properties.authenticationMode	AuthenticationMode	ConnectionString	認証モード。
properties.container	string		関連付けられたストレージアカウント内のコンテナーの名前。このコンテナーには、読み取りまたは書き込み対象の BLOB が含まれています。 PUT (CreateOrReplace) 要求で必要です。
properties.dateFormat	string		日付の形式。 {date} が pathPattern に表示される場合は、このプロパティの値が代わりに日付形式として使用されます。
properties.pathPattern	string		BLOB パスパターン。正規表現ではありません。これは、BLOB 名を照合して、ジョブへの入力または出力として含めるかどうかを判断するパターンを表します。詳細な説明と例については、または https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output を参照https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-inputしてください。
properties.sourcePartitionCount	integer		BLOB 入力データソースのパーティション数。範囲 1 ~ 1024。
properties.storageAccounts	StorageAccount[]		1 つ以上の Azure Storage アカウントの一覧。 PUT (CreateOrReplace) 要求で必要です。
properties.timeFormat	string		時刻の形式。 {time} が pathPattern に表示される場合は、このプロパティの値が代わりに時刻形式として使用されます。
type	string: Microsoft.Storage/Blob		ストリームデータを含む入力データソースの種類を示します。 PUT (CreateOrReplace) 要求で必要です。

Compression

入力データの圧縮方法について説明します

名前	型	規定値	説明
type	CompressionType	None	入力で使用される圧縮の種類を示します。 PUT (CreateOrReplace) 要求で必要です。

CompressionType

入力で使用される圧縮の種類を示します。 PUT (CreateOrReplace) 要求で必要です。

名前	型	説明
Deflate	string
GZip	string
None	string

CsvSerialization

入力からのデータをシリアル化する方法、または CSV 形式で出力に書き込むときにデータをシリアル化する方法について説明します。

名前	型	説明
properties.encoding	Encoding	入力の場合の受信データのエンコードと、出力の場合の送信データのエンコードを指定します。 PUT (CreateOrReplace) 要求で必要です。
properties.fieldDelimiter	string	コンマ区切り値 (CSV) レコードを区切るために使用する区切り記号を指定します。サポートされている値の一覧については、または https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output を参照してくださいhttps://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input。 PUT (CreateOrReplace) 要求で必要です。
type	string: Csv	入力または出力で使用されるシリアル化の種類を示します。 PUT (CreateOrReplace) 要求で必要です。

DiagnosticCondition

顧客の注意を必要とするリソースまたはジョブ全体に適用される条件。

名前	型	説明
code	string	不透明な診断コード。
message	string	条件を詳しく説明する人間が判読できるメッセージ。クライアント要求の Accept-Language にローカライズされます。
since	string	条件が開始されたときの UTC タイムスタンプ。この時点で、お客様は ops ログで対応するイベントを見つけることができます。

Diagnostics

入力、出力、またはジョブ全体に適用できる、顧客の注意を必要とする条件について説明します。

名前	型	説明
conditions	DiagnosticCondition[]	顧客の注意を必要とする、リソースまたはジョブ全体に適用できる 0 個以上の条件のコレクション。

Encoding

入力の場合の受信データのエンコードと、出力の場合の送信データのエンコードを指定します。

名前	型	説明
UTF8	string

Error

一般的なエラー表現。

名前	型	説明
error	Error	エラー定義のプロパティ。

EventHubStreamInputDataSource

ストリームデータを含む Event Hub 入力データソースについて説明します。

名前	型	規定値	説明
authenticationMode	AuthenticationMode	ConnectionString	認証モード。
properties.consumerGroupName	string		イベントハブからイベントを読み取るために使用する必要があるイベントハブコンシューマーグループの名前。複数の入力に対して個別のコンシューマーグループ名を指定すると、これらの各入力でイベントハブから同じイベントを受信できます。指定しない場合、入力では Event Hub の既定のコンシューマーグループが使用されます。
properties.eventHubName	string		イベントハブの名前。 PUT (CreateOrReplace) 要求で必要です。
serviceBusNamespace	string		目的のイベントハブ、Service Bus キュー、Service Bus トピックなどに関連付けられている名前空間。PUT (CreateOrReplace) 要求で必要です。
sharedAccessPolicyKey	string		指定した共有アクセスポリシーの共有アクセスポリシーキー。 PUT (CreateOrReplace) 要求で必要です。
sharedAccessPolicyName	string		イベントハブ、Service Bus キュー、Service Bus トピックなどの共有アクセスポリシー名。PUT (CreateOrReplace) 要求で必要です。
type	string: Microsoft.ServiceBus/EventHub		ストリームデータを含む入力データソースの種類を示します。 PUT (CreateOrReplace) 要求で必要です。

EventHubV2StreamInputDataSource

ストリームデータを含む Event Hub 入力データソースについて説明します。

名前	型	規定値	説明
authenticationMode	AuthenticationMode	ConnectionString	認証モード。
properties.consumerGroupName	string		イベントハブからイベントを読み取るために使用する必要があるイベントハブコンシューマーグループの名前。複数の入力に対して個別のコンシューマーグループ名を指定すると、これらの各入力でイベントハブから同じイベントを受信できます。指定しない場合、入力では Event Hub の既定のコンシューマーグループが使用されます。
properties.eventHubName	string		イベントハブの名前。 PUT (CreateOrReplace) 要求で必要です。
serviceBusNamespace	string		目的のイベントハブ、Service Bus キュー、Service Bus トピックなどに関連付けられている名前空間。PUT (CreateOrReplace) 要求で必要です。
sharedAccessPolicyKey	string		指定した共有アクセスポリシーの共有アクセスポリシーキー。 PUT (CreateOrReplace) 要求で必要です。
sharedAccessPolicyName	string		イベントハブ、Service Bus キュー、Service Bus トピックなどの共有アクセスポリシー名。PUT (CreateOrReplace) 要求で必要です。
type	string: Microsoft.EventHub/EventHub		ストリームデータを含む入力データソースの種類を示します。 PUT (CreateOrReplace) 要求で必要です。

EventSerializationType

入力または出力で使用されるシリアル化の種類を示します。 PUT (CreateOrReplace) 要求で必要です。

名前	型	説明
Avro	string
Csv	string
Json	string
Parquet	string

FileReferenceInputDataSource

参照データを含むファイル入力データソースについて説明します。

名前	型	説明
properties.path	string	ファイルのパス。
type	string: File	参照データを含む入力データソースの種類を示します。 PUT (CreateOrReplace) 要求で必要です。

GatewayMessageBusStreamInputDataSource

ストリームデータを含む BLOB 入力データソースについて説明します。

名前	型	説明
properties.topic	string	Service Bus トピックの名前。
type	string: GatewayMessageBus	ストリームデータを含む入力データソースの種類を示します。 PUT (CreateOrReplace) 要求で必要です。

Input

名前付き入力に関連付けられているすべての情報を含む入力オブジェクト。すべての入力はストリーミングジョブの下に含まれます。

名前	型	説明
id	string	リソース ID
name	string	リソース名
properties	InputProperties: ReferenceInputProperties StreamInputProperties	入力に関連付けられているプロパティ。 PUT (CreateOrReplace) 要求で必要です。
type	string	リソースの種類

InputListResult

ストリーミングジョブの下の入力の一覧を含むオブジェクト。

名前	型	説明
nextLink	string	結果の次のページへのリンク (URL)。
value	Input[]	ストリーミングジョブの下の入力の一覧。 'List' 操作によって設定されます。

IoTHubStreamInputDataSource

ストリームデータを含むIoT Hub入力データソースについて説明します。

名前	型	説明
properties.consumerGroupName	string	IoT Hubからイベントを読み取るために使用するIoT Hub コンシューマーグループの名前。指定しない場合、入力では IoT Hub の既定のコンシューマーグループが使用されます。
properties.endpoint	string	接続するIoT Hubエンドポイント (つまり、messages/events、messages/operationsMonitoringEvents など)。
properties.iotHubNamespace	string	IoT Hubの名前または URI。 PUT (CreateOrReplace) 要求で必要です。
properties.sharedAccessPolicyKey	string	指定した共有アクセスポリシーの共有アクセスポリシーキー。 PUT (CreateOrReplace) 要求で必要です。
properties.sharedAccessPolicyName	string	IoT Hubの共有アクセスポリシー名。このポリシーには、少なくともサービス接続アクセス許可が含まれている必要があります。 PUT (CreateOrReplace) 要求で必要です。
type	string: Microsoft.Devices/IotHubs	ストリームデータを含む入力データソースの種類を示します。 PUT (CreateOrReplace) 要求で必要です。

JsonOutputSerializationFormat

出力が書き込まれる JSON の形式を指定します。現在サポートされている値は、出力が新しい行で区切られた各 JSON オブジェクトを使用して書式設定されることを示す 'lineSeparated' と、出力が JSON オブジェクトの配列として書式設定されることを示す 'array' です。

名前	型	説明
Array	string
LineSeparated	string

JsonSerialization

入力からのデータをシリアル化する方法、または JSON 形式で出力に書き込むときにデータをシリアル化する方法について説明します。

名前	型	説明
properties.encoding	Encoding	入力の場合の受信データのエンコードと、出力の場合の送信データのエンコードを指定します。 PUT (CreateOrReplace) 要求で必要です。
properties.format	JsonOutputSerializationFormat	このプロパティは、出力の JSON シリアル化にのみ適用されます。入力には適用されません。このプロパティは、出力が書き込まれる JSON の形式を指定します。現在サポートされている値は、出力が新しい行で区切られた各 JSON オブジェクトを使用して書式設定されることを示す 'lineSeparated' と、出力が JSON オブジェクトの配列として書式設定されることを示す 'array' です。左 null の場合、既定値は 'lineSeparated' です。
type	string: Json	入力または出力で使用されるシリアル化の種類を示します。 PUT (CreateOrReplace) 要求で必要です。

ParquetSerialization

入力からのデータをシリアル化する方法、または Parquet 形式で出力に書き込むときにデータをシリアル化する方法について説明します。

名前	型	説明
type	string: Parquet	入力または出力で使用されるシリアル化の種類を示します。 PUT (CreateOrReplace) 要求で必要です。

ReferenceInputProperties

参照データを含む入力に関連付けられているプロパティ。

名前	型	説明
compression	Compression	入力データの圧縮方法について説明します
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	参照データを含む入力データソースについて説明します。 PUT (CreateOrReplace) 要求で必要です。
diagnostics	Diagnostics	入力、出力、またはジョブ全体に適用できる、顧客の注意を必要とする条件について説明します。
etag	string	入力の現在のエンティティタグ。これは不透明な文字列です。これを使用して、要求間でリソースが変更されたかどうかを検出できます。また、オプティミスティックコンカレンシーの書き込み操作に対して、If-Match ヘッダーまたは If-None-Match ヘッダーで使用することもできます。
partitionKey	string	partitionKey 入力データのパーティション分割に使用される入力データ内のキーについて説明します
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	入力からのデータをシリアル化する方法、または出力に書き込むときにデータをシリアル化する方法について説明します。 PUT (CreateOrReplace) 要求で必要です。
type	string: Reference	入力が参照データのソースであるか、ストリームデータであるかを示します。 PUT (CreateOrReplace) 要求で必要です。

RefreshType

データ更新オプションの種類を示します。

名前	型	説明
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

StorageAccount

Azure Storage アカウントに関連付けられているプロパティ

名前	型	説明
accountKey	string	Azure Storage アカウントのアカウントキー。 PUT (CreateOrReplace) 要求で必要です。
accountName	string	Azure ストレージアカウントの名前。 PUT (CreateOrReplace) 要求で必要です。

StreamInputProperties

ストリームデータを含む入力に関連付けられているプロパティ。

名前	型	説明
compression	Compression	入力データの圧縮方法について説明します
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	ストリームデータを含む入力データソースについて説明します。 PUT (CreateOrReplace) 要求で必要です。
diagnostics	Diagnostics	入力、出力、またはジョブ全体に適用できる、顧客の注意を必要とする条件について説明します。
etag	string	入力の現在のエンティティタグ。これは不透明な文字列です。これを使用して、要求間でリソースが変更されたかどうかを検出できます。また、オプティミスティックコンカレンシーの書き込み操作に対して、If-Match ヘッダーまたは If-None-Match ヘッダーで使用することもできます。
partitionKey	string	partitionKey 入力データのパーティション分割に使用される入力データ内のキーについて説明します
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	入力からのデータをシリアル化する方法、または出力に書き込むときにデータをシリアル化する方法について説明します。 PUT (CreateOrReplace) 要求で必要です。
type	string: Stream	入力が参照データのソースであるか、ストリームデータであるかを示します。 PUT (CreateOrReplace) 要求で必要です。

次の方法で共有

Inputs - List By Streaming Job

URI パラメーター

応答

セキュリティ

azure_auth

スコープ

例

List all inputs in a streaming job

要求のサンプル

応答のサンプル

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

要求のサンプル

応答のサンプル

定義

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

その他のリソース