Inputs - Update

Служба:

Stream Analytics

Версия API:

2020-03-01

Обновляет существующие входные данные в существующем задании потоковой передачи. Это можно использовать для частичного обновления (т. е. обновления одного или двух свойств) входных данных, не затрагивая остальное задание или определение входных данных.

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

Параметры URI

Имя	В	Обязательно	Тип	Описание
inputName	path	True	string	Имя входных данных.
jobName	path	True	string	Имя задания потоковой передачи.
resourceGroupName	path	True	string minLength: 1 maxLength: 90 pattern: ^[-\w\._\(\)]+$	Имя группы ресурсов. Имя не учитывает регистр.
subscriptionId	path	True	string minLength: 1	Идентификатор целевой подписки.
api-version	query	True	string minLength: 1	Версия API, используемая для этой операции.

Заголовок запроса

Имя	Обязательно	Тип	Описание
If-Match		string	ETag входных данных. Опустите это значение, чтобы всегда перезаписать текущие входные данные. Укажите последнее значение ETag, чтобы предотвратить случайное перезапись одновременных изменений.

Текст запроса

Имя	Тип	Описание
name	string	Имя ресурса
properties	InputProperties: StreamInputProperties ReferenceInputProperties	Свойства, связанные с входными данными. Требуется для запросов PUT (CreateOrReplace).

Ответы

Имя	Тип	Описание
200 OK	Input	Входные данные успешно обновлены. Заголовки ETag: string
Other Status Codes	Error	Ошибка.

Безопасность

azure_auth

Поток OAuth2 Azure Active Directory

Тип: oauth2
Flow: implicit
URL-адрес авторизации: https://login.microsoftonline.com/common/oauth2/authorize

Области

Имя	Описание
user_impersonation	олицетворения учетной записи пользователя

Примеры

Update a reference blob input

Update a stream blob input

Update a stream Event Hub input

Update a stream IoT Hub input

Update a reference blob input

Образец запроса

HTTP

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

{
  "properties": {
    "type": "Reference",
    "datasource": {
      "type": "Microsoft.Storage/Blob",
      "properties": {
        "container": "differentContainer"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": "|",
        "encoding": "UTF8"
      }
    }
  }
}

Java

import com.azure.resourcemanager.streamanalytics.models.BlobReferenceInputDataSource;
import com.azure.resourcemanager.streamanalytics.models.CsvSerialization;
import com.azure.resourcemanager.streamanalytics.models.Encoding;
import com.azure.resourcemanager.streamanalytics.models.Input;
import com.azure.resourcemanager.streamanalytics.models.ReferenceInputProperties;

/**
 * Samples for Inputs Update.
 */
