Inputs - Update

Servizio:

Stream Analytics

Versione API:

2020-03-01

Aggiornamenti un input esistente in un processo di streaming esistente. Può essere usato per aggiornare parzialmente (ad esempio aggiornare una o due proprietà) un input senza influire sul resto del processo o della definizione di input.

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

Parametri dell'URI

Nome	In	Necessario	Tipo	Descrizione
inputName	path	True	string	Nome dell'input.
jobName	path	True	string	Nome del processo di streaming.
resourceGroupName	path	True	string	Nome del gruppo di risorse. Per il nome non viene fatta distinzione tra maiuscole e minuscole. Criterio di espressione regolare: ^[-\w\._\(\)]+$
subscriptionId	path	True	string	ID della sottoscrizione di destinazione.
api-version	query	True	string	Versione dell'API da usare per questa operazione.

Intestazione della richiesta

Nome	Necessario	Tipo	Descrizione
If-Match		string	ETag dell'input. Omettere questo valore per sovrascrivere sempre l'input corrente. Specificare l'ultimo valore ETag visualizzato per impedire la sovrascrittura accidentale delle modifiche simultanee.

Corpo della richiesta

Nome	Tipo	Descrizione
name	string	Nome risorsa
properties	InputProperties: StreamInputProperties ReferenceInputProperties	Proprietà associate a un input. Obbligatorio nelle richieste PUT (CreateOrReplace).

Risposte

Nome	Tipo	Descrizione
200 OK	Input	L'input è stato aggiornato correttamente. Intestazioni ETag: string
Other Status Codes	Error	Errore.

Sicurezza

azure_auth

Flusso OAuth2 di Azure Active Directory

Tipo: oauth2
Flow: implicit
URL di autorizzazione: https://login.microsoftonline.com/common/oauth2/authorize

Ambiti

Nome	Descrizione
user_impersonation	rappresentare l'account utente

Esempio

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

Esempio di richiesta

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

Risposta di esempio

Codice di stato:

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

Esempio di richiesta

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

Risposta di esempio

Codice di stato:

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

Esempio di richiesta

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

Risposta di esempio

Codice di stato:

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

Esempio di richiesta

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

Risposta di esempio

Codice di stato:

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

Definizioni

Nome	Descrizione
AuthenticationMode	Modalità di autenticazione. Le modalità valide sono ConnectionString, Msi e 'UserToken'.
AvroSerialization	Descrive come i dati di un input vengono serializzati o la serializzazione dei dati quando vengono scritti in un output in formato Avro.
AzureSqlReferenceInputDataSource	Descrive un'origine dati di riferimento del database Azure SQL.
BlobReferenceInputDataSource	Descrive un'origine dati di input BLOB contenente i dati di riferimento.
BlobStreamInputDataSource	Descrive un'origine dati di input BLOB contenente i dati di flusso.
Compression	Descrive il modo in cui i dati di input vengono compressi
CompressionType	Indica il tipo di compressione usato dall'input. Obbligatorio nelle richieste PUT (CreateOrReplace).
CsvSerialization	Viene descritto come i dati di un input vengono serializzati o la serializzazione dei dati quando vengono scritti in un output in formato CSV.
DiagnosticCondition	Condizione applicabile alla risorsa o al processo complessivo, che garantisce l'attenzione dei clienti.
Diagnostics	Descrive le condizioni applicabili all'input, all'output o al processo complessivo, che garantiscono l'attenzione dei clienti.
Encoding	Specifica la codifica dei dati in ingresso nel caso di input e la codifica dei dati in uscita nel caso di output.
Error	Rappresentazione di errore comune.
EventHubStreamInputDataSource	Descrive un'origine dati di input dell'hub eventi che contiene dati di flusso.
EventHubV2StreamInputDataSource	Descrive un'origine dati di input dell'hub eventi che contiene dati di flusso.
EventSerializationType	Indica il tipo di serializzazione usato dall'input o dall'output. Obbligatorio nelle richieste PUT (CreateOrReplace).
FileReferenceInputDataSource	Descrive un'origine dati di input file contenente i dati di riferimento.
GatewayMessageBusStreamInputDataSource	Descrive un'origine dati di input BLOB contenente i dati di flusso.
Input	Oggetto di input contenente tutte le informazioni associate all'input denominato. Tutti gli input sono contenuti in un processo di streaming.
IoTHubStreamInputDataSource	Descrive un'origine dati di input hub IoT che contiene dati di flusso.
JsonOutputSerializationFormat	Specifica il formato dell'output JSON in cui verrà scritto. I valori attualmente supportati sono "lineSeparated" che indicano che l'output verrà formattato con ogni oggetto JSON separato da una nuova riga e "array" che indica che l'output verrà formattato come matrice di oggetti JSON.
JsonSerialization	Descrive come i dati di un input vengono serializzati o la serializzazione dei dati quando vengono scritti in un output in formato JSON.
ParquetSerialization	Descrive come i dati di un input vengono serializzati o la serializzazione dei dati quando vengono scritti in un output in formato Parquet.
ReferenceInputProperties	Proprietà associate a un input contenente dati di riferimento.
RefreshType	Indica il tipo di opzione di aggiornamento dei dati.
StorageAccount	Proprietà associate a un account di archiviazione di Azure
StreamInputProperties	Proprietà associate a un input contenente i dati di flusso.

