Inputs - Create Or Replace

Service:

Stream Analytics

API-versie:

2020-03-01

Hiermee maakt u een invoer of vervangt u een bestaande invoer onder een bestaande streamingtaak.

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

URI-parameters

Name	In	Vereist	Type	Description
inputName	path	True	string	De naam van de invoer.
jobName	path	True	string	De naam van de streamingtaak.
resourceGroupName	path	True	string	De naam van de resourcegroep. De naam is niet hoofdlettergevoelig. Regex-patroon: ^[-\w\._\(\)]+$
subscriptionId	path	True	string	De id van het doelabonnement.
api-version	query	True	string	De API-versie die voor deze bewerking moet worden gebruikt.

Aanvraagkoptekst

Name	Vereist	Type	Description
If-Match		string	De ETag van de invoer. Laat deze waarde weg om de huidige invoer altijd te overschrijven. Geef de laatst gezienETag-waarde op om te voorkomen dat gelijktijdige wijzigingen per ongeluk worden overschreven.
If-None-Match		string	Stel in op *om nieuwe invoer te maken, maar om te voorkomen dat een bestaande invoer wordt bijgewerkt. Andere waarden resulteren in een 412 Pre-condition Failed-antwoord.

Aanvraagbody

Name	Type	Description
name	string	Resourcenaam
properties	InputProperties: StreamInputProperties ReferenceInputProperties	De eigenschappen die zijn gekoppeld aan een invoer. Vereist voor PUT-aanvragen (CreateOrReplace).

Antwoorden

Name	Type	Description
200 OK	Input	De invoer is gemaakt of vervangen. Kopteksten ETag: string
201 Created	Input	De invoer is gemaakt of vervangen. Kopteksten ETag: string
Other Status Codes	Error	Fout.

Beveiliging

azure_auth

Azure Active Directory OAuth2-stroom

Type: oauth2
Stroom: implicit
Autorisatie-URL: https://login.microsoftonline.com/common/oauth2/authorize

Bereiken

Name	Description
user_impersonation	uw gebruikersaccount imiteren

Voorbeelden

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

Voorbeeldaanvraag

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