public final class Main {
    /*
     * x-ms-original-file:
     * specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/
     * Input_Update_Reference_Blob.json
     */
    /**
     * Sample code: Update a reference blob input.
     * 
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void
        updateAReferenceBlobInput(com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        Input resource = manager.inputs()
            .getWithResponse("sjrg8440", "sj9597", "input7225", com.azure.core.util.Context.NONE).getValue();
        resource.update()
            .withProperties(new ReferenceInputProperties()
                .withSerialization(new CsvSerialization().withFieldDelimiter("|").withEncoding(Encoding.UTF8))
                .withDatasource(new BlobReferenceInputDataSource().withContainer("differentContainer")))
            .apply();
    }
}

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_Update_Reference_Blob.json
func ExampleInputsClient_Update_updateAReferenceBlobInput() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armstreamanalytics.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewInputsClient().Update(ctx, "sjrg8440", "sj9597", "input7225", armstreamanalytics.Input{
		Properties: &armstreamanalytics.ReferenceInputProperties{
			Type: to.Ptr("Reference"),
			Serialization: &armstreamanalytics.CSVSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
				Properties: &armstreamanalytics.CSVSerializationProperties{
					Encoding:       to.Ptr(armstreamanalytics.EncodingUTF8),
					FieldDelimiter: to.Ptr("|"),
				},
			},
			Datasource: &armstreamanalytics.BlobReferenceInputDataSource{
				Type: to.Ptr("Microsoft.Storage/Blob"),
				Properties: &armstreamanalytics.BlobReferenceInputDataSourceProperties{
					Container: to.Ptr("differentContainer"),
				},
			},
		},
	}, &armstreamanalytics.InputsClientUpdateOptions{IfMatch: nil})
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.Input = armstreamanalytics.Input{
	// 	Name: to.Ptr("input7225"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7225"),
	// 	Properties: &armstreamanalytics.ReferenceInputProperties{
	// 		Type: to.Ptr("Reference"),
	// 		Serialization: &armstreamanalytics.CSVSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
	// 			Properties: &armstreamanalytics.CSVSerializationProperties{
	// 				Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
	// 				FieldDelimiter: to.Ptr("|"),
	// 			},
	// 		},
	// 		Datasource: &armstreamanalytics.BlobReferenceInputDataSource{
	// 			Type: to.Ptr("Microsoft.Storage/Blob"),
	// 			Properties: &armstreamanalytics.BlobReferenceInputDataSourceProperties{
	// 				Container: to.Ptr("differentContainer"),
	// 				DateFormat: to.Ptr("yyyy/MM/dd"),
	// 				PathPattern: to.Ptr("{date}/{time}"),
	// 				StorageAccounts: []*armstreamanalytics.StorageAccount{
	// 					{
	// 						AccountName: to.Ptr("someAccountName"),
	// 				}},
	// 				TimeFormat: to.Ptr("HH"),
	// 			},
	// 		},
	// 	},
	// }
}

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

JavaScript

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

/**
 * This sample demonstrates how to Updates an existing input under an existing streaming job. This can be used to partially update (ie. update one or two properties) an input without affecting the rest the job or input definition.
 *
 * @summary Updates an existing input under an existing streaming job. This can be used to partially update (ie. update one or two properties) an input without affecting the rest the job or input definition.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Update_Reference_Blob.json
 */
async function updateAReferenceBlobInput() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg8440";
  const jobName = "sj9597";
  const inputName = "input7225";
  const input = {
    properties: {
      type: "Reference",
      datasource: {
        type: "Microsoft.Storage/Blob",
        container: "differentContainer",
      },
      serialization: { type: "Csv", encoding: "UTF8", fieldDelimiter: "|" },
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.update(resourceGroupName, jobName, inputName, input);
  console.log(result);
}

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

ETag: a4ceb697-1c8f-40c8-b951-fb5ee4757437

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

Update a stream blob input

Образец запроса

HTTP

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

{
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.Storage/Blob",
      "properties": {
        "sourcePartitionCount": 32
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": "|",
        "encoding": "UTF8"
      }
    }
  }
}

Java

import com.azure.resourcemanager.streamanalytics.models.BlobStreamInputDataSource;
import com.azure.resourcemanager.streamanalytics.models.CsvSerialization;
import com.azure.resourcemanager.streamanalytics.models.Encoding;
import com.azure.resourcemanager.streamanalytics.models.Input;
import com.azure.resourcemanager.streamanalytics.models.StreamInputProperties;

/**
 * Samples for Inputs Update.
 */
