Inputs - Update

Servicio:

Stream Analytics

Versión de la API:

2020-03-01

Novedades una entrada existente en un trabajo de streaming existente. Esto se puede usar para actualizar parcialmente (es decir, actualizar una o dos propiedades) una entrada sin afectar al resto de la definición de entrada o trabajo.

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

Parámetros de identificador URI

Nombre	En	Requerido	Tipo	Description
inputName	path	True	string	Nombre de la entrada.
jobName	path	True	string	Nombre del trabajo de streaming.
resourceGroupName	path	True	string	Nombre del grupo de recursos. El nombre distingue mayúsculas de minúsculas. Patrón de Regex: ^[-\w\._\(\)]+$
subscriptionId	path	True	string	Identificador de la suscripción de destino.
api-version	query	True	string	Versión de API que se usará para la operación.

Encabezado de la solicitud

Nombre	Requerido	Tipo	Description
If-Match		string	ETag de la entrada. Omita este valor para sobrescribir siempre la entrada actual. Especifique el último valor de ETag visto para evitar que se sobrescriba accidentalmente los cambios simultáneos.

Cuerpo de la solicitud

Nombre	Tipo	Description
name	string	Nombre del recurso
properties	InputProperties: StreamInputProperties ReferenceInputProperties	Propiedades asociadas a una entrada. Obligatorio en las solicitudes PUT (CreateOrReplace).

Respuestas

Nombre	Tipo	Description
200 OK	Input	La entrada se actualizó correctamente. Encabezados ETag: string
Other Status Codes	Error	Error.

Seguridad

azure_auth

Flujo OAuth2 de Azure Active Directory

Tipo: oauth2
Flujo: implicit
Dirección URL de autorización: https://login.microsoftonline.com/common/oauth2/authorize

Ámbitos

Nombre	Description
user_impersonation	suplantación de su cuenta de usuario

Ejemplos

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

Solicitud de ejemplo

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.core.util.Context;
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", Context.NONE).getValue();
        resource
            .update()
            .withProperties(
                new ReferenceInputProperties()
                    .withSerialization(new CsvSerialization().withFieldDelimiter("|").withEncoding(Encoding.UTF8))
                    .withDatasource(new BlobReferenceInputDataSource()))
            .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

Respuesta de muestra

status code:

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

Solicitud de ejemplo

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.core.util.Context;
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", 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

Respuesta de muestra

status code:

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

Solicitud de ejemplo

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.core.util.Context;
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", 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

Respuesta de muestra

status code:

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

Solicitud de ejemplo

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.core.util.Context;
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", 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

Respuesta de muestra

status code:

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

Definiciones

Nombre	Description
AuthenticationMode	Modo de autenticación. Los modos válidos son ConnectionString, Msi y "UserToken".
AvroSerialization	Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida en formato Avro.
AzureSqlReferenceInputDataSource	Describe un Azure SQL origen de datos de entrada de referencia de base de datos.
BlobReferenceInputDataSource	Describe un origen de datos de entrada de blobs que contiene datos de referencia.
BlobStreamInputDataSource	Describe un origen de datos de entrada de blobs que contiene datos de flujo.
Compression	Describe cómo se comprimen los datos de entrada.
CompressionType	Indica el tipo de compresión que usa la entrada. Obligatorio en las solicitudes PUT (CreateOrReplace).
CsvSerialization	Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida en formato CSV.
DiagnosticCondition	Condición aplicable al recurso, o al trabajo en general, que garantiza la atención al cliente.
Diagnostics	Describe las condiciones aplicables a la entrada, la salida o el trabajo en general, que garantizan la atención al cliente.
Encoding	Especifica la codificación de los datos entrantes en el caso de la entrada y la codificación de los datos salientes en el caso de la salida.
Error	Representación de error común.
EventHubStreamInputDataSource	Describe un origen de datos de entrada del centro de eventos que contiene datos de flujo.
EventHubV2StreamInputDataSource	Describe un origen de datos de entrada del centro de eventos que contiene datos de flujo.
EventSerializationType	Indica el tipo de serialización que usa la entrada o salida. Obligatorio en las solicitudes PUT (CreateOrReplace).
FileReferenceInputDataSource	Describe un origen de datos de entrada de archivo que contiene datos de referencia.
GatewayMessageBusStreamInputDataSource	Describe un origen de datos de entrada de blobs que contiene datos de flujo.
Input	Objeto de entrada que contiene toda la información asociada a la entrada con nombre. Todas las entradas están contenidas en un trabajo de streaming.
IoTHubStreamInputDataSource	Describe un IoT Hub origen de datos de entrada que contiene datos de flujo.
JsonOutputSerializationFormat	Especifica el formato json en el que se escribirá la salida. Los valores admitidos actualmente son "lineSeparated" que indican que la salida se dará formato al tener cada objeto JSON separado por una nueva línea y "matriz" que indica que la salida se dará formato como una matriz de objetos JSON.
JsonSerialization	Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida en formato JSON.
ParquetSerialization	Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida en formato Parquet.
ReferenceInputProperties	Propiedades asociadas a una entrada que contiene datos de referencia.
RefreshType	Indica el tipo de opción de actualización de datos.
StorageAccount	Propiedades asociadas a una cuenta de Azure Storage
StreamInputProperties	Propiedades asociadas a una entrada que contiene datos de flujo.

