Inputs - Update

Referenz

Dienst:: Stream Analytics

API-Version:: 2020-03-01

Updates eine vorhandene Eingabe unter einem vorhandenen Streamingauftrag. Dies kann verwendet werden, um eine Eingabe teilweise zu aktualisieren (dh eine oder zwei Eigenschaften zu aktualisieren), ohne den Rest des Auftrags oder der Eingabedefinition zu beeinträchtigen.

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

URI-Parameter

Name	In	Erforderlich	Typ	Beschreibung
inputName	path	True	string	Der Name der Eingabe.
jobName	path	True	string	Der Name des Streamingauftrags.
resourceGroupName	path	True	string	Der Name der Ressourcengruppe. Für den Namen wird die Groß-/Kleinschreibung nicht beachtet. RegEx-Muster: `^[-\w\._]+$`
subscriptionId	path	True	string	Hierbei handelt es sich um die ID des Zielabonnements.
api-version	query	True	string	Hierbei handelt es sich um die für diesen Vorgang zu verwendende API-Version.

Anforderungsheader

Name	Erforderlich	Typ	Beschreibung
If-Match		string	Das ETag der Eingabe. Lassen Sie diesen Wert weg, um die aktuelle Eingabe immer zu überschreiben. Geben Sie den zuletzt angezeigten ETag-Wert an, um das versehentliche Überschreiben gleichzeitiger Änderungen zu verhindern.

Anforderungstext

Name	Typ	Beschreibung
name	string	Ressourcenname
properties	InputProperties: StreamInputProperties ReferenceInputProperties	Die Eigenschaften, die einer Eingabe zugeordnet sind. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Antworten

Name	Typ	Beschreibung
200 OK	Input	Die Eingabe wurde erfolgreich aktualisiert. Header ETag: string
Other Status Codes	Error	Fehler.

Name

Typ

Beschreibung

200 OK

Input

Die Eingabe wurde erfolgreich aktualisiert.

Header

ETag: string

Other Status Codes

Error

Fehler.

Sicherheit

azure_auth

Azure Active Directory-OAuth2-Flow

Typ: oauth2
Ablauf: implicit
Autorisierungs-URL: https://login.microsoftonline.com/common/oauth2/authorize

Bereiche

Name	Beschreibung
user_impersonation	Identitätswechsel Ihres Benutzerkontos

Beispiele

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

Beispielanforderung

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


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

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

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

Beispiel für eine Antwort

Statuscode:: 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

Beispielanforderung

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


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

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

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

Beispiel für eine Antwort

Statuscode:: 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

Beispielanforderung

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


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

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

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

Beispiel für eine Antwort

Statuscode:: 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

Beispielanforderung

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


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

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

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

Beispiel für eine Antwort

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

Definitionen