public final class Main {
    /*
     * x-ms-original-file:
     * specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/
     * Input_Update_Stream_Blob.json
     */
    /**
     * Sample code: Update a stream blob input.
     * 
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void
        updateAStreamBlobInput(com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        Input resource = manager.inputs()
            .getWithResponse("sjrg8161", "sj6695", "input8899", com.azure.core.util.Context.NONE).getValue();
        resource.update()
            .withProperties(new StreamInputProperties()
                .withSerialization(new CsvSerialization().withFieldDelimiter("|").withEncoding(Encoding.UTF8))
                .withDatasource(new BlobStreamInputDataSource().withSourcePartitionCount(32)))
            .apply();
    }
}

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_Update_Stream_Blob.json
func ExampleInputsClient_Update_updateAStreamBlobInput() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armstreamanalytics.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewInputsClient().Update(ctx, "sjrg8161", "sj6695", "input8899", armstreamanalytics.Input{
		Properties: &armstreamanalytics.StreamInputProperties{
			Type: to.Ptr("Stream"),
			Serialization: &armstreamanalytics.CSVSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
				Properties: &armstreamanalytics.CSVSerializationProperties{
					Encoding:       to.Ptr(armstreamanalytics.EncodingUTF8),
					FieldDelimiter: to.Ptr("|"),
				},
			},
			Datasource: &armstreamanalytics.BlobStreamInputDataSource{
				Type: to.Ptr("Microsoft.Storage/Blob"),
				Properties: &armstreamanalytics.BlobStreamInputDataSourceProperties{
					SourcePartitionCount: to.Ptr[int32](32),
				},
			},
		},
	}, &armstreamanalytics.InputsClientUpdateOptions{IfMatch: nil})
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.Input = armstreamanalytics.Input{
	// 	Name: to.Ptr("input8899"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8161/providers/Microsoft.StreamAnalytics/streamingjobs/sj6695/inputs/input8899"),
	// 	Properties: &armstreamanalytics.StreamInputProperties{
	// 		Type: to.Ptr("Stream"),
	// 		Serialization: &armstreamanalytics.CSVSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
	// 			Properties: &armstreamanalytics.CSVSerializationProperties{
	// 				Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
	// 				FieldDelimiter: to.Ptr("|"),
	// 			},
	// 		},
	// 		Datasource: &armstreamanalytics.BlobStreamInputDataSource{
	// 			Type: to.Ptr("Microsoft.Storage/Blob"),
	// 			Properties: &armstreamanalytics.BlobStreamInputDataSourceProperties{
	// 				Container: to.Ptr("state"),
	// 				DateFormat: to.Ptr("yyyy/MM/dd"),
	// 				PathPattern: to.Ptr("{date}/{time}"),
	// 				StorageAccounts: []*armstreamanalytics.StorageAccount{
	// 					{
	// 						AccountName: to.Ptr("someAccountName"),
	// 				}},
	// 				TimeFormat: to.Ptr("HH"),
	// 				SourcePartitionCount: to.Ptr[int32](32),
	// 			},
	// 		},
	// 	},
	// }
}

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 Updates an existing input under an existing streaming job. This can be used to partially update (ie. update one or two properties) an input without affecting the rest the job or input definition.
 *
 * @summary Updates an existing input under an existing streaming job. This can be used to partially update (ie. update one or two properties) an input without affecting the rest the job or input definition.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Update_Stream_Blob.json
 */
async function updateAStreamBlobInput() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg8161";
  const jobName = "sj6695";
  const inputName = "input8899";
  const input = {
    properties: {
      type: "Stream",
      datasource: { type: "Microsoft.Storage/Blob", sourcePartitionCount: 32 },
      serialization: { type: "Csv", encoding: "UTF8", fieldDelimiter: "|" },
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.update(resourceGroupName, jobName, inputName, input);
  console.log(result);
}

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

ETag: 3b35d57c-02f4-4b41-8e1d-af02a86c2fa1

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

Update a stream Event Hub input

Образец запроса

HTTP

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

{
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.ServiceBus/EventHub",
      "properties": {
        "consumerGroupName": "differentConsumerGroupName"
      }
    },
    "serialization": {
      "type": "Avro"
    }
  }
}

Java

import com.azure.resourcemanager.streamanalytics.models.AvroSerialization;
import com.azure.resourcemanager.streamanalytics.models.EventHubStreamInputDataSource;
import com.azure.resourcemanager.streamanalytics.models.Input;
import com.azure.resourcemanager.streamanalytics.models.StreamInputProperties;

/**
 * Samples for Inputs Update.
 */