AuthenticationMode

Modo de autenticación. Los modos válidos son ConnectionString, Msi y "UserToken".

Nombre	Tipo	Description
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida en formato Avro.

Nombre	Tipo	Description
type	string: Avro	Indica el tipo de serialización que usa la entrada o salida. Obligatorio en las solicitudes PUT (CreateOrReplace).

AzureSqlReferenceInputDataSource

Describe un Azure SQL origen de datos de entrada de referencia de base de datos.

Nombre	Tipo	Description
properties.database	string	Este elemento está asociado al elemento datasource. Este es el nombre de la base de datos en la que se escribirá la salida.
properties.deltaSnapshotQuery	string	Este elemento está asociado al elemento datasource. Esta consulta se usa para capturar los cambios incrementales de la base de datos SQL. Para usar esta opción, se recomienda usar tablas temporales en Azure SQL Database.
properties.fullSnapshotQuery	string	Este elemento está asociado al elemento datasource. Esta consulta se usa para capturar datos de la base de datos sql.
properties.password	string	Este elemento está asociado al elemento datasource. Esta es la contraseña que se utilizará para conectarse a la instancia de Base de datos SQL.
properties.refreshRate	string	Este elemento está asociado al elemento datasource. Esto indica la frecuencia con la que se capturarán los datos de la base de datos. Es del formato DateTime.
properties.refreshType	RefreshType	Indica el tipo de opción de actualización de datos.
properties.server	string	Este elemento está asociado al elemento datasource. Este es el nombre del servidor que contiene la base de datos en la que se escribirá.
properties.table	string	Este elemento está asociado al elemento datasource. Nombre de la tabla de la Azure SQL base de datos.
properties.user	string	Este elemento está asociado al elemento datasource. Este es el nombre de usuario que se utilizará para conectarse a la instancia de Base de datos SQL.
type	string: Microsoft.Sql/Server/Database	Indica el tipo de origen de datos de entrada que contiene datos de referencia. Obligatorio en las solicitudes PUT (CreateOrReplace).

BlobReferenceInputDataSource

Describe un origen de datos de entrada de blobs que contiene datos de referencia.

Nombre	Tipo	Valor predeterminado	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticación.
properties.container	string		Nombre de un contenedor dentro de la cuenta de almacenamiento asociada. Este contenedor contiene los blobs en los que se van a leer o escribir. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.dateFormat	string		El formato de la fecha. Siempre que {date} aparezca en pathPattern, el valor de esta propiedad se usa como formato de fecha en su lugar.
properties.pathPattern	string		Patrón de ruta de acceso del blob. No es una expresión regular. Representa un patrón con el que se buscarán coincidencias con los nombres de blobs para determinar si se deben incluir como entrada o salida en el trabajo. Consulte 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 para obtener una explicación y un ejemplo más detallados.
properties.storageAccounts	StorageAccount[]		Una lista de una o varias cuentas de Azure Storage. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.timeFormat	string		Formato de hora. Siempre que aparezca {time} en pathPattern, el valor de esta propiedad se usa como formato de hora en su lugar.
type	string: Microsoft.Storage/Blob		Indica el tipo de origen de datos de entrada que contiene datos de referencia. Obligatorio en las solicitudes PUT (CreateOrReplace).