Name	Beschreibung
AuthenticationMode	Authentifizierungsmodus. Gültige Modi sind `ConnectionString`, `Msi` und "UserToken".
AvroSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im Avro-Format geschrieben werden.
AzureSqlReferenceInputDataSource	Beschreibt eine Azure SQL Datenbankreferenzeingabedatenquelle.
BlobReferenceInputDataSource	Beschreibt eine Blobeingabedatenquelle, die Verweisdaten enthält.
BlobStreamInputDataSource	Beschreibt eine Blobeingabedatenquelle, die Streamdaten enthält.
Compression	Beschreibt, wie Eingabedaten komprimiert werden.
CompressionType	Gibt den Komprimierungstyp an, den die Eingabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).
CsvSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im CSV-Format geschrieben werden.
DiagnosticCondition	Bedingung für die Ressource oder den Auftrag insgesamt, die die Aufmerksamkeit des Kunden rechtfertigen.
Diagnostics	Beschreibt Bedingungen für die Eingabe, Ausgabe oder den Auftrag insgesamt, die die Aufmerksamkeit des Kunden erfordern.
Encoding	Gibt die Codierung der eingehenden Daten im Falle einer Eingabe und die Codierung ausgehender Daten im Fall der Ausgabe an.
Error	Häufige Fehlerdarstellung.
EventHubStreamInputDataSource	Beschreibt eine Event Hub-Eingabedatenquelle, die Streamdaten enthält.
EventHubV2StreamInputDataSource	Beschreibt eine Event Hub-Eingabedatenquelle, die Streamdaten enthält.
EventSerializationType	Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).
FileReferenceInputDataSource	Beschreibt eine Dateieingabedatenquelle, die Verweisdaten enthält.
GatewayMessageBusStreamInputDataSource	Beschreibt eine Blobeingabedatenquelle, die Streamdaten enthält.
Input	Ein Eingabeobjekt, das alle Informationen enthält, die der benannten Eingabe zugeordnet sind. Alle Eingaben sind unter einem Streamingauftrag enthalten.
IoTHubStreamInputDataSource	Beschreibt eine IoT Hub Eingabedatenquelle, die Streamdaten enthält.
JsonOutputSerializationFormat	Gibt das Format des JSON-Codes an, in das die Ausgabe geschrieben wird. Die derzeit unterstützten Werte sind "lineSeparated", was angibt, dass die Ausgabe formatiert wird, indem jedes JSON-Objekt durch eine neue Zeile und "Array" getrennt wird, was angibt, dass die Ausgabe als Array von JSON-Objekten formatiert wird.
JsonSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie im JSON-Format in eine Ausgabe geschrieben werden.
ParquetSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im Parquet-Format geschrieben werden.
ReferenceInputProperties	Die Eigenschaften, die einer Eingabe zugeordnet sind, die Verweisdaten enthält.
RefreshType	Gibt den Typ der Datenaktualisierungsoption an.
StorageAccount	Die Eigenschaften, die einem Azure Storage-Konto zugeordnet sind
StreamInputProperties	Die Eigenschaften, die einer Eingabe zugeordnet sind, die Datenstromdaten enthält.

AuthenticationMode

Authentifizierungsmodus. Gültige Modi sind ConnectionString, Msi und "UserToken".

Name	Typ	Beschreibung
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im Avro-Format geschrieben werden.

Name	Typ	Beschreibung
type	string: Avro	Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).

AzureSqlReferenceInputDataSource

Beschreibt eine Azure SQL Datenbankreferenzeingabedatenquelle.

Name	Typ	Beschreibung
properties.database	string	Dieses Element ist dem datasource-Element zugeordnet. Dies ist der Name der Datenbank, in die die Ausgabe geschrieben wird.
properties.deltaSnapshotQuery	string	Dieses Element ist dem datasource-Element zugeordnet. Diese Abfrage wird verwendet, um inkrementelle Änderungen aus der SQL-Datenbank abzurufen. Um diese Option zu verwenden, wird empfohlen, temporale Tabellen in Azure SQL-Datenbank zu verwenden.
properties.fullSnapshotQuery	string	Dieses Element ist dem datasource-Element zugeordnet. Diese Abfrage wird verwendet, um Daten aus der sql-Datenbank abzurufen.
properties.password	string	Dieses Element ist dem datasource-Element zugeordnet. Dies ist das Kennwort für die Verbindung mit der SQL-Datenbankinstanz.
properties.refreshRate	string	Dieses Element ist dem datasource-Element zugeordnet. Dies gibt an, wie häufig die Daten aus der Datenbank abgerufen werden. Es hat das DateTime-Format.
properties.refreshType	RefreshType	Gibt den Typ der Datenaktualisierungsoption an.
properties.server	string	Dieses Element ist dem datasource-Element zugeordnet. Dies ist der Name des Servers, der die Datenbank enthält, in die geschrieben wird.
properties.table	string	Dieses Element ist dem datasource-Element zugeordnet. Der Name der Tabelle in der Azure SQL-Datenbank..
properties.user	string	Dieses Element ist dem datasource-Element zugeordnet. Dies ist der Benutzername, der für die Verbindung mit der SQL-Datenbankinstanz verwendet wird.
type	string: Microsoft.Sql/Server/Database	Gibt den Typ der Eingabedatenquelle an, die Verweisdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

BlobReferenceInputDataSource

Beschreibt eine Blobeingabedatenquelle, die Verweisdaten enthält.

Name	Typ	Standardwert	Beschreibung
properties.authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.container	string		Der Name eines Containers innerhalb des zugeordneten Speicherkontos. Dieser Container enthält entweder die Blobs, aus dem gelesen oder geschrieben werden sollen. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.dateFormat	string		Das Datumsformat, Überall, wo {date} in pathPattern angezeigt wird, wird stattdessen der Wert dieser Eigenschaft als Datumsformat verwendet.
properties.pathPattern	string		Das Blobpfadmuster. Kein regulärer Ausdruck. Es stellt ein Muster dar, mit dem Blobnamen abgeglichen werden, um zu bestimmen, ob sie als Eingabe oder Ausgabe in den Auftrag einbezogen werden sollen oder nicht. Eine ausführlichere Erklärung und ein Beispiel finden Sie unter https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input oder https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output .
properties.storageAccounts	StorageAccount[]		Eine Liste mit mindestens einem Azure Storage-Konto. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.timeFormat	string		Das Zeitformat. Unabhängig davon, wo {time} in pathPattern angezeigt wird, wird der Wert dieser Eigenschaft stattdessen als Zeitformat verwendet.
type	string: Microsoft.Storage/Blob		Gibt den Typ der Eingabedatenquelle an, die Verweisdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

BlobStreamInputDataSource

Beschreibt eine Blobeingabedatenquelle, die Streamdaten enthält.

Name	Typ	Standardwert	Beschreibung
properties.authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.container	string		Der Name eines Containers innerhalb des zugeordneten Speicherkontos. Dieser Container enthält entweder die Blobs, aus dem gelesen oder geschrieben werden sollen. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.dateFormat	string		Das Datumsformat, Überall, wo {date} in pathPattern angezeigt wird, wird stattdessen der Wert dieser Eigenschaft als Datumsformat verwendet.
properties.pathPattern	string		Das Blobpfadmuster. Kein regulärer Ausdruck. Es stellt ein Muster dar, mit dem Blobnamen abgeglichen werden, um zu bestimmen, ob sie als Eingabe oder Ausgabe in den Auftrag einbezogen werden sollen oder nicht. Eine ausführlichere Erklärung und ein Beispiel finden Sie unter https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input oder https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output .
properties.sourcePartitionCount	integer		Die Partitionsanzahl der Blobeingabedatenquelle. Bereich 1 - 1024.
properties.storageAccounts	StorageAccount[]		Eine Liste mit mindestens einem Azure Storage-Konto. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.timeFormat	string		Das Zeitformat. Unabhängig davon, wo {time} in pathPattern angezeigt wird, wird der Wert dieser Eigenschaft stattdessen als Zeitformat verwendet.
type	string: Microsoft.Storage/Blob		Gibt den Typ der Eingabedatenquelle an, die Datenstromdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Compression

Beschreibt, wie Eingabedaten komprimiert werden.

Name	Typ	Standardwert	Beschreibung
type	CompressionType	None	Gibt den Komprimierungstyp an, den die Eingabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).

CompressionType

Gibt den Komprimierungstyp an, den die Eingabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Name	Typ	Beschreibung
Deflate	string
GZip	string
None	string

CsvSerialization

Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im CSV-Format geschrieben werden.

Name	Typ	Beschreibung
properties.encoding	Encoding	Gibt die Codierung der eingehenden Daten im Falle einer Eingabe und die Codierung ausgehender Daten im Fall der Ausgabe an. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.fieldDelimiter	string	Gibt das Trennzeichen an, das zum Trennen von CSV-Datensätzen (Durch Trennzeichen getrennte Werte) verwendet wird. Eine Liste der unterstützten Werte finden Sie unter https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input oder https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output . Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Csv	Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).

DiagnosticCondition

Bedingung für die Ressource oder den Auftrag insgesamt, die die Aufmerksamkeit des Kunden rechtfertigen.

Name	Typ	Beschreibung
code	string	Der undurchsichtige Diagnosecode.
message	string	Die für Menschen lesbare Nachricht, die die Bedingung ausführlich beschreibt. Lokalisiert im Accept-Language der Clientanforderung.
since	string	Der UTC-Zeitstempel des Startpunkts der Bedingung. Kunden sollten zu diesem Zeitpunkt ein entsprechendes Ereignis im Ops-Protokoll finden können.

Diagnostics

Beschreibt Bedingungen für die Eingabe, Ausgabe oder den Auftrag insgesamt, die die Aufmerksamkeit des Kunden erfordern.

Name	Typ	Beschreibung
conditions	DiagnosticCondition[]	Eine Sammlung von null oder mehr Bedingungen, die für die Ressource oder den Auftrag insgesamt gelten und die die Aufmerksamkeit des Kunden rechtfertigen.

Encoding

Gibt die Codierung der eingehenden Daten im Falle einer Eingabe und die Codierung ausgehender Daten im Fall der Ausgabe an.

Name	Typ	Beschreibung
UTF8	string

Error

Häufige Fehlerdarstellung.

Name	Typ	Beschreibung
error	Error	Fehlerdefinitionseigenschaften.

EventHubStreamInputDataSource

Beschreibt eine Event Hub-Eingabedatenquelle, die Streamdaten enthält.

Name	Typ	Standardwert	Beschreibung
authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.consumerGroupName	string		Der Name einer Event Hub-Consumergruppe, die zum Lesen von Ereignissen aus dem Event Hub verwendet werden soll. Wenn Sie verschiedene Consumergruppennamen für mehrere Eingaben angeben, kann jede dieser Eingaben dieselben Ereignisse vom Event Hub empfangen. Falls nicht angegeben, verwendet die Eingabe die Standard-Consumergruppe des Event Hubs.
properties.eventHubName	string		Der Name des Event Hubs. Erforderlich für PUT-Anforderungen (CreateOrReplace).
serviceBusNamespace	string		Der Namespace, der dem gewünschten Event Hub, der Service Bus-Warteschlange, dem Service Bus-Thema usw. zugeordnet ist. Erforderlich für PUT-Anforderungen (CreateOrReplace).
sharedAccessPolicyKey	string		Der Shared Access Policy Key für die angegebene Shared Access-Richtlinie. Erforderlich für PUT-Anforderungen (CreateOrReplace).
sharedAccessPolicyName	string		Der Name der Shared Access-Richtlinie für den Event Hub, Die Service Bus-Warteschlange, das Service Bus-Thema usw. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Gibt den Typ der Eingabedatenquelle an, die Datenstromdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

EventHubV2StreamInputDataSource

Beschreibt eine Event Hub-Eingabedatenquelle, die Streamdaten enthält.

Name	Typ	Standardwert	Beschreibung
authenticationMode	AuthenticationMode	ConnectionString	Authentifizierungsmodus.
properties.consumerGroupName	string		Der Name einer Event Hub-Consumergruppe, die zum Lesen von Ereignissen aus dem Event Hub verwendet werden soll. Wenn Sie verschiedene Consumergruppennamen für mehrere Eingaben angeben, kann jede dieser Eingaben dieselben Ereignisse vom Event Hub empfangen. Falls nicht angegeben, verwendet die Eingabe die Standard-Consumergruppe des Event Hubs.
properties.eventHubName	string		Der Name des Event Hubs. Erforderlich für PUT-Anforderungen (CreateOrReplace).
serviceBusNamespace	string		Der Namespace, der dem gewünschten Event Hub, der Service Bus-Warteschlange, dem Service Bus-Thema usw. zugeordnet ist. Erforderlich für PUT-Anforderungen (CreateOrReplace).
sharedAccessPolicyKey	string		Der Shared Access Policy Key für die angegebene Shared Access-Richtlinie. Erforderlich für PUT-Anforderungen (CreateOrReplace).
sharedAccessPolicyName	string		Der Name der Shared Access-Richtlinie für den Event Hub, Die Service Bus-Warteschlange, das Service Bus-Thema usw. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Gibt den Typ der Eingabedatenquelle an, die Datenstromdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

EventSerializationType

Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Name	Typ	Beschreibung
Avro	string
Csv	string
Json	string
Parquet	string

FileReferenceInputDataSource

Beschreibt eine Dateieingabedatenquelle, die Verweisdaten enthält.

Name	Typ	Beschreibung
properties.path	string	Der Pfad der Datei.
type	string: File	Gibt den Typ der Eingabedatenquelle an, die Verweisdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Beschreibt eine Blobeingabedatenquelle, die Streamdaten enthält.

Name	Typ	Beschreibung
properties.topic	string	Der Name des Service Bus-Themas.
type	string: GatewayMessageBus	Gibt den Typ der Eingabedatenquelle an, die Datenstromdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Input

Ein Eingabeobjekt, das alle Informationen enthält, die der benannten Eingabe zugeordnet sind. Alle Eingaben sind unter einem Streamingauftrag enthalten.

Name	Typ	Beschreibung
id	string	Ressourcen-ID
name	string	Ressourcenname
properties	InputProperties: ReferenceInputProperties StreamInputProperties	Die Eigenschaften, die einer Eingabe zugeordnet sind. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string	Ressourcentyp

IoTHubStreamInputDataSource

Beschreibt eine IoT Hub Eingabedatenquelle, die Streamdaten enthält.

Name	Typ	Beschreibung
properties.consumerGroupName	string	Der Name einer IoT Hub Consumergruppe, die zum Lesen von Ereignissen aus dem IoT Hub verwendet werden soll. Falls nicht angegeben, verwendet die Eingabe die Standard-Consumergruppe von Iot Hub.
properties.endpoint	string	Der IoT Hub Endpunkt, mit dem eine Verbindung hergestellt werden soll (z. B. Nachrichten/Ereignisse, Nachrichten/VorgängeMonitoringEvents usw.).
properties.iotHubNamespace	string	Der Name oder der URI des IoT Hub. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.sharedAccessPolicyKey	string	Der Shared Access Policy Key für die angegebene Shared Access-Richtlinie. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.sharedAccessPolicyName	string	Der Name der Shared Access-Richtlinie für die IoT Hub. Diese Richtlinie muss mindestens die Berechtigung Dienstverbindung enthalten. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Gibt den Typ der Eingabedatenquelle an, die Datenstromdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).

JsonOutputSerializationFormat

Gibt das Format des JSON-Codes an, in das die Ausgabe geschrieben wird. Die derzeit unterstützten Werte sind "lineSeparated", was angibt, dass die Ausgabe formatiert wird, indem jedes JSON-Objekt durch eine neue Zeile und "Array" getrennt wird, was angibt, dass die Ausgabe als Array von JSON-Objekten formatiert wird.

Name	Typ	Beschreibung
Array	string
LineSeparated	string

JsonSerialization

Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie im JSON-Format in eine Ausgabe geschrieben werden.

Name	Typ	Beschreibung
properties.encoding	Encoding	Gibt die Codierung der eingehenden Daten im Falle einer Eingabe und die Codierung ausgehender Daten im Fall der Ausgabe an. Erforderlich für PUT-Anforderungen (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Diese Eigenschaft gilt nur für die JSON-Serialisierung von Ausgaben. Sie gilt nicht für Eingaben. Diese Eigenschaft gibt das Format des JSON-Codes an, in das die Ausgabe geschrieben wird. Die derzeit unterstützten Werte sind "lineSeparated", was angibt, dass die Ausgabe formatiert wird, indem jedes JSON-Objekt durch eine neue Zeile und "Array" getrennt wird, was angibt, dass die Ausgabe als Array von JSON-Objekten formatiert wird. Der Standardwert ist "lineSeparated", wenn null verlassen wird.
type	string: Json	Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).

ParquetSerialization

Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe im Parquet-Format geschrieben werden.

Name	Typ	Beschreibung
type	string: Parquet	Gibt den Typ der Serialisierung an, den die Eingabe oder Ausgabe verwendet. Erforderlich für PUT-Anforderungen (CreateOrReplace).

ReferenceInputProperties

Die Eigenschaften, die einer Eingabe zugeordnet sind, die Verweisdaten enthält.

Name	Typ	Beschreibung
compression	Compression	Beschreibt, wie Eingabedaten komprimiert werden.
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Beschreibt eine Eingabedatenquelle, die Verweisdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).
diagnostics	Diagnostics	Beschreibt Bedingungen für die Eingabe, Ausgabe oder den Auftrag insgesamt, die die Aufmerksamkeit des Kunden erfordern.
etag	string	Das aktuelle Entitätstag für die Eingabe. Dies ist eine undurchsichtige Zeichenfolge. Sie können sie verwenden, um zu erkennen, ob sich die Ressource zwischen Anforderungen geändert hat. Sie können es auch im If-Match- oder If-None-Match-Header für Schreibvorgänge für optimistische Parallelität verwenden.
partitionKey	string	partitionKey Beschreibt einen Schlüssel in den Eingabedaten, der zum Partitionieren der Eingabedaten verwendet wird.
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe geschrieben werden. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Reference	Gibt an, ob die Eingabe eine Quelle für Verweisdaten oder Streamdaten ist. Erforderlich für PUT-Anforderungen (CreateOrReplace).

RefreshType

Gibt den Typ der Datenaktualisierungsoption an.

Name	Typ	Beschreibung
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

StorageAccount

Die Eigenschaften, die einem Azure Storage-Konto zugeordnet sind

Name	Typ	Beschreibung
accountKey	string	Der Kontoschlüssel für das Azure Storage-Konto. Erforderlich für PUT-Anforderungen (CreateOrReplace).
accountName	string	Der Name des Azure Storage-Kontos. Erforderlich für PUT-Anforderungen (CreateOrReplace).

StreamInputProperties

Die Eigenschaften, die einer Eingabe zugeordnet sind, die Datenstromdaten enthält.

Name	Typ	Beschreibung
compression	Compression	Beschreibt, wie Eingabedaten komprimiert werden.
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Beschreibt eine Eingabedatenquelle, die Streamdaten enthält. Erforderlich für PUT-Anforderungen (CreateOrReplace).
diagnostics	Diagnostics	Beschreibt Bedingungen für die Eingabe, Ausgabe oder den Auftrag insgesamt, die die Aufmerksamkeit des Kunden erfordern.
etag	string	Das aktuelle Entitätstag für die Eingabe. Dies ist eine undurchsichtige Zeichenfolge. Sie können sie verwenden, um zu erkennen, ob sich die Ressource zwischen Anforderungen geändert hat. Sie können es auch im If-Match- oder If-None-Match-Header für Schreibvorgänge für optimistische Parallelität verwenden.
partitionKey	string	partitionKey Beschreibt einen Schlüssel in den Eingabedaten, der zum Partitionieren der Eingabedaten verwendet wird.
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beschreibt, wie Daten aus einer Eingabe serialisiert werden oder wie Daten serialisiert werden, wenn sie in eine Ausgabe geschrieben werden. Erforderlich für PUT-Anforderungen (CreateOrReplace).
type	string: Stream	Gibt an, ob die Eingabe eine Quelle für Verweisdaten oder Streamdaten ist. Erforderlich für PUT-Anforderungen (CreateOrReplace).

Freigeben über

Inputs - Update

URI-Parameter

Anforderungsheader

Anforderungstext

Antworten

Sicherheit

azure_auth

Bereiche

Beispiele

Update a reference blob input

Beispielanforderung

Beispiel für eine Antwort

Update a stream blob input

Beispielanforderung

Beispiel für eine Antwort

Update a stream Event Hub input

Beispielanforderung

Beispiel für eine Antwort

Update a stream IoT Hub input

Beispielanforderung

Beispiel für eine Antwort

Definitionen

AuthenticationMode

AvroSerialization

AzureSqlReferenceInputDataSource

BlobReferenceInputDataSource

BlobStreamInputDataSource

Compression

CompressionType

CsvSerialization

DiagnosticCondition

Diagnostics

Encoding

Error

EventHubStreamInputDataSource

EventHubV2StreamInputDataSource

EventSerializationType

FileReferenceInputDataSource

GatewayMessageBusStreamInputDataSource

Input

IoTHubStreamInputDataSource

JsonOutputSerializationFormat

JsonSerialization

ParquetSerialization

ReferenceInputProperties

RefreshType

StorageAccount

StreamInputProperties

Zusätzliche Ressourcen