public final class Main {
    /*
     * x-ms-original-file:
     * specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/
     * Input_Update_Stream_EventHub.json
     */
    /**
     * Sample code: Update a stream Event Hub input.
     * 
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void
        updateAStreamEventHubInput(com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        Input resource = manager.inputs()
            .getWithResponse("sjrg3139", "sj197", "input7425", com.azure.core.util.Context.NONE).getValue();
        resource.update().withProperties(new StreamInputProperties().withSerialization(new AvroSerialization())
            .withDatasource(new EventHubStreamInputDataSource().withConsumerGroupName("differentConsumerGroupName")))
            .apply();
    }
}

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_Update_Stream_EventHub.json
func ExampleInputsClient_Update_updateAStreamEventHubInput() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armstreamanalytics.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewInputsClient().Update(ctx, "sjrg3139", "sj197", "input7425", armstreamanalytics.Input{
		Properties: &armstreamanalytics.StreamInputProperties{
			Type: to.Ptr("Stream"),
			Serialization: &armstreamanalytics.AvroSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeAvro),
			},
			Datasource: &armstreamanalytics.EventHubStreamInputDataSource{
				Type: to.Ptr("Microsoft.ServiceBus/EventHub"),
				Properties: &armstreamanalytics.EventHubStreamInputDataSourceProperties{
					ConsumerGroupName: to.Ptr("differentConsumerGroupName"),
				},
			},
		},
	}, &armstreamanalytics.InputsClientUpdateOptions{IfMatch: nil})
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.Input = armstreamanalytics.Input{
	// 	Name: to.Ptr("input7425"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3139/providers/Microsoft.StreamAnalytics/streamingjobs/sj197/inputs/input7425"),
	// 	Properties: &armstreamanalytics.StreamInputProperties{
	// 		Type: to.Ptr("Stream"),
	// 		Serialization: &armstreamanalytics.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"),
	// 			},
	// 		},
	// 	},
	// }
}

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 Updates an existing input under an existing streaming job. This can be used to partially update (ie. update one or two properties) an input without affecting the rest the job or input definition.
 *
 * @summary Updates an existing input under an existing streaming job. This can be used to partially update (ie. update one or two properties) an input without affecting the rest the job or input definition.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Update_Stream_EventHub.json
 */
async function updateAStreamEventHubInput() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg3139";
  const jobName = "sj197";
  const inputName = "input7425";
  const input = {
    properties: {
      type: "Stream",
      datasource: {
        type: "Microsoft.ServiceBus/EventHub",
        consumerGroupName: "differentConsumerGroupName",
      },
      serialization: { type: "Avro" },
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.update(resourceGroupName, jobName, inputName, input);
  console.log(result);
}

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

ETag: 7548f259-81b5-4ea7-b896-25c6717d98ba

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

Update a stream IoT Hub input

Образец запроса

HTTP

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

{
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.Devices/IotHubs",
      "properties": {
        "endpoint": "messages/operationsMonitoringEvents"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": "|",
        "encoding": "UTF8"
      }
    }
  }
}

Java

import com.azure.resourcemanager.streamanalytics.models.CsvSerialization;
import com.azure.resourcemanager.streamanalytics.models.Encoding;
import com.azure.resourcemanager.streamanalytics.models.Input;
import com.azure.resourcemanager.streamanalytics.models.IoTHubStreamInputDataSource;
import com.azure.resourcemanager.streamanalytics.models.StreamInputProperties;

/**
 * Samples for Inputs Update.
 */