BlobStreamInputDataSource

Describe un origen de datos de entrada de blobs que contiene datos de flujo.

Nombre	Tipo	Valor predeterminado	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticación.
properties.container	string		Nombre de un contenedor dentro de la cuenta de almacenamiento asociada. Este contenedor contiene los blobs en los que se van a leer o escribir. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.dateFormat	string		El formato de la fecha. Siempre que {date} aparezca en pathPattern, el valor de esta propiedad se usa como formato de fecha en su lugar.
properties.pathPattern	string		Patrón de ruta de acceso del blob. No es una expresión regular. Representa un patrón con el que se buscarán coincidencias con los nombres de blobs para determinar si se deben incluir como entrada o salida en el trabajo. Consulte 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 para obtener una explicación y un ejemplo más detallados.
properties.sourcePartitionCount	integer		Recuento de particiones del origen de datos de entrada del blob. Intervalo 1 - 1024.
properties.storageAccounts	StorageAccount[]		Una lista de una o varias cuentas de Azure Storage. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.timeFormat	string		Formato de hora. Siempre que aparezca {time} en pathPattern, el valor de esta propiedad se usa como formato de hora en su lugar.
type	string: Microsoft.Storage/Blob		Indica el tipo de origen de datos de entrada que contiene datos de flujo. Obligatorio en las solicitudes PUT (CreateOrReplace).

Compression

Describe cómo se comprimen los datos de entrada.

Nombre	Tipo	Valor predeterminado	Description
type	CompressionType	None	Indica el tipo de compresión que usa la entrada. Obligatorio en las solicitudes PUT (CreateOrReplace).

CompressionType

Indica el tipo de compresión que usa la entrada. Obligatorio en las solicitudes PUT (CreateOrReplace).

Nombre	Tipo	Description
Deflate	string
GZip	string
None	string

CsvSerialization

Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida en formato CSV.

Nombre	Tipo	Description
properties.encoding	Encoding	Especifica la codificación de los datos entrantes en el caso de la entrada y la codificación de los datos salientes en el caso de la salida. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.fieldDelimiter	string	Especifica el delimitador que se usará para separar los registros de valores separados por comas (CSV). Consulte 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 para obtener una lista de valores admitidos. Obligatorio en las solicitudes PUT (CreateOrReplace).
type	string: Csv	Indica el tipo de serialización que usa la entrada o salida. Obligatorio en las solicitudes PUT (CreateOrReplace).

DiagnosticCondition

Condición aplicable al recurso, o al trabajo en general, que garantiza la atención al cliente.

Nombre	Tipo	Description
code	string	Código de diagnóstico opaco.
message	string	Mensaje legible que describe la condición en detalle. Localizado en el Accept-Language de la solicitud de cliente.
since	string	Marca de tiempo UTC de cuándo se inició la condición. Los clientes deben poder encontrar un evento correspondiente en el registro de operaciones en este momento.

Diagnostics

Describe las condiciones aplicables a la entrada, la salida o el trabajo en general, que garantizan la atención al cliente.

Nombre	Tipo	Description
conditions	DiagnosticCondition[]	Colección de cero o más condiciones aplicables al recurso, o al trabajo en general, que justifican la atención al cliente.

Encoding

Especifica la codificación de los datos entrantes en el caso de la entrada y la codificación de los datos salientes en el caso de la salida.

Nombre	Tipo	Description
UTF8	string

Error

Representación de error común.

Nombre	Tipo	Description
error	Error	Propiedades de definición de error.

EventHubStreamInputDataSource

Describe un origen de datos de entrada del centro de eventos que contiene datos de flujo.

Nombre	Tipo	Valor predeterminado	Description
authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticación.
properties.consumerGroupName	string		Nombre de un grupo de consumidores del centro de eventos que se debe usar para leer eventos del centro de eventos. Especificar nombres de grupo de consumidores distintos para varias entradas permite que cada una de esas entradas reciba los mismos eventos del centro de eventos. Si no se especifica, la entrada usa el grupo de consumidores predeterminado del centro de eventos.
properties.eventHubName	string		Nombre del centro de eventos. Obligatorio en las solicitudes PUT (CreateOrReplace).
serviceBusNamespace	string		Espacio de nombres asociado al centro de eventos deseado, cola de Service Bus, tema de Service Bus, etc. Obligatorio en las solicitudes PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Clave de directiva de acceso compartido para la directiva de acceso compartido especificada. Obligatorio en las solicitudes PUT (CreateOrReplace).
sharedAccessPolicyName	string		El nombre de la directiva de acceso compartido para el centro de eventos, la cola de Service Bus, el tema de Service Bus, etc. Obligatorio en las solicitudes PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Indica el tipo de origen de datos de entrada que contiene datos de flujo. Obligatorio en las solicitudes PUT (CreateOrReplace).