import com.azure.resourcemanager.streamanalytics.models.GatewayMessageBusStreamInputDataSource;
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_GatewayMessageBus.json
     */
    /**
     * Sample code: Create a Gateway Message Bus input.
     * 
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void
        createAGatewayMessageBusInput(com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager.inputs().define("input7970").withExistingStreamingjob("sjrg3467", "sj9742")
            .withProperties(new StreamInputProperties()
                .withDatasource(new GatewayMessageBusStreamInputDataSource().withTopic("EdgeTopic1")))
            .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

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

Voorbeeldrespons

Statuscode:

201

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

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

Statuscode:

200

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

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

Voorbeeldaanvraag

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;
import com.azure.resourcemanager.streamanalytics.models.StorageAccount;
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_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()
                    .withStorageAccounts(Arrays.asList(
                        new StorageAccount().withAccountName("someAccountName").withAccountKey("fakeTokenPlaceholder")))
                    .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_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

Voorbeeldrespons

Statuscode:

201

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

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

Statuscode:

200

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

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

Voorbeeldaanvraag

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

import com.azure.resourcemanager.streamanalytics.models.FileReferenceInputDataSource;
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_File.json
     */
    /**
     * Sample code: Create a reference file input.
     * 
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void
        createAReferenceFileInput(com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager.inputs().define("input7225").withExistingStreamingjob("sjrg8440", "sj9597")
            .withProperties(
                new ReferenceInputProperties().withDatasource(new FileReferenceInputDataSource().withPath("my/path")))
            .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

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

Voorbeeldrespons

Statuscode:

201

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

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

Statuscode:

200

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

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

Voorbeeldaanvraag

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("fakeTokenPlaceholder")))
                    .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

Voorbeeldrespons

Statuscode:

201

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

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

Statuscode:

200

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

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

Voorbeeldaanvraag

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("fakeTokenPlaceholder")))
            .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

Voorbeeldrespons

Statuscode:

201

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

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

Statuscode:

200

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

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

Voorbeeldaanvraag

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("fakeTokenPlaceholder")
                    .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

Voorbeeldrespons

Statuscode:

201

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

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

Statuscode:

200

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

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

Definities

Name	Description
AuthenticationMode	Verificatiemodus. Geldige modi zijn ConnectionString, Msi en 'UserToken'.
AvroSerialization	Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in Avro-indeling worden geschreven.
AzureSqlReferenceInputDataSource	Beschrijft een Azure SQL databasereferentiegegevensbron.
BlobReferenceInputDataSource	Beschrijft een blob-invoergegevensbron die referentiegegevens bevat.
BlobStreamInputDataSource	Beschrijft een blob-invoergegevensbron die stroomgegevens bevat.
Compression	Beschrijft hoe invoergegevens worden gecomprimeerd
CompressionType	Geeft het type compressie aan dat door de invoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).
CsvSerialization	Hierin wordt beschreven hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in CSV-indeling worden geschreven.
DiagnosticCondition	Voorwaarde die van toepassing is op de resource of op de taak in het algemeen, die aandacht van de klant vereist.
Diagnostics	Beschrijft voorwaarden die van toepassing zijn op de invoer, uitvoer of de taak in het algemeen, die aandacht van de klant vereisen.
Encoding	Hiermee geeft u de codering van de binnenkomende gegevens in het geval van invoer en de codering van uitgaande gegevens in het geval van uitvoer.
Error	Veelvoorkomende foutweergave.
EventHubStreamInputDataSource	Beschrijft een Event Hub-invoergegevensbron die stroomgegevens bevat.
EventHubV2StreamInputDataSource	Beschrijft een Event Hub-invoergegevensbron die stroomgegevens bevat.
EventSerializationType	Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).
FileReferenceInputDataSource	Beschrijft een bestandsinvoergegevensbron die referentiegegevens bevat.
GatewayMessageBusStreamInputDataSource	Beschrijft een blob-invoergegevensbron die stroomgegevens bevat.
Input	Een invoerobject, dat alle informatie bevat die is gekoppeld aan de benoemde invoer. Alle invoer bevindt zich onder een streamingtaak.
IoTHubStreamInputDataSource	Beschrijft een IoT Hub invoergegevensbron die stroomgegevens bevat.
JsonOutputSerializationFormat	Hiermee geeft u de indeling van de JSON waarin de uitvoer wordt geschreven. De momenteel ondersteunde waarden zijn 'lineSeparated' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt door elk JSON-object te laten scheiden door een nieuwe regel en 'matrix' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt als een matrix van JSON-objecten.
JsonSerialization	Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in JSON-indeling worden geschreven.
ParquetSerialization	Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in Parquet-indeling worden geschreven.
ReferenceInputProperties	De eigenschappen die zijn gekoppeld aan een invoer die referentiegegevens bevat.
RefreshType	Geeft het type optie voor het vernieuwen van gegevens aan.
StorageAccount	De eigenschappen die zijn gekoppeld aan een Azure Storage-account
StreamInputProperties	De eigenschappen die zijn gekoppeld aan een invoer die stroomgegevens bevat.

AuthenticationMode

Verificatiemodus. Geldige modi zijn ConnectionString, Msi en 'UserToken'.

Name	Type	Description
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in Avro-indeling worden geschreven.

Name	Type	Description
type	string: Avro	Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

AzureSqlReferenceInputDataSource

Beschrijft een Azure SQL databasereferentiegegevensbron.

Name	Type	Description
properties.database	string	Dit element is gekoppeld aan het gegevensbronelement. Dit is de naam van de database waarnaar de uitvoer wordt geschreven.
properties.deltaSnapshotQuery	string	Dit element is gekoppeld aan het gegevensbronelement. Deze query wordt gebruikt om incrementele wijzigingen op te halen uit de SQL-database. Als u deze optie wilt gebruiken, raden we u aan tijdelijke tabellen te gebruiken in Azure SQL Database.
properties.fullSnapshotQuery	string	Dit element is gekoppeld aan het gegevensbronelement. Deze query wordt gebruikt om gegevens op te halen uit de SQL-database.
properties.password	string	Dit element is gekoppeld aan het gegevensbronelement. Dit is het wachtwoord dat wordt gebruikt om verbinding te maken met het SQL Database-exemplaar.
properties.refreshRate	string	Dit element is gekoppeld aan het gegevensbronelement. Dit geeft aan hoe vaak de gegevens uit de database worden opgehaald. Het heeft de datum/tijd-indeling.
properties.refreshType	RefreshType	Geeft het type optie voor het vernieuwen van gegevens aan.
properties.server	string	Dit element is gekoppeld aan het gegevensbronelement. Dit is de naam van de server die de database bevat waarnaar wordt geschreven.
properties.table	string	Dit element is gekoppeld aan het gegevensbronelement. De naam van de tabel in de Azure SQL database.
properties.user	string	Dit element is gekoppeld aan het gegevensbronelement. Dit is de gebruikersnaam die wordt gebruikt om verbinding te maken met het SQL Database exemplaar.
type	string: Microsoft.Sql/Server/Database	Geeft het type invoergegevensbron met referentiegegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

BlobReferenceInputDataSource

Beschrijft een blob-invoergegevensbron die referentiegegevens bevat.

Name	Type	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.container	string		De naam van een container in het gekoppelde opslagaccount. Deze container bevat de blob(s) waaruit moet worden gelezen of geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.dateFormat	string		De datumnotatie. Overal waar {date} wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de datumnotatie.
properties.pathPattern	string		Het blobpadpatroon. Geen reguliere expressie. Het vertegenwoordigt een patroon waarmee blobnamen worden vergeleken om te bepalen of ze moeten worden opgenomen als invoer of uitvoer voor de taak. Zie https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input of https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output voor een meer gedetailleerde uitleg en voorbeeld.
properties.storageAccounts	StorageAccount[]		Een lijst met een of meer Azure Storage-accounts. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.timeFormat	string		De tijdnotatie. Overal waar {time} wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de tijdnotatie.
type	string: Microsoft.Storage/Blob		Geeft het type invoergegevensbron met referentiegegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

BlobStreamInputDataSource

Beschrijft een blob-invoergegevensbron die stroomgegevens bevat.

Name	Type	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.container	string		De naam van een container in het gekoppelde opslagaccount. Deze container bevat de blob(s) waaruit moet worden gelezen of geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.dateFormat	string		De datumnotatie. Overal waar {date} wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de datumnotatie.
properties.pathPattern	string		Het blobpadpatroon. Geen reguliere expressie. Het vertegenwoordigt een patroon waarmee blobnamen worden vergeleken om te bepalen of ze moeten worden opgenomen als invoer of uitvoer voor de taak. Zie https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input of https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output voor een meer gedetailleerde uitleg en voorbeeld.
properties.sourcePartitionCount	integer		Het aantal partities van de blob-invoergegevensbron. Bereik 1 - 1024.
properties.storageAccounts	StorageAccount[]		Een lijst met een of meer Azure Storage-accounts. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.timeFormat	string		De tijdnotatie. Overal waar {time} wordt weergegeven in pathPattern, wordt de waarde van deze eigenschap gebruikt als de tijdnotatie.
type	string: Microsoft.Storage/Blob		Geeft het type invoergegevensbron met stroomgegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

Compression

Beschrijft hoe invoergegevens worden gecomprimeerd

Name	Type	Default value	Description
type	CompressionType	None	Geeft het type compressie aan dat door de invoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

CompressionType

Geeft het type compressie aan dat door de invoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

Name	Type	Description
Deflate	string
GZip	string
None	string

CsvSerialization

Hierin wordt beschreven hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in CSV-indeling worden geschreven.

Name	Type	Description
properties.encoding	Encoding	Hiermee geeft u de codering van de binnenkomende gegevens in het geval van invoer en de codering van uitgaande gegevens in het geval van uitvoer. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.fieldDelimiter	string	Hiermee geeft u het scheidingsteken op dat wordt gebruikt om records met door komma's gescheiden waarden (CSV) te scheiden. Zie https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input of https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output voor een lijst met ondersteunde waarden. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Csv	Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

DiagnosticCondition

Voorwaarde die van toepassing is op de resource of op de taak in het algemeen, die aandacht van de klant vereist.

Name	Type	Description
code	string	De ondoorzichtige diagnostische code.
message	string	Het voor mensen leesbare bericht waarin de voorwaarde in detail wordt beschreven. Gelokaliseerd in de Accept-Language van de clientaanvraag.
since	string	Het UTC-tijdstempel van wanneer de voorwaarde is gestart. Klanten moeten rond deze tijd een bijbehorende gebeurtenis kunnen vinden in het ops-logboek.

Diagnostics

Beschrijft voorwaarden die van toepassing zijn op de invoer, uitvoer of de taak in het algemeen, die aandacht van de klant vereisen.

Name	Type	Description
conditions	DiagnosticCondition[]	Een verzameling van nul of meer voorwaarden die van toepassing zijn op de resource of op de taak in het algemeen, die aandacht van de klant vereisen.

Encoding

Hiermee geeft u de codering van de binnenkomende gegevens in het geval van invoer en de codering van uitgaande gegevens in het geval van uitvoer.

Name	Type	Description
UTF8	string

Error

Veelvoorkomende foutweergave.

Name	Type	Description
error	Error	Eigenschappen van foutdefinitie.

EventHubStreamInputDataSource

Beschrijft een Event Hub-invoergegevensbron die stroomgegevens bevat.

Name	Type	Default value	Description
authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.consumerGroupName	string		De naam van een Event Hub-consumentengroep die moet worden gebruikt om gebeurtenissen uit de Event Hub te lezen. Door afzonderlijke namen van consumentengroepen op te geven voor meerdere invoergegevens, kan elk van deze invoer dezelfde gebeurtenissen ontvangen van de Event Hub. Als dit niet is opgegeven, wordt voor de invoer de standaardconsumenergroep van de Event Hub gebruikt.
properties.eventHubName	string		De naam van de Event Hub. Vereist voor PUT-aanvragen (CreateOrReplace).
serviceBusNamespace	string		De naamruimte die is gekoppeld aan de gewenste Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
sharedAccessPolicyKey	string		De sleutel voor het gedeelde toegangsbeleid voor het opgegeven beleid voor gedeelde toegang. Vereist voor PUT-aanvragen (CreateOrReplace).
sharedAccessPolicyName	string		De naam van het beleid voor gedeelde toegang voor de Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Geeft het type invoergegevensbron met stroomgegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

EventHubV2StreamInputDataSource

Beschrijft een Event Hub-invoergegevensbron die stroomgegevens bevat.

Name	Type	Default value	Description
authenticationMode	AuthenticationMode	ConnectionString	Verificatiemodus.
properties.consumerGroupName	string		De naam van een Event Hub-consumentengroep die moet worden gebruikt om gebeurtenissen uit de Event Hub te lezen. Door afzonderlijke namen van consumentengroepen op te geven voor meerdere invoergegevens, kan elk van deze invoer dezelfde gebeurtenissen ontvangen van de Event Hub. Als dit niet is opgegeven, wordt voor de invoer de standaardconsumenergroep van de Event Hub gebruikt.
properties.eventHubName	string		De naam van de Event Hub. Vereist voor PUT-aanvragen (CreateOrReplace).
serviceBusNamespace	string		De naamruimte die is gekoppeld aan de gewenste Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
sharedAccessPolicyKey	string		De sleutel voor het gedeelde toegangsbeleid voor het opgegeven beleid voor gedeelde toegang. Vereist voor PUT-aanvragen (CreateOrReplace).
sharedAccessPolicyName	string		De naam van het beleid voor gedeelde toegang voor de Event Hub, Service Bus-wachtrij, Service Bus-onderwerp, enzovoort. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Geeft het type invoergegevensbron met stroomgegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

EventSerializationType

Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

Name	Type	Description
Avro	string
Csv	string
Json	string
Parquet	string

FileReferenceInputDataSource

Beschrijft een bestandsinvoergegevensbron die referentiegegevens bevat.

Name	Type	Description
properties.path	string	Het pad van het bestand.
type	string: File	Geeft het type invoergegevensbron met referentiegegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Beschrijft een blob-invoergegevensbron die stroomgegevens bevat.

Name	Type	Description
properties.topic	string	De naam van het Service Bus-onderwerp.
type	string: GatewayMessageBus	Geeft het type invoergegevensbron met stroomgegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

Input

Een invoerobject, dat alle informatie bevat die is gekoppeld aan de benoemde invoer. Alle invoer bevindt zich onder een streamingtaak.

Name	Type	Description
id	string	Resource-id
name	string	Resourcenaam
properties	InputProperties: ReferenceInputProperties StreamInputProperties	De eigenschappen die zijn gekoppeld aan een invoer. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string	Resourcetype

IoTHubStreamInputDataSource

Beschrijft een IoT Hub invoergegevensbron die stroomgegevens bevat.

Name	Type	Description
properties.consumerGroupName	string	De naam van een IoT Hub consumentengroep die moet worden gebruikt om gebeurtenissen uit de IoT Hub te lezen. Als dit niet is opgegeven, gebruikt de invoer de standaardconsumenergroep van de IoT Hub.
properties.endpoint	string	De IoT Hub eindpunt om verbinding mee te maken (bijvoorbeeld berichten/gebeurtenissen, berichten/bewerkingenMonitoringEvents, enzovoort).
properties.iotHubNamespace	string	De naam of de URI van de IoT Hub. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.sharedAccessPolicyKey	string	De sleutel voor het gedeelde toegangsbeleid voor het opgegeven beleid voor gedeelde toegang. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.sharedAccessPolicyName	string	De naam van het beleid voor gedeelde toegang voor de IoT Hub. Dit beleid moet ten minste de machtiging Service connect bevatten. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Geeft het type invoergegevensbron met stroomgegevens aan. Vereist voor PUT-aanvragen (CreateOrReplace).

JsonOutputSerializationFormat

Hiermee geeft u de indeling van de JSON waarin de uitvoer wordt geschreven. De momenteel ondersteunde waarden zijn 'lineSeparated' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt door elk JSON-object te laten scheiden door een nieuwe regel en 'matrix' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt als een matrix van JSON-objecten.

Name	Type	Description
Array	string
LineSeparated	string

JsonSerialization

Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in JSON-indeling worden geschreven.

Name	Type	Description
properties.encoding	Encoding	Hiermee geeft u de codering van de binnenkomende gegevens in het geval van invoer en de codering van uitgaande gegevens in het geval van uitvoer. Vereist voor PUT-aanvragen (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Deze eigenschap is alleen van toepassing op JSON-serialisatie van uitvoer. Dit is niet van toepassing op invoer. Deze eigenschap geeft de indeling op van de JSON waarin de uitvoer wordt geschreven. De momenteel ondersteunde waarden zijn 'lineSeparated' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt door elk JSON-object te laten scheiden door een nieuwe regel en 'matrix' waarmee wordt aangegeven dat de uitvoer wordt opgemaakt als een matrix van JSON-objecten. De standaardwaarde is 'lineSeparated' als deze null blijft.
type	string: Json	Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

ParquetSerialization

Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer in Parquet-indeling worden geschreven.

Name	Type	Description
type	string: Parquet	Geeft het type serialisatie aan dat door de invoer of uitvoer wordt gebruikt. Vereist voor PUT-aanvragen (CreateOrReplace).

ReferenceInputProperties

De eigenschappen die zijn gekoppeld aan een invoer die referentiegegevens bevat.

Name	Type	Description
compression	Compression	Beschrijft hoe invoergegevens worden gecomprimeerd
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Beschrijft een invoergegevensbron die referentiegegevens bevat. Vereist voor PUT-aanvragen (CreateOrReplace).
diagnostics	Diagnostics	Beschrijft voorwaarden die van toepassing zijn op de invoer, uitvoer of de taak in het algemeen, die aandacht van de klant vereisen.
etag	string	De huidige entiteitstag voor de invoer. Dit is een ondoorzichtige tekenreeks. U kunt deze gebruiken om te detecteren of de resource tussen aanvragen is gewijzigd. U kunt deze ook gebruiken in de If-Match- of If-None-Match-headers voor schrijfbewerkingen voor optimistische gelijktijdigheid.
partitionKey	string	partitionKey beschrijft een sleutel in de invoergegevens die wordt gebruikt voor het partitioneren van de invoergegevens
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer worden geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Reference	Geeft aan of de invoer een bron van referentiegegevens of stroomgegevens is. Vereist voor PUT-aanvragen (CreateOrReplace).

RefreshType

Geeft het type optie voor het vernieuwen van gegevens aan.

Name	Type	Description
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

StorageAccount

De eigenschappen die zijn gekoppeld aan een Azure Storage-account

Name	Type	Description
accountKey	string	De accountsleutel voor het Azure Storage-account. Vereist voor PUT-aanvragen (CreateOrReplace).
accountName	string	De naam van het Azure Storage-account. Vereist voor PUT-aanvragen (CreateOrReplace).

StreamInputProperties

De eigenschappen die zijn gekoppeld aan een invoer die stroomgegevens bevat.

Name	Type	Description
compression	Compression	Beschrijft hoe invoergegevens worden gecomprimeerd
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Beschrijft een invoergegevensbron die stroomgegevens bevat. Vereist voor PUT-aanvragen (CreateOrReplace).
diagnostics	Diagnostics	Beschrijft voorwaarden die van toepassing zijn op de invoer, uitvoer of de taak in het algemeen, die aandacht van de klant vereisen.
etag	string	De huidige entiteitstag voor de invoer. Dit is een ondoorzichtige tekenreeks. U kunt deze gebruiken om te detecteren of de resource tussen aanvragen is gewijzigd. U kunt deze ook gebruiken in de If-Match- of If-None-Match-headers voor schrijfbewerkingen voor optimistische gelijktijdigheid.
partitionKey	string	partitionKey beschrijft een sleutel in de invoergegevens die wordt gebruikt voor het partitioneren van de invoergegevens
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer worden geschreven. Vereist voor PUT-aanvragen (CreateOrReplace).
type	string: Stream	Geeft aan of de invoer een bron van referentiegegevens of stroomgegevens is. Vereist voor PUT-aanvragen (CreateOrReplace).