Inputs - Create Or Replace

Service:

Stream Analytics

API Version:

2020-03-01

Erstellt eine Eingabe oder ersetzt eine bereits vorhandene Eingabe unter einem vorhandenen Streamingauftrag.

PUT 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 pattern: ^[-\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.
If-None-Match		string	Legen Sie auf "*" fest, um das Erstellen einer neuen Eingabe zu ermöglichen, aber zu verhindern, dass eine vorhandene Eingabe aktualisiert wird. Andere Werte führen zu einer Antwort vom Typ 412 Pre-condition Failed .

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 erstellt oder ersetzt. Headers ETag: string
201 Created	Input	Die Eingabe wurde erfolgreich erstellt oder ersetzt. Headers ETag: string
Other Status Codes	Error	Fehler.

Sicherheit

azure_auth

Azure Active Directory-OAuth2-Flow

Type: oauth2
Flow: implicit
Authorization URL: https://login.microsoftonline.com/common/oauth2/authorize

Scopes

Name	Beschreibung
user_impersonation	Identitätswechsel Ihres Benutzerkontos

Beispiele

Create a Gateway Message Bus input

Create a reference blob input with CSV serialization

Create a reference file input

Create a stream blob input with CSV serialization

Create a stream Event Hub input with JSON serialization

Create a stream IoT Hub input with Avro serialization

Create a Gateway Message Bus input

Sample Request

HTTP

PUT 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": "GatewayMessageBus",
      "properties": {
        "topic": "EdgeTopic1"
      }
    }
  }
}

Java

No code sample is available. To request a code sample, open a GitHub issue

Go

No code sample is available. To request a code sample, open a GitHub issue

JavaScript

No code sample is available. To request a code sample, open a GitHub issue

Sample Response

Status code:

201

ETag: bd8009b3-8165-4bd3-aad2-29a2b378dd14

Response Body

{
  "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": "GatewayMessageBus",
      "properties": {
        "topic": "EdgeTopic1"
      }
    }
  }
}

Status code:

200

ETag: bd8009b3-8165-4bd3-aad2-29a2b378dd14

Response Body

{
  "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": "GatewayMessageBus",
      "properties": {
        "topic": "EdgeTopic1"
      }
    }
  }
}

Create a reference blob input with CSV serialization

Sample Request

HTTP

PUT 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": {
        "storageAccounts": [
          {
            "accountName": "someAccountName",
            "accountKey": "someAccountKey=="
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

Java

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

/** Samples for Inputs CreateOrReplace. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Reference_Blob_CSV.json
     */
    /**
     * Sample code: Create a reference blob input with CSV serialization.
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void createAReferenceBlobInputWithCSVSerialization(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager
            .inputs()
            .define("input7225")
            .withExistingStreamingjob("sjrg8440", "sj9597")
            .withProperties(
                new ReferenceInputProperties()
                    .withSerialization(new CsvSerialization().withFieldDelimiter(",").withEncoding(Encoding.UTF8))
                    .withDatasource(new BlobReferenceInputDataSource()))
            .create();
    }
}

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_Create_Reference_Blob_CSV.json
func ExampleInputsClient_CreateOrReplace_createAReferenceBlobInputWithCsvSerialization() {
	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().CreateOrReplace(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("state"),
					DateFormat:  to.Ptr("yyyy/MM/dd"),
					PathPattern: to.Ptr("{date}/{time}"),
					StorageAccounts: []*armstreamanalytics.StorageAccount{
						{
							AccountKey:  to.Ptr("someAccountKey=="),
							AccountName: to.Ptr("someAccountName"),
						}},
					TimeFormat: to.Ptr("HH"),
				},
			},
		},
	}, &armstreamanalytics.InputsClientCreateOrReplaceOptions{IfMatch: nil,
		IfNoneMatch: 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("state"),
	// 				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 Creates an input or replaces an already existing input under an existing streaming job.
 *
 * @summary Creates an input or replaces an already existing input under an existing streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Reference_Blob_CSV.json
 */
async function createAReferenceBlobInputWithCsvSerialization() {
  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: "state",
        dateFormat: "yyyy/MM/dd",
        pathPattern: "{date}/{time}",
        storageAccounts: [{ accountKey: "someAccountKey==", accountName: "someAccountName" }],
        timeFormat: "HH",
      },
      serialization: { type: "Csv", encoding: "UTF8", fieldDelimiter: "," },
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.createOrReplace(resourceGroupName, jobName, inputName, input);
  console.log(result);
}

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

Sample Response

Status code:

201

ETag: c987701d-4039-47aa-a115-ad84f67d07c5

Response Body

{
  "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": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

Status code:

200

ETag: c987701d-4039-47aa-a115-ad84f67d07c5

Response Body

{
  "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": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

Create a reference file input

Sample Request

HTTP

PUT 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": "File",
      "properties": {
        "path": "my/path"
      }
    }
  }
}