AuthenticationMode

Modalità di autenticazione. Le modalità valide sono ConnectionString, Msi e 'UserToken'.

Nome	Tipo	Descrizione
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Descrive come i dati di un input vengono serializzati o la serializzazione dei dati quando vengono scritti in un output in formato Avro.

Nome	Tipo	Descrizione
type	string: Avro	Indica il tipo di serializzazione usato dall'input o dall'output. Obbligatorio nelle richieste PUT (CreateOrReplace).

AzureSqlReferenceInputDataSource

Descrive un'origine dati di riferimento del database Azure SQL.

Nome	Tipo	Descrizione
properties.database	string	Questo elemento viene associato all'elemento datasource. Nome del database in cui verrà scritto l'output.
properties.deltaSnapshotQuery	string	Questo elemento viene associato all'elemento datasource. Questa query viene usata per recuperare le modifiche incrementali dal database SQL. Per usare questa opzione, è consigliabile usare tabelle temporali in Azure SQL Database.
properties.fullSnapshotQuery	string	Questo elemento viene associato all'elemento datasource. Questa query viene usata per recuperare i dati dal database SQL.
properties.password	string	Questo elemento viene associato all'elemento datasource. Password che verrà usata per connettersi all'istanza di database SQL.
properties.refreshRate	string	Questo elemento viene associato all'elemento datasource. Ciò indica la frequenza di recupero dei dati dal database. È di formato DateTime.
properties.refreshType	RefreshType	Indica il tipo di opzione di aggiornamento dei dati.
properties.server	string	Questo elemento viene associato all'elemento datasource. Nome del server che contiene il database in cui verranno scritti i dati.
properties.table	string	Questo elemento viene associato all'elemento datasource. Nome della tabella nel database Azure SQL.
properties.user	string	Questo elemento viene associato all'elemento datasource. Nome utente che verrà usato per connettersi all'istanza di database SQL.
type	string: Microsoft.Sql/Server/Database	Indica il tipo di origine dati di input contenente i dati di riferimento. Obbligatorio nelle richieste PUT (CreateOrReplace).

BlobReferenceInputDataSource

Descrive un'origine dati di input BLOB contenente i dati di riferimento.

Nome	Tipo	Valore predefinito	Descrizione
properties.authenticationMode	AuthenticationMode	ConnectionString	Modalità di autenticazione.
properties.container	string		Nome di un contenitore all'interno dell'account di archiviazione associato. Questo contenitore contiene i BLOB da leggere o scrivere in. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.dateFormat	string		Formato della data. Ovunque {date} venga visualizzato in pathPattern, il valore di questa proprietà viene usato come formato data.
properties.pathPattern	string		Modello di percorso BLOB. Non un'espressione regolare. Rappresenta un modello rispetto al quale i nomi BLOB verranno corrispondenti per determinare se devono essere inclusi come input o output al processo. Vedere https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input o https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output per una spiegazione più dettagliata ed esempio.
properties.storageAccounts	StorageAccount[]		Elenco di uno o più account di archiviazione di Azure. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.timeFormat	string		Formato ora. Ovunque {time} venga visualizzato in pathPattern, il valore di questa proprietà viene usato come formato ora.
type	string: Microsoft.Storage/Blob		Indica il tipo di origine dati di input contenente i dati di riferimento. Obbligatorio nelle richieste PUT (CreateOrReplace).