EventHubV2StreamInputDataSource

Describe un origen de datos de entrada del centro de eventos que contiene datos de flujo.

Nombre	Tipo	Valor predeterminado	Description
authenticationMode	AuthenticationMode	ConnectionString	Modo de autenticación.
properties.consumerGroupName	string		Nombre de un grupo de consumidores del centro de eventos que se debe usar para leer eventos del centro de eventos. Especificar nombres de grupo de consumidores distintos para varias entradas permite que cada una de esas entradas reciba los mismos eventos del centro de eventos. Si no se especifica, la entrada usa el grupo de consumidores predeterminado del centro de eventos.
properties.eventHubName	string		Nombre del centro de eventos. Obligatorio en las solicitudes PUT (CreateOrReplace).
serviceBusNamespace	string		Espacio de nombres asociado al centro de eventos deseado, cola de Service Bus, tema de Service Bus, etc. Obligatorio en las solicitudes PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Clave de directiva de acceso compartido para la directiva de acceso compartido especificada. Obligatorio en las solicitudes PUT (CreateOrReplace).
sharedAccessPolicyName	string		El nombre de la directiva de acceso compartido para el centro de eventos, la cola de Service Bus, el tema de Service Bus, etc. Obligatorio en las solicitudes PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Indica el tipo de origen de datos de entrada que contiene datos de flujo. Obligatorio en las solicitudes PUT (CreateOrReplace).

EventSerializationType

Indica el tipo de serialización que usa la entrada o salida. Obligatorio en las solicitudes PUT (CreateOrReplace).

Nombre	Tipo	Description
Avro	string
Csv	string
Json	string
Parquet	string

FileReferenceInputDataSource

Describe un origen de datos de entrada de archivo que contiene datos de referencia.