public final class Main {
    /*
     * x-ms-original-file:
     * specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/
     * Input_Update_Stream_IoTHub.json
     */
    /**
     * Sample code: Update a stream IoT Hub input.
     * 
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void
        updateAStreamIoTHubInput(com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        Input resource = manager.inputs()
            .getWithResponse("sjrg3467", "sj9742", "input7970", com.azure.core.util.Context.NONE).getValue();
        resource.update()
            .withProperties(new StreamInputProperties()
                .withSerialization(new CsvSerialization().withFieldDelimiter("|").withEncoding(Encoding.UTF8))
                .withDatasource(new IoTHubStreamInputDataSource().withEndpoint("messages/operationsMonitoringEvents")))
            .apply();
    }
}

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_Update_Stream_IoTHub.json
func ExampleInputsClient_Update_updateAStreamIoTHubInput() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armstreamanalytics.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewInputsClient().Update(ctx, "sjrg3467", "sj9742", "input7970", armstreamanalytics.Input{
		Properties: &armstreamanalytics.StreamInputProperties{
			Type: to.Ptr("Stream"),
			Serialization: &armstreamanalytics.CSVSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
				Properties: &armstreamanalytics.CSVSerializationProperties{
					Encoding:       to.Ptr(armstreamanalytics.EncodingUTF8),
					FieldDelimiter: to.Ptr("|"),
				},
			},
			Datasource: &armstreamanalytics.IoTHubStreamInputDataSource{
				Type: to.Ptr("Microsoft.Devices/IotHubs"),
				Properties: &armstreamanalytics.IoTHubStreamInputDataSourceProperties{
					Endpoint: to.Ptr("messages/operationsMonitoringEvents"),
				},
			},
		},
	}, &armstreamanalytics.InputsClientUpdateOptions{IfMatch: nil})
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.Input = armstreamanalytics.Input{
	// 	Name: to.Ptr("input7970"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970"),
	// 	Properties: &armstreamanalytics.StreamInputProperties{
	// 		Type: to.Ptr("Stream"),
	// 		Serialization: &armstreamanalytics.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 Updates an existing input under an existing streaming job. This can be used to partially update (ie. update one or two properties) an input without affecting the rest the job or input definition.
 *
 * @summary Updates an existing input under an existing streaming job. This can be used to partially update (ie. update one or two properties) an input without affecting the rest the job or input definition.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Update_Stream_IoTHub.json
 */
async function updateAStreamIoTHubInput() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg3467";
  const jobName = "sj9742";
  const inputName = "input7970";
  const input = {
    properties: {
      type: "Stream",
      datasource: {
        type: "Microsoft.Devices/IotHubs",
        endpoint: "messages/operationsMonitoringEvents",
      },
      serialization: { type: "Csv", encoding: "UTF8", fieldDelimiter: "|" },
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.update(resourceGroupName, jobName, inputName, input);
  console.log(result);
}

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

ETag: e2d847e0-c95b-48ef-9e14-1afc1f2270cb

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

Определения

Имя	Описание
AuthenticationMode	Режим проверки подлинности. Допустимые режимы: ConnectionString, Msi и UserToken.
AvroSerialization	Описывает, как данные из входных данных сериализуются или как данные сериализуются при записи в выходные данные в формате Avro.
AzureSqlReferenceInputDataSource	Описывает источник входных данных базы данных SQL Azure.
BlobReferenceInputDataSource	Описывает источник входных данных большого двоичного объекта, содержащий эталонные данные.
BlobStreamInputDataSource	Описывает источник входных данных БОЛЬШОго двоичного объекта, содержащий потоковые данные.
Compression	Описание сжатия входных данных
CompressionType	Указывает тип сжатия, используемого входными данными. Требуется для запросов PUT (CreateOrReplace).
CsvSerialization	Описывает, как данные из входных данных сериализуются или как данные сериализуются при записи в выходные данные в формате CSV.
DiagnosticCondition	Условие, применимое к ресурсу или к заданию в целом, которое гарантирует внимание клиентов.
Diagnostics	Описывает условия, применимые к входным, выходным данным или общему заданию, которые гарантируют внимание клиентов.
Encoding	Указывает кодировку входящих данных в случае ввода и кодирования исходящих данных в случае выходных данных.
Error	Представление распространенных ошибок.
EventHubStreamInputDataSource	Описывает источник входных данных концентратора событий, содержащий потоковые данные.
EventHubV2StreamInputDataSource	Описывает источник входных данных концентратора событий, содержащий потоковые данные.
EventSerializationType	Указывает тип сериализации, используемой входными или выходными данными. Требуется для запросов PUT (CreateOrReplace).
FileReferenceInputDataSource	Описывает источник входных данных файла, содержащий эталонные данные.
GatewayMessageBusStreamInputDataSource	Описывает источник входных данных БОЛЬШОго двоичного объекта, содержащий потоковые данные.
Input	Входной объект, содержащий все сведения, связанные с именованными входными данными. Все входные данные содержатся в задании потоковой передачи.
IoTHubStreamInputDataSource	Описывает источник входных данных Центра Интернета вещей, содержащий потоковые данные.
JsonOutputSerializationFormat	Указывает формат JSON, в который будут записаны выходные данные. Поддерживаемые в настоящее время значения имеют значение lineSeparated, указывающее, что выходные данные будут отформатированы путем разделения каждого объекта JSON новой строкой и массива, указывающего, что выходные данные будут отформатированы в виде массива объектов JSON.
JsonSerialization	Описывает, как данные из входных данных сериализуются или как данные сериализуются при записи в выходные данные в формате JSON.
ParquetSerialization	Описывает, как данные из входных данных сериализуются или как данные сериализуются при записи в выходные данные в формате Parquet.
ReferenceInputProperties	Свойства, связанные с входными данными, содержащими справочные данные.
RefreshType	Указывает тип параметра обновления данных.
StorageAccount	Свойства, связанные с учетной записью хранения Azure
StreamInputProperties	Свойства, связанные с входными данными, содержащими потоковые данные.

AuthenticationMode

Перечисление

Режим проверки подлинности. Допустимые режимы: ConnectionString, Msi и UserToken.

Значение	Описание
ConnectionString
Msi
UserToken

AvroSerialization

Object

Описывает, как данные из входных данных сериализуются или как данные сериализуются при записи в выходные данные в формате Avro.

Имя	Тип	Описание
type	string: Avro	Указывает тип сериализации, используемой входными или выходными данными. Требуется для запросов PUT (CreateOrReplace).

AzureSqlReferenceInputDataSource

Object

Описывает источник входных данных базы данных SQL Azure.

Имя	Тип	Описание
properties.database	string	Этот элемент связан с элементом источника данных. Это имя базы данных, в которую будут записаны выходные данные.
properties.deltaSnapshotQuery	string	Этот элемент связан с элементом источника данных. Этот запрос используется для получения добавочных изменений из базы данных SQL. Чтобы использовать этот параметр, рекомендуется использовать темпоральные таблицы в Базе данных SQL Azure.
properties.fullSnapshotQuery	string	Этот элемент связан с элементом источника данных. Этот запрос используется для получения данных из базы данных SQL.
properties.password	string	Этот элемент связан с элементом источника данных. Это пароль, который будет использоваться для подключения к экземпляру базы данных SQL.
properties.refreshRate	string	Этот элемент связан с элементом источника данных. Это указывает, как часто данные будут извлекаться из базы данных. Он имеет формат DateTime.
properties.refreshType	RefreshType	Указывает тип параметра обновления данных.
properties.server	string	Этот элемент связан с элементом источника данных. Это имя сервера, содержащего базу данных, в которую будет записана запись.
properties.table	string	Этот элемент связан с элементом источника данных. Имя таблицы в базе данных SQL Azure.
properties.user	string	Этот элемент связан с элементом источника данных. Это имя пользователя, которое будет использоваться для подключения к экземпляру базы данных SQL.
type	string: Microsoft.Sql/Server/Database	Указывает тип входного источника данных, содержащего эталонные данные. Требуется для запросов PUT (CreateOrReplace).

BlobReferenceInputDataSource

Object

Описывает источник входных данных большого двоичного объекта, содержащий эталонные данные.

Имя	Тип	Default value	Описание
properties.authenticationMode	AuthenticationMode	ConnectionString	Режим проверки подлинности.
properties.container	string		Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит большие двоичные объекты, которые должны быть считываются или записываются в нее. Требуется для запросов PUT (CreateOrReplace).
properties.dateFormat	string		Формат даты. Когда {date} отображается в pathPattern, значение этого свойства используется в качестве формата даты.
properties.pathPattern	string		Шаблон пути большого двоичного объекта. Не регулярное выражение. Он представляет шаблон, с которыми будут соответствовать имена BLOB-объектов, чтобы определить, следует ли включать их в качестве входных или выходных данных в задание. Более подробное описание и пример см. в https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input или https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output.
properties.storageAccounts	StorageAccount[]		Список одной или нескольких учетных записей хранения Azure. Требуется для запросов PUT (CreateOrReplace).
properties.timeFormat	string		Формат времени. Когда {time} отображается в pathPattern, значение этого свойства используется в качестве формата времени.
type	string: Microsoft.Storage/Blob		Указывает тип входного источника данных, содержащего эталонные данные. Требуется для запросов PUT (CreateOrReplace).

BlobStreamInputDataSource

Object

Описывает источник входных данных БОЛЬШОго двоичного объекта, содержащий потоковые данные.

Имя	Тип	Default value	Описание
properties.authenticationMode	AuthenticationMode	ConnectionString	Режим проверки подлинности.
properties.container	string		Имя контейнера в связанной учетной записи хранения. Этот контейнер содержит большие двоичные объекты, которые должны быть считываются или записываются в нее. Требуется для запросов PUT (CreateOrReplace).
properties.dateFormat	string		Формат даты. Когда {date} отображается в pathPattern, значение этого свойства используется в качестве формата даты.
properties.pathPattern	string		Шаблон пути большого двоичного объекта. Не регулярное выражение. Он представляет шаблон, с которыми будут соответствовать имена BLOB-объектов, чтобы определить, следует ли включать их в качестве входных или выходных данных в задание. Более подробное описание и пример см. в https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input или https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output.
properties.sourcePartitionCount	integer (int32)		Число секций входного источника данных БОЛЬШОго двоичного объекта. Диапазон 1 – 1024.
properties.storageAccounts	StorageAccount[]		Список одной или нескольких учетных записей хранения Azure. Требуется для запросов PUT (CreateOrReplace).
properties.timeFormat	string		Формат времени. Когда {time} отображается в pathPattern, значение этого свойства используется в качестве формата времени.
type	string: Microsoft.Storage/Blob		Указывает тип входного источника данных, содержащего потоковые данные. Требуется для запросов PUT (CreateOrReplace).

Compression

Object

Описание сжатия входных данных

Имя	Тип	Default value	Описание
type	CompressionType	None	Указывает тип сжатия, используемого входными данными. Требуется для запросов PUT (CreateOrReplace).

CompressionType

Перечисление

Указывает тип сжатия, используемого входными данными. Требуется для запросов PUT (CreateOrReplace).

Значение	Описание
Deflate
GZip
None

CsvSerialization

Object

Описывает, как данные из входных данных сериализуются или как данные сериализуются при записи в выходные данные в формате CSV.

Имя	Тип	Описание
properties.encoding	Encoding	Указывает кодировку входящих данных в случае ввода и кодирования исходящих данных в случае выходных данных. Требуется для запросов PUT (CreateOrReplace).
properties.fieldDelimiter	string	Указывает разделитель, который будет использоваться для разделения записей с разделителями-запятыми (CSV). Список поддерживаемых значений см. в https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input или https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output. Требуется для запросов PUT (CreateOrReplace).
type	string: Csv	Указывает тип сериализации, используемой входными или выходными данными. Требуется для запросов PUT (CreateOrReplace).

DiagnosticCondition

Object

Условие, применимое к ресурсу или к заданию в целом, которое гарантирует внимание клиентов.

Имя	Тип	Описание
code	string	Непрозрачный диагностический код.
message	string	Читаемое человеком сообщение, описывающее условие подробно. Локализовано в Accept-Language запроса клиента.
since	string	Метка времени UTC при запуске условия. Клиенты должны иметь возможность найти соответствующее событие в журнале ops примерно в это время.

Diagnostics

Object

Описывает условия, применимые к входным, выходным данным или общему заданию, которые гарантируют внимание клиентов.

Имя	Тип	Описание
conditions	DiagnosticCondition[]	Коллекция нулевых или более условий, применимых к ресурсу или к общему заданию, что гарантирует внимание клиентов.

Encoding

Перечисление

Указывает кодировку входящих данных в случае ввода и кодирования исходящих данных в случае выходных данных.

Значение	Описание
UTF8

Error

Object

Представление распространенных ошибок.

Имя	Тип	Описание
error	Error	Свойства определения ошибки.

EventHubStreamInputDataSource

Object

Описывает источник входных данных концентратора событий, содержащий потоковые данные.

Имя	Тип	Default value	Описание
authenticationMode	AuthenticationMode	ConnectionString	Режим проверки подлинности.
properties.consumerGroupName	string		Имя группы потребителей концентратора событий, которая должна использоваться для чтения событий из Концентратора событий. Указание отдельных имен групп потребителей для нескольких входных данных позволяет каждому из этих входных данных получать те же события из Концентратора событий. Если это не указано, входные данные используют группу потребителей концентратора событий по умолчанию.
properties.eventHubName	string		Имя концентратора событий. Требуется для запросов PUT (CreateOrReplace).
serviceBusNamespace	string		Пространство имен, связанное с требуемым концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace).
sharedAccessPolicyName	string		Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Указывает тип входного источника данных, содержащего потоковые данные. Требуется для запросов PUT (CreateOrReplace).

EventHubV2StreamInputDataSource

Object

Описывает источник входных данных концентратора событий, содержащий потоковые данные.

Имя	Тип	Default value	Описание
authenticationMode	AuthenticationMode	ConnectionString	Режим проверки подлинности.
properties.consumerGroupName	string		Имя группы потребителей концентратора событий, которая должна использоваться для чтения событий из Концентратора событий. Указание отдельных имен групп потребителей для нескольких входных данных позволяет каждому из этих входных данных получать те же события из Концентратора событий. Если это не указано, входные данные используют группу потребителей концентратора событий по умолчанию.
properties.eventHubName	string		Имя концентратора событий. Требуется для запросов PUT (CreateOrReplace).
serviceBusNamespace	string		Пространство имен, связанное с требуемым концентратором событий, очередью служебной шины, разделом служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace).
sharedAccessPolicyName	string		Имя политики общего доступа для концентратора событий, очереди служебной шины, раздела служебной шины и т. д. Требуется для запросов PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Указывает тип входного источника данных, содержащего потоковые данные. Требуется для запросов PUT (CreateOrReplace).