BlobStreamInputDataSource

Descrive un'origine dati di input BLOB contenente i dati di flusso.

Nome	Tipo	Valore predefinito	Descrizione
properties.authenticationMode	AuthenticationMode	ConnectionString	Modalità di autenticazione.
properties.container	string		Nome di un contenitore all'interno dell'account di archiviazione associato. Questo contenitore contiene i BLOB da leggere o scrivere in. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.dateFormat	string		Formato della data. Ovunque {date} venga visualizzato in pathPattern, il valore di questa proprietà viene usato come formato data.
properties.pathPattern	string		Modello di percorso BLOB. Non un'espressione regolare. Rappresenta un modello rispetto al quale i nomi BLOB verranno corrispondenti per determinare se devono essere inclusi come input o output al processo. Vedere https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input o https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output per una spiegazione più dettagliata ed esempio.
properties.sourcePartitionCount	integer		Numero di partizioni dell'origine dati di input BLOB. Intervallo 1 - 1024.
properties.storageAccounts	StorageAccount[]		Elenco di uno o più account di archiviazione di Azure. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.timeFormat	string		Formato ora. Ovunque {time} venga visualizzato in pathPattern, il valore di questa proprietà viene usato come formato ora.
type	string: Microsoft.Storage/Blob		Indica il tipo di origine dati di input contenente i dati di flusso. Obbligatorio nelle richieste PUT (CreateOrReplace).

Compression

Descrive il modo in cui i dati di input vengono compressi

Nome	Tipo	Valore predefinito	Descrizione
type	CompressionType	None	Indica il tipo di compressione usato dall'input. Obbligatorio nelle richieste PUT (CreateOrReplace).

CompressionType

Indica il tipo di compressione usato dall'input. Obbligatorio nelle richieste PUT (CreateOrReplace).

Nome	Tipo	Descrizione
Deflate	string
GZip	string
None	string

CsvSerialization

Viene descritto come i dati di un input vengono serializzati o la serializzazione dei dati quando vengono scritti in un output in formato CSV.

Nome	Tipo	Descrizione
properties.encoding	Encoding	Specifica la codifica dei dati in ingresso nel caso di input e la codifica dei dati in uscita nel caso di output. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.fieldDelimiter	string	Specifica il delimitatore che verrà usato per separare i record con valori delimitati da virgole (CSV). Vedere https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input o https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output per un elenco di valori supportati. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Csv	Indica il tipo di serializzazione usato dall'input o dall'output. Obbligatorio nelle richieste PUT (CreateOrReplace).

DiagnosticCondition

Condizione applicabile alla risorsa o al processo complessivo, che garantisce l'attenzione dei clienti.

Nome	Tipo	Descrizione
code	string	Codice diagnostico opaco.
message	string	Messaggio leggibile che descrive in dettaglio la condizione. Localizzato nella Accept-Language della richiesta client.
since	string	Timestamp UTC di all'avvio della condizione. I clienti devono essere in grado di trovare un evento corrispondente nel log operazioni di questo periodo.

Diagnostics

Descrive le condizioni applicabili all'input, all'output o al processo complessivo, che garantiscono l'attenzione dei clienti.

Nome	Tipo	Descrizione
conditions	DiagnosticCondition[]	Raccolta di zero o più condizioni applicabili alla risorsa o al processo complessivo, che garantiscono l'attenzione dei clienti.

Encoding

Specifica la codifica dei dati in ingresso nel caso di input e la codifica dei dati in uscita nel caso di output.

Nome	Tipo	Descrizione
UTF8	string

Error

Rappresentazione di errore comune.

Nome	Tipo	Descrizione
error	Error	Proprietà di definizione degli errori.

EventHubStreamInputDataSource

Descrive un'origine dati di input dell'hub eventi che contiene dati di flusso.

Nome	Tipo	Valore predefinito	Descrizione
authenticationMode	AuthenticationMode	ConnectionString	Modalità di autenticazione.
properties.consumerGroupName	string		Nome di un gruppo di consumer dell'hub eventi che deve essere usato per leggere gli eventi dall'hub eventi. Specificando nomi di gruppi di consumer distinti per più input, ognuno di questi input può ricevere gli stessi eventi dall'hub eventi. Se non specificato, l'input usa il gruppo consumer predefinito dell'hub eventi.
properties.eventHubName	string		Nome dell'hub eventi. Obbligatorio nelle richieste PUT (CreateOrReplace).
serviceBusNamespace	string		Spazio dei nomi associato all'hub eventi desiderato, coda del bus di servizio, argomento del bus di servizio e così via. Obbligatorio nelle richieste PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Chiave dei criteri di accesso condiviso per i criteri di accesso condiviso specificati. Obbligatorio nelle richieste PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nome dei criteri di accesso condiviso per l'hub eventi, la coda del bus di servizio, l'argomento del bus di servizio e così via. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Indica il tipo di origine dati di input contenente i dati di flusso. Obbligatorio nelle richieste PUT (CreateOrReplace).

EventHubV2StreamInputDataSource

Descrive un'origine dati di input dell'hub eventi che contiene dati di flusso.

Nome	Tipo	Valore predefinito	Descrizione
authenticationMode	AuthenticationMode	ConnectionString	Modalità di autenticazione.
properties.consumerGroupName	string		Nome di un gruppo di consumer dell'hub eventi che deve essere usato per leggere gli eventi dall'hub eventi. Specificando nomi di gruppi di consumer distinti per più input, ognuno di questi input può ricevere gli stessi eventi dall'hub eventi. Se non specificato, l'input usa il gruppo consumer predefinito dell'hub eventi.
properties.eventHubName	string		Nome dell'hub eventi. Obbligatorio nelle richieste PUT (CreateOrReplace).
serviceBusNamespace	string		Spazio dei nomi associato all'hub eventi desiderato, coda del bus di servizio, argomento del bus di servizio e così via. Obbligatorio nelle richieste PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Chiave dei criteri di accesso condiviso per i criteri di accesso condiviso specificati. Obbligatorio nelle richieste PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nome dei criteri di accesso condiviso per l'hub eventi, la coda del bus di servizio, l'argomento del bus di servizio e così via. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Indica il tipo di origine dati di input contenente i dati di flusso. Obbligatorio nelle richieste PUT (CreateOrReplace).

EventSerializationType

Indica il tipo di serializzazione usato dall'input o dall'output. Obbligatorio nelle richieste PUT (CreateOrReplace).

Nome	Tipo	Descrizione
Avro	string
Csv	string
Json	string
Parquet	string

FileReferenceInputDataSource

Descrive un'origine dati di input file contenente i dati di riferimento.

Nome	Tipo	Descrizione
properties.path	string	Percorso del file.
type	string: File	Indica il tipo di origine dati di input contenente i dati di riferimento. Obbligatorio nelle richieste PUT (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Descrive un'origine dati di input BLOB contenente i dati di flusso.

Nome	Tipo	Descrizione
properties.topic	string	Nome dell'argomento del bus di servizio.
type	string: GatewayMessageBus	Indica il tipo di origine dati di input contenente i dati di flusso. Obbligatorio nelle richieste PUT (CreateOrReplace).

Input

Oggetto di input contenente tutte le informazioni associate all'input denominato. Tutti gli input sono contenuti in un processo di streaming.

Nome	Tipo	Descrizione
id	string	ID risorsa
name	string	Nome risorsa
properties	InputProperties: ReferenceInputProperties StreamInputProperties	Proprietà associate a un input. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string	Tipo di risorsa

IoTHubStreamInputDataSource

Descrive un'origine dati di input hub IoT che contiene dati di flusso.

Nome	Tipo	Descrizione
properties.consumerGroupName	string	Nome di un gruppo di consumer di hub IoT che deve essere usato per leggere gli eventi dall'hub IoT. Se non specificato, l'input usa il gruppo consumer predefinito di Iot Hub.
properties.endpoint	string	Endpoint hub IoT da connettersi (ad esempio messaggi/eventi, messaggi/operazioniMonitoringEvents e così via).
properties.iotHubNamespace	string	Nome o URI dell'hub IoT. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string	Chiave dei criteri di accesso condiviso per i criteri di accesso condiviso specificati. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string	Nome dei criteri di accesso condiviso per il hub IoT. Questo criterio deve contenere almeno l'autorizzazione di connessione del servizio. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Indica il tipo di origine dati di input contenente i dati di flusso. Obbligatorio nelle richieste PUT (CreateOrReplace).

JsonOutputSerializationFormat

Specifica il formato dell'output JSON in cui verrà scritto. I valori attualmente supportati sono "lineSeparated" che indicano che l'output verrà formattato con ogni oggetto JSON separato da una nuova riga e "array" che indica che l'output verrà formattato come matrice di oggetti JSON.

Nome	Tipo	Descrizione
Array	string
LineSeparated	string

JsonSerialization

Descrive come i dati di un input vengono serializzati o la serializzazione dei dati quando vengono scritti in un output in formato JSON.

Nome	Tipo	Descrizione
properties.encoding	Encoding	Specifica la codifica dei dati in ingresso nel caso di input e la codifica dei dati in uscita nel caso di output. Obbligatorio nelle richieste PUT (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Questa proprietà si applica solo alla serializzazione JSON degli output. Non è applicabile agli input. Questa proprietà specifica il formato dell'output JSON in cui verrà scritto. I valori attualmente supportati sono "lineSeparated" che indicano che l'output verrà formattato con ogni oggetto JSON separato da una nuova riga e "array" che indica che l'output verrà formattato come matrice di oggetti JSON. Il valore predefinito è 'lineSeparated' se è stato lasciato null.
type	string: Json	Indica il tipo di serializzazione usato dall'input o dall'output. Obbligatorio nelle richieste PUT (CreateOrReplace).

ParquetSerialization

Descrive come i dati di un input vengono serializzati o la serializzazione dei dati quando vengono scritti in un output in formato Parquet.

Nome	Tipo	Descrizione
type	string: Parquet	Indica il tipo di serializzazione usato dall'input o dall'output. Obbligatorio nelle richieste PUT (CreateOrReplace).

ReferenceInputProperties

Proprietà associate a un input contenente dati di riferimento.

Nome	Tipo	Descrizione
compression	Compression	Descrive il modo in cui i dati di input vengono compressi
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Descrive un'origine dati di input contenente i dati di riferimento. Obbligatorio nelle richieste PUT (CreateOrReplace).
diagnostics	Diagnostics	Descrive le condizioni applicabili all'input, all'output o al processo complessivo, che garantiscono l'attenzione dei clienti.
etag	string	Tag di entità corrente per l'input. Si tratta di una stringa opaca. È possibile usarlo per rilevare se la risorsa è cambiata tra le richieste. È anche possibile usarlo nelle intestazioni di If-Match o If-None-Match per le operazioni di scrittura per la concorrenza ottimistica.
partitionKey	string	partitionKey Descrive una chiave nei dati di input usati per partizionamento dei dati di input
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Descrive la serializzazione dei dati da un input o la serializzazione dei dati quando vengono scritti in un output. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Reference	Indica se l'input è un'origine di dati di riferimento o di flusso. Obbligatorio nelle richieste PUT (CreateOrReplace).

RefreshType

Indica il tipo di opzione di aggiornamento dei dati.

Nome	Tipo	Descrizione
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

StorageAccount

Proprietà associate a un account di archiviazione di Azure

Nome	Tipo	Descrizione
accountKey	string	Chiave dell'account per l'account di archiviazione di Azure. Obbligatorio nelle richieste PUT (CreateOrReplace).
accountName	string	il nome dell'account di archiviazione di Azure. Obbligatorio nelle richieste PUT (CreateOrReplace).

StreamInputProperties

Proprietà associate a un input contenente i dati di flusso.

Nome	Tipo	Descrizione
compression	Compression	Descrive il modo in cui i dati di input vengono compressi
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Descrive un'origine dati di input che contiene dati di flusso. Obbligatorio nelle richieste PUT (CreateOrReplace).
diagnostics	Diagnostics	Descrive le condizioni applicabili all'input, all'output o al processo complessivo, che garantiscono l'attenzione dei clienti.
etag	string	Tag di entità corrente per l'input. Si tratta di una stringa opaca. È possibile usarlo per rilevare se la risorsa è cambiata tra le richieste. È anche possibile usarlo nelle intestazioni di If-Match o If-None-Match per le operazioni di scrittura per la concorrenza ottimistica.
partitionKey	string	partitionKey Descrive una chiave nei dati di input usati per partizionamento dei dati di input
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Descrive la serializzazione dei dati da un input o la serializzazione dei dati quando vengono scritti in un output. Obbligatorio nelle richieste PUT (CreateOrReplace).
type	string: Stream	Indica se l'input è un'origine di dati di riferimento o di flusso. Obbligatorio nelle richieste PUT (CreateOrReplace).