Nombre	Tipo	Description
properties.path	string	Ruta de acceso del archivo.
type	string: File	Indica el tipo de origen de datos de entrada que contiene datos de referencia. Obligatorio en las solicitudes PUT (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Describe un origen de datos de entrada de blobs que contiene datos de flujo.

Nombre	Tipo	Description
properties.topic	string	Nombre del tema de Service Bus.
type	string: GatewayMessageBus	Indica el tipo de origen de datos de entrada que contiene datos de flujo. Obligatorio en las solicitudes PUT (CreateOrReplace).

Input

Objeto de entrada que contiene toda la información asociada a la entrada con nombre. Todas las entradas están contenidas en un trabajo de streaming.

Nombre	Tipo	Description
id	string	Id. de recurso
name	string	Nombre del recurso
properties	InputProperties: ReferenceInputProperties StreamInputProperties	Propiedades asociadas a una entrada. Obligatorio en las solicitudes PUT (CreateOrReplace).
type	string	Tipo de recurso

IoTHubStreamInputDataSource

Describe un IoT Hub origen de datos de entrada que contiene datos de flujo.

Nombre	Tipo	Description
properties.consumerGroupName	string	Nombre de un grupo de consumidores de IoT Hub que se debe usar para leer eventos del IoT Hub. Si no se especifica, la entrada usa el grupo de consumidores predeterminado de Iot Hub.
properties.endpoint	string	El punto de conexión IoT Hub al que conectarse (es decir, mensajes/eventos, mensajes/operacionesMonitoringEvents, etc.).
properties.iotHubNamespace	string	Nombre o URI del IoT Hub. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string	Clave de directiva de acceso compartido para la directiva de acceso compartido especificada. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string	Nombre de la directiva de acceso compartido para el IoT Hub. Esta directiva debe contener al menos el permiso De conexión de servicio. Obligatorio en las solicitudes PUT (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Indica el tipo de origen de datos de entrada que contiene datos de flujo. Obligatorio en las solicitudes PUT (CreateOrReplace).

JsonOutputSerializationFormat

Especifica el formato json en el que se escribirá la salida. Los valores admitidos actualmente son "lineSeparated" que indican que la salida se dará formato al tener cada objeto JSON separado por una nueva línea y "matriz" que indica que la salida se dará formato como una matriz de objetos JSON.

Nombre	Tipo	Description
Array	string
LineSeparated	string

JsonSerialization

Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida en formato JSON.

Nombre	Tipo	Description
properties.encoding	Encoding	Especifica la codificación de los datos entrantes en el caso de la entrada y la codificación de los datos salientes en el caso de la salida. Obligatorio en las solicitudes PUT (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Esta propiedad solo se aplica a la serialización JSON de salidas. No es aplicable a las entradas. Esta propiedad especifica el formato json en el que se escribirá la salida. Los valores admitidos actualmente son "lineSeparated" que indican que la salida se dará formato al tener cada objeto JSON separado por una nueva línea y "matriz" que indica que la salida se dará formato como una matriz de objetos JSON. El valor predeterminado es "lineSeparated" si se deja null.
type	string: Json	Indica el tipo de serialización que usa la entrada o salida. Obligatorio en las solicitudes PUT (CreateOrReplace).

ParquetSerialization

Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida en formato Parquet.

Nombre	Tipo	Description
type	string: Parquet	Indica el tipo de serialización que usa la entrada o salida. Obligatorio en las solicitudes PUT (CreateOrReplace).

ReferenceInputProperties

Propiedades asociadas a una entrada que contiene datos de referencia.

Nombre	Tipo	Description
compression	Compression	Describe cómo se comprimen los datos de entrada.
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Describe un origen de datos de entrada que contiene datos de referencia. Obligatorio en las solicitudes PUT (CreateOrReplace).
diagnostics	Diagnostics	Describe las condiciones aplicables a la entrada, la salida o el trabajo en general, que garantizan la atención al cliente.
etag	string	Etiqueta de entidad actual para la entrada. Se trata de una cadena opaca. Puede usarlo para detectar si el recurso ha cambiado entre solicitudes. También puede usarlo en los encabezados If-Match o If-None-Match para operaciones de escritura para la simultaneidad optimista.
partitionKey	string	partitionKey Describe una clave en los datos de entrada que se usan para crear particiones de los datos de entrada.
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida. Obligatorio en las solicitudes PUT (CreateOrReplace).
type	string: Reference	Indica si la entrada es un origen de datos de referencia o datos de flujo. Obligatorio en las solicitudes PUT (CreateOrReplace).

RefreshType

Indica el tipo de opción de actualización de datos.

Nombre	Tipo	Description
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

StorageAccount

Propiedades asociadas a una cuenta de Azure Storage

Nombre	Tipo	Description
accountKey	string	Clave de cuenta de la cuenta de Azure Storage. Obligatorio en las solicitudes PUT (CreateOrReplace).
accountName	string	nombre de la cuenta de Azure Storage. Obligatorio en las solicitudes PUT (CreateOrReplace).

StreamInputProperties

Propiedades asociadas a una entrada que contiene datos de flujo.

Nombre	Tipo	Description
compression	Compression	Describe cómo se comprimen los datos de entrada.
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Describe un origen de datos de entrada que contiene datos de flujo. Obligatorio en las solicitudes PUT (CreateOrReplace).
diagnostics	Diagnostics	Describe las condiciones aplicables a la entrada, la salida o el trabajo en general, que garantizan la atención al cliente.
etag	string	Etiqueta de entidad actual para la entrada. Se trata de una cadena opaca. Puede usarlo para detectar si el recurso ha cambiado entre solicitudes. También puede usarlo en los encabezados If-Match o If-None-Match para operaciones de escritura para la simultaneidad optimista.
partitionKey	string	partitionKey Describe una clave en los datos de entrada que se usan para crear particiones de los datos de entrada.
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Describe cómo se serializan los datos de una entrada o cómo se serializan los datos cuando se escriben en una salida. Obligatorio en las solicitudes PUT (CreateOrReplace).
type	string: Stream	Indica si la entrada es un origen de datos de referencia o datos de flujo. Obligatorio en las solicitudes PUT (CreateOrReplace).