EventSerializationType

Перечисление

Указывает тип сериализации, используемой входными или выходными данными. Требуется для запросов PUT (CreateOrReplace).

Значение	Описание
Avro
Csv
Json
Parquet

FileReferenceInputDataSource

Object

Описывает источник входных данных файла, содержащий эталонные данные.

Имя	Тип	Описание
properties.path	string	Путь к файлу.
type	string: File	Указывает тип входного источника данных, содержащего эталонные данные. Требуется для запросов PUT (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Object

Описывает источник входных данных БОЛЬШОго двоичного объекта, содержащий потоковые данные.

Имя	Тип	Описание
properties.topic	string	Имя раздела служебной шины.
type	string: GatewayMessageBus	Указывает тип входного источника данных, содержащего потоковые данные. Требуется для запросов PUT (CreateOrReplace).

Input

Object

Входной объект, содержащий все сведения, связанные с именованными входными данными. Все входные данные содержатся в задании потоковой передачи.

Имя	Тип	Описание
id	string	Идентификатор ресурса
name	string	Имя ресурса
properties	InputProperties: ReferenceInputProperties StreamInputProperties	Свойства, связанные с входными данными. Требуется для запросов PUT (CreateOrReplace).
type	string	Тип ресурса

IoTHubStreamInputDataSource

Object

Описывает источник входных данных Центра Интернета вещей, содержащий потоковые данные.

Имя	Тип	Описание
properties.consumerGroupName	string	Имя группы потребителей Центра Интернета вещей, которая должна использоваться для чтения событий из Центра Интернета вещей. Если это не указано, входные данные используют группу потребителей по умолчанию Центра Iot Hub.
properties.endpoint	string	Конечная точка Центра Интернета вещей для подключения (т. е. сообщения, события, сообщения и операцииMonitoringEvents и т. д.).
properties.iotHubNamespace	string	Имя или универсальный код ресурса (URI) Центра Интернета вещей. Требуется для запросов PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string	Ключ политики общего доступа для указанной политики общего доступа. Требуется для запросов PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string	Имя политики общего доступа для Центра Интернета вещей. Эта политика должна содержать по крайней мере разрешение на подключение службы. Требуется для запросов PUT (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Указывает тип входного источника данных, содержащего потоковые данные. Требуется для запросов PUT (CreateOrReplace).

JsonOutputSerializationFormat

Перечисление

Указывает формат JSON, в который будут записаны выходные данные. Поддерживаемые в настоящее время значения имеют значение lineSeparated, указывающее, что выходные данные будут отформатированы путем разделения каждого объекта JSON новой строкой и массива, указывающего, что выходные данные будут отформатированы в виде массива объектов JSON.

Значение	Описание
Array
LineSeparated

JsonSerialization

Object

Описывает, как данные из входных данных сериализуются или как данные сериализуются при записи в выходные данные в формате JSON.

Имя	Тип	Описание
properties.encoding	Encoding	Указывает кодировку входящих данных в случае ввода и кодирования исходящих данных в случае выходных данных. Требуется для запросов PUT (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Это свойство применяется только к сериализации выходных данных JSON. Это не применимо к входным данным. Это свойство указывает формат JSON, в который будут записаны выходные данные. Поддерживаемые в настоящее время значения имеют значение lineSeparated, указывающее, что выходные данные будут отформатированы путем разделения каждого объекта JSON новой строкой и массива, указывающего, что выходные данные будут отформатированы в виде массива объектов JSON. Значение по умолчанию — lineSeparated, если осталось значение NULL.
type	string: Json	Указывает тип сериализации, используемой входными или выходными данными. Требуется для запросов PUT (CreateOrReplace).

ParquetSerialization

Object

Описывает, как данные из входных данных сериализуются или как данные сериализуются при записи в выходные данные в формате Parquet.

Имя	Тип	Описание
type	string: Parquet	Указывает тип сериализации, используемой входными или выходными данными. Требуется для запросов PUT (CreateOrReplace).

ReferenceInputProperties

Object

Свойства, связанные с входными данными, содержащими справочные данные.

Имя	Тип	Описание
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
RefreshPeriodicallyWithFull
Static

StorageAccount

Object

Свойства, связанные с учетной записью хранения Azure

Имя	Тип	Описание
accountKey	string	Ключ учетной записи для учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace).
accountName	string	Имя учетной записи хранения Azure. Требуется для запросов PUT (CreateOrReplace).

StreamInputProperties

Object

Свойства, связанные с входными данными, содержащими потоковые данные.

Имя	Тип	Описание
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).