Java

No code sample is available. To request a code sample, open a GitHub issue

Go

No code sample is available. To request a code sample, open a GitHub issue

JavaScript

No code sample is available. To request a code sample, open a GitHub issue

Sample Response

Status code:

201

ETag: c987701d-4039-47aa-a115-ad84f67d07c5

Response Body

{
  "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": "File",
      "properties": {
        "path": "my/path"
      }
    }
  }
}

Status code:

200

ETag: c987701d-4039-47aa-a115-ad84f67d07c5

Response Body

{
  "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": "File",
      "properties": {
        "path": "my/path"
      }
    }
  }
}

Create a stream blob input with CSV serialization

Sample Request

HTTP

PUT 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": {
        "storageAccounts": [
          {
            "accountName": "someAccountName",
            "accountKey": "someAccountKey=="
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH",
        "sourcePartitionCount": 16
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

Java

import com.azure.resourcemanager.streamanalytics.models.BlobStreamInputDataSource;
import com.azure.resourcemanager.streamanalytics.models.CsvSerialization;
import com.azure.resourcemanager.streamanalytics.models.Encoding;
import com.azure.resourcemanager.streamanalytics.models.StorageAccount;
import com.azure.resourcemanager.streamanalytics.models.StreamInputProperties;
import java.util.Arrays;

/** Samples for Inputs CreateOrReplace. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_Blob_CSV.json
     */
    /**
     * Sample code: Create a stream blob input with CSV serialization.
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void createAStreamBlobInputWithCSVSerialization(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager
            .inputs()
            .define("input8899")
            .withExistingStreamingjob("sjrg8161", "sj6695")
            .withProperties(
                new StreamInputProperties()
                    .withSerialization(new CsvSerialization().withFieldDelimiter(",").withEncoding(Encoding.UTF8))
                    .withDatasource(
                        new BlobStreamInputDataSource()
                            .withSourcePartitionCount(16)
                            .withStorageAccounts(
                                Arrays
                                    .asList(
                                        new StorageAccount()
                                            .withAccountName("someAccountName")
                                            .withAccountKey("someAccountKey==")))
                            .withContainer("state")
                            .withPathPattern("{date}/{time}")
                            .withDateFormat("yyyy/MM/dd")
                            .withTimeFormat("HH")))
            .create();
    }
}

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_Create_Stream_Blob_CSV.json
func ExampleInputsClient_CreateOrReplace_createAStreamBlobInputWithCsvSerialization() {
	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().CreateOrReplace(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{
					Container:   to.Ptr("state"),
					DateFormat:  to.Ptr("yyyy/MM/dd"),
					PathPattern: to.Ptr("{date}/{time}"),
					StorageAccounts: []*armstreamanalytics.StorageAccount{
						{
							AccountKey:  to.Ptr("someAccountKey=="),
							AccountName: to.Ptr("someAccountName"),
						}},
					TimeFormat:           to.Ptr("HH"),
					SourcePartitionCount: to.Ptr[int32](16),
				},
			},
		},
	}, &armstreamanalytics.InputsClientCreateOrReplaceOptions{IfMatch: nil,
		IfNoneMatch: 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](16),
	// 			},
	// 		},
	// 	},
	// }
}

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 Creates an input or replaces an already existing input under an existing streaming job.
 *
 * @summary Creates an input or replaces an already existing input under an existing streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_Blob_CSV.json
 */
async function createAStreamBlobInputWithCsvSerialization() {
  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",
        container: "state",
        dateFormat: "yyyy/MM/dd",
        pathPattern: "{date}/{time}",
        sourcePartitionCount: 16,
        storageAccounts: [{ accountKey: "someAccountKey==", accountName: "someAccountName" }],
        timeFormat: "HH",
      },
      serialization: { type: "Csv", encoding: "UTF8", fieldDelimiter: "," },
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.createOrReplace(resourceGroupName, jobName, inputName, input);
  console.log(result);
}

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

Sample Response

Status code:

201

ETag: 475074b8-c957-4b1f-a219-12b8399c3d4c

Response Body

{
  "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": 16,
        "storageAccounts": [
          {
            "accountName": "someAccountName"
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

Status code:

200

ETag: 475074b8-c957-4b1f-a219-12b8399c3d4c

Response Body

{
  "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": 16,
        "storageAccounts": [
          {
            "accountName": "someAccountName"
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

Create a stream Event Hub input with JSON serialization

Sample Request

HTTP

PUT 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": {
        "serviceBusNamespace": "sdktest",
        "sharedAccessPolicyName": "RootManageSharedAccessKey",
        "sharedAccessPolicyKey": "someSharedAccessPolicyKey==",
        "eventHubName": "sdkeventhub",
        "consumerGroupName": "sdkconsumergroup"
      }
    },
    "serialization": {
      "type": "Json",
      "properties": {
        "encoding": "UTF8"
      }
    }
  }
}

Java

import com.azure.resourcemanager.streamanalytics.models.Encoding;
import com.azure.resourcemanager.streamanalytics.models.EventHubStreamInputDataSource;
import com.azure.resourcemanager.streamanalytics.models.JsonSerialization;
import com.azure.resourcemanager.streamanalytics.models.StreamInputProperties;

/** Samples for Inputs CreateOrReplace. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_EventHub_JSON.json
     */
    /**
     * Sample code: Create a stream Event Hub input with JSON serialization.
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void createAStreamEventHubInputWithJSONSerialization(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager
            .inputs()
            .define("input7425")
            .withExistingStreamingjob("sjrg3139", "sj197")
            .withProperties(
                new StreamInputProperties()
                    .withSerialization(new JsonSerialization().withEncoding(Encoding.UTF8))
                    .withDatasource(
                        new EventHubStreamInputDataSource()
                            .withConsumerGroupName("sdkconsumergroup")
                            .withEventHubName("sdkeventhub")
                            .withServiceBusNamespace("sdktest")
                            .withSharedAccessPolicyName("RootManageSharedAccessKey")
                            .withSharedAccessPolicyKey("someSharedAccessPolicyKey==")))
            .create();
    }
}

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_Create_Stream_EventHub_JSON.json
func ExampleInputsClient_CreateOrReplace_createAStreamEventHubInputWithJsonSerialization() {
	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().CreateOrReplace(ctx, "sjrg3139", "sj197", "input7425", armstreamanalytics.Input{
		Properties: &armstreamanalytics.StreamInputProperties{
			Type: to.Ptr("Stream"),
			Serialization: &armstreamanalytics.JSONSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
				Properties: &armstreamanalytics.JSONSerializationProperties{
					Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
				},
			},
			Datasource: &armstreamanalytics.EventHubStreamInputDataSource{
				Type: to.Ptr("Microsoft.ServiceBus/EventHub"),
				Properties: &armstreamanalytics.EventHubStreamInputDataSourceProperties{
					ServiceBusNamespace:    to.Ptr("sdktest"),
					SharedAccessPolicyKey:  to.Ptr("someSharedAccessPolicyKey=="),
					SharedAccessPolicyName: to.Ptr("RootManageSharedAccessKey"),
					EventHubName:           to.Ptr("sdkeventhub"),
					ConsumerGroupName:      to.Ptr("sdkconsumergroup"),
				},
			},
		},
	}, &armstreamanalytics.InputsClientCreateOrReplaceOptions{IfMatch: nil,
		IfNoneMatch: 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.JSONSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
	// 			Properties: &armstreamanalytics.JSONSerializationProperties{
	// 				Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
	// 			},
	// 		},
	// 		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("sdkconsumergroup"),
	// 			},
	// 		},
	// 	},
	// }
}

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 Creates an input or replaces an already existing input under an existing streaming job.
 *
 * @summary Creates an input or replaces an already existing input under an existing streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_EventHub_JSON.json
 */
async function createAStreamEventHubInputWithJsonSerialization() {
  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: "sdkconsumergroup",
        eventHubName: "sdkeventhub",
        serviceBusNamespace: "sdktest",
        sharedAccessPolicyKey: "someSharedAccessPolicyKey==",
        sharedAccessPolicyName: "RootManageSharedAccessKey",
      },
      serialization: { type: "Json", encoding: "UTF8" },
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.createOrReplace(resourceGroupName, jobName, inputName, input);
  console.log(result);
}

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

Sample Response

Status code:

201

ETag: afd0d184-37e9-4370-9e55-32501bc4de3a

Response Body

{
  "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": "sdkconsumergroup",
        "serviceBusNamespace": "sdktest",
        "sharedAccessPolicyName": "RootManageSharedAccessKey"
      }
    },
    "serialization": {
      "type": "Json",
      "properties": {
        "encoding": "UTF8"
      }
    }
  }
}

Status code:

200

ETag: afd0d184-37e9-4370-9e55-32501bc4de3a

Response Body

{
  "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": "sdkconsumergroup",
        "serviceBusNamespace": "sdktest",
        "sharedAccessPolicyName": "RootManageSharedAccessKey"
      }
    },
    "serialization": {
      "type": "Json",
      "properties": {
        "encoding": "UTF8"
      }
    }
  }
}

Create a stream IoT Hub input with Avro serialization

Sample Request

HTTP

PUT 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": {
        "iotHubNamespace": "iothub",
        "sharedAccessPolicyName": "owner",
        "sharedAccessPolicyKey": "sharedAccessPolicyKey=",
        "consumerGroupName": "sdkconsumergroup",
        "endpoint": "messages/events"
      }
    },
    "serialization": {
      "type": "Avro"
    }
  }
}

Java

import com.azure.resourcemanager.streamanalytics.models.AvroSerialization;
import com.azure.resourcemanager.streamanalytics.models.IoTHubStreamInputDataSource;
import com.azure.resourcemanager.streamanalytics.models.StreamInputProperties;

/** Samples for Inputs CreateOrReplace. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_IoTHub_Avro.json
     */
    /**
     * Sample code: Create a stream IoT Hub input with Avro serialization.
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void createAStreamIoTHubInputWithAvroSerialization(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager
            .inputs()
            .define("input7970")
            .withExistingStreamingjob("sjrg3467", "sj9742")
            .withProperties(
                new StreamInputProperties()
                    .withSerialization(new AvroSerialization())
                    .withDatasource(
                        new IoTHubStreamInputDataSource()
                            .withIotHubNamespace("iothub")
                            .withSharedAccessPolicyName("owner")
                            .withSharedAccessPolicyKey("sharedAccessPolicyKey=")
                            .withConsumerGroupName("sdkconsumergroup")
                            .withEndpoint("messages/events")))
            .create();
    }
}

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_Create_Stream_IoTHub_Avro.json
func ExampleInputsClient_CreateOrReplace_createAStreamIoTHubInputWithAvroSerialization() {
	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().CreateOrReplace(ctx, "sjrg3467", "sj9742", "input7970", armstreamanalytics.Input{
		Properties: &armstreamanalytics.StreamInputProperties{
			Type: to.Ptr("Stream"),
			Serialization: &armstreamanalytics.AvroSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeAvro),
			},
			Datasource: &armstreamanalytics.IoTHubStreamInputDataSource{
				Type: to.Ptr("Microsoft.Devices/IotHubs"),
				Properties: &armstreamanalytics.IoTHubStreamInputDataSourceProperties{
					ConsumerGroupName:      to.Ptr("sdkconsumergroup"),
					Endpoint:               to.Ptr("messages/events"),
					IotHubNamespace:        to.Ptr("iothub"),
					SharedAccessPolicyKey:  to.Ptr("sharedAccessPolicyKey="),
					SharedAccessPolicyName: to.Ptr("owner"),
				},
			},
		},
	}, &armstreamanalytics.InputsClientCreateOrReplaceOptions{IfMatch: nil,
		IfNoneMatch: 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.AvroSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeAvro),
	// 			Properties: map[string]any{
	// 			},
	// 		},
	// 		Datasource: &armstreamanalytics.IoTHubStreamInputDataSource{
	// 			Type: to.Ptr("Microsoft.Devices/IotHubs"),
	// 			Properties: &armstreamanalytics.IoTHubStreamInputDataSourceProperties{
	// 				ConsumerGroupName: to.Ptr("sdkconsumergroup"),
	// 				Endpoint: to.Ptr("messages/events"),
	// 				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 Creates an input or replaces an already existing input under an existing streaming job.
 *
 * @summary Creates an input or replaces an already existing input under an existing streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_IoTHub_Avro.json
 */
async function createAStreamIoTHubInputWithAvroSerialization() {
  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",
        consumerGroupName: "sdkconsumergroup",
        endpoint: "messages/events",
        iotHubNamespace: "iothub",
        sharedAccessPolicyKey: "sharedAccessPolicyKey=",
        sharedAccessPolicyName: "owner",
      },
      serialization: { type: "Avro" },
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.createOrReplace(resourceGroupName, jobName, inputName, input);
  console.log(result);
}

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

Sample Response

Status code:

201

ETag: bd8009b3-8165-4bd3-aad2-29a2b378dd14

Response Body

{
  "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/events",
        "consumerGroupName": "sdkconsumergroup"
      }
    },
    "serialization": {
      "type": "Avro",
      "properties": {}
    }
  }
}

Status code:

200

ETag: bd8009b3-8165-4bd3-aad2-29a2b378dd14

Response Body

{
  "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/events",
        "consumerGroupName": "sdkconsumergroup"
      }
    },
    "serialization": {
      "type": "Avro",
      "properties": {}
    }
  }
}

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