Inputs - Create Or Replace

Tjänst:

Stream Analytics

API-version:

2020-03-01

Skapar indata eller ersätter redan befintliga indata under ett befintligt strömningsjobb.

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

URI-parametrar

Name	I	Obligatorisk	Typ	Description
inputName	path	True	string	Namnet på indata.
jobName	path	True	string	Namnet på strömningsjobbet.
resourceGroupName	path	True	string	Namnet på resursgruppen. Namnet är skiftlägesokänsligt. Reguljärt uttrycksmönster: ^[-\w\._\(\)]+$
subscriptionId	path	True	string	ID för målprenumerationen.
api-version	query	True	string	Den API-version som ska användas för den här åtgärden.

Begärandehuvud

Name	Obligatorisk	Typ	Description
If-Match		string	ETag för indata. Utelämna det här värdet för att alltid skriva över de aktuella indata. Ange det senast sedda ETag-värdet för att förhindra att samtidiga ändringar skrivs över av misstag.
If-None-Match		string	Ange till *för att tillåta att nya indata skapas, men för att förhindra uppdatering av befintliga indata. Andra värden resulterar i ett 412-förvillkor misslyckades svar.

Begärandetext

Name	Typ	Description
name	string	Resursnamn
properties	InputProperties: StreamInputProperties ReferenceInputProperties	De egenskaper som är associerade med indata. Krävs för PUT-begäranden (CreateOrReplace).

Svar

Name	Typ	Description
200 OK	Input	Indata har skapats eller ersatts. Sidhuvuden ETag: string
201 Created	Input	Indata har skapats eller ersatts. Sidhuvuden ETag: string
Other Status Codes	Error	Fel.

Säkerhet

azure_auth

Azure Active Directory OAuth2 Flow

Typ: oauth2
Flow: implicit
Auktoriseringswebbadress: https://login.microsoftonline.com/common/oauth2/authorize

Omfattningar

Name	Description
user_impersonation	personifiera ditt användarkonto

Exempel

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

Exempelbegäran

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

Exempelsvar

Statuskod:

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

Statuskod:

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

Exempelbegäran

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

Exempelsvar

Statuskod:

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

Statuskod:

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

Exempelbegäran

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

Exempelsvar

Statuskod:

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

Statuskod:

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

Exempelbegäran

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

Exempelsvar

Statuskod:

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

Statuskod:

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

Exempelbegäran

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

Exempelsvar

Statuskod:

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

Statuskod:

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

Exempelbegäran

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

Exempelsvar

Statuskod:

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

Statuskod:

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

Definitioner

Name	Description
AuthenticationMode	Autentiseringsläge. Giltiga lägen är ConnectionString, Msi och UserToken.
AvroSerialization	Beskriver hur data från en indata serialiseras eller hur data serialiseras när de skrivs till utdata i Avro-format.
AzureSqlReferenceInputDataSource	Beskriver en Azure SQL databasreferensens indatakälla.
BlobReferenceInputDataSource	Beskriver en blobindatakälla som innehåller referensdata.
BlobStreamInputDataSource	Beskriver en blobindatakälla som innehåller dataströmmar.
Compression	Beskriver hur indata komprimeras
CompressionType	Anger vilken typ av komprimering som indata använder. Krävs för PUT-begäranden (CreateOrReplace).
CsvSerialization	Beskriver hur data från en indata serialiseras eller hur data serialiseras när de skrivs till utdata i CSV-format.
DiagnosticCondition	Villkor som gäller för resursen, eller för jobbet överlag, som motiverar kundernas uppmärksamhet.
Diagnostics	Beskriver de villkor som gäller för indata, utdata eller det övergripande jobbet som berättigar till kund uppmärksamhet.
Encoding	Anger kodningen av inkommande data vid indata och kodning av utgående data när det gäller utdata.
Error	Vanlig felrepresentation.
EventHubStreamInputDataSource	Beskriver en Händelsehubb-indatakälla som innehåller dataströmmar.
EventHubV2StreamInputDataSource	Beskriver en Händelsehubb-indatakälla som innehåller dataströmmar.
EventSerializationType	Anger vilken typ av serialisering som indata eller utdata använder. Krävs för PUT-begäranden (CreateOrReplace).
FileReferenceInputDataSource	Beskriver en filindatakälla som innehåller referensdata.
GatewayMessageBusStreamInputDataSource	Beskriver en blobindatakälla som innehåller dataströmmar.
Input	Ett indataobjekt som innehåller all information som är associerad med de namngivna indata. Alla indata finns under ett strömningsjobb.
IoTHubStreamInputDataSource	Beskriver en IoT Hub indatakälla som innehåller dataströmmar.
JsonOutputSerializationFormat	Anger formatet för JSON som utdata ska skrivas i. De värden som stöds för närvarande är "lineSeparated" som anger att utdata kommer att formateras genom att varje JSON-objekt avgränsas med en ny rad och "matris" som anger att utdata kommer att formateras som en matris med JSON-objekt.
JsonSerialization	Beskriver hur data från en indata serialiseras eller hur data serialiseras när de skrivs till utdata i JSON-format.
ParquetSerialization	Beskriver hur data från en indata serialiseras eller hur data serialiseras när de skrivs till utdata i Parquet-format.
ReferenceInputProperties	De egenskaper som är associerade med indata som innehåller referensdata.
RefreshType	Anger typen av datauppdateringsalternativ.
StorageAccount	De egenskaper som är associerade med ett Azure Storage-konto
StreamInputProperties	De egenskaper som är associerade med indata som innehåller dataströmmen.

AuthenticationMode

Autentiseringsläge. Giltiga lägen är ConnectionString, Msi och UserToken.

Name	Typ	Description
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Beskriver hur data från en indata serialiseras eller hur data serialiseras när de skrivs till utdata i Avro-format.

Name	Typ	Description
type	string: Avro	Anger vilken typ av serialisering som indata eller utdata använder. Krävs för PUT-begäranden (CreateOrReplace).

AzureSqlReferenceInputDataSource

Beskriver en Azure SQL databasreferensens indatakälla.

Name	Typ	Description
properties.database	string	Det här elementet är associerat med datakällans element. Det här är namnet på databasen som utdata skrivs till.
properties.deltaSnapshotQuery	string	Det här elementet är associerat med datakällans element. Den här frågan används för att hämta inkrementella ändringar från SQL-databasen. Om du vill använda det här alternativet rekommenderar vi att du använder temporala tabeller i Azure SQL Database.
properties.fullSnapshotQuery	string	Det här elementet är associerat med datakällans element. Den här frågan används för att hämta data från sql-databasen.
properties.password	string	Det här elementet är associerat med datakällans element. Det här är lösenordet som ska användas för att ansluta till SQL Database-instansen.
properties.refreshRate	string	Det här elementet är associerat med datakällans element. Detta anger hur ofta data hämtas från databasen. Det är i DateTime-format.
properties.refreshType	RefreshType	Anger typen av datauppdateringsalternativ.
properties.server	string	Det här elementet är associerat med datakällans element. Det här är namnet på den server som innehåller databasen som ska skrivas till.
properties.table	string	Det här elementet är associerat med datakällans element. Namnet på tabellen i Azure SQL-databasen..
properties.user	string	Det här elementet är associerat med datakällans element. Det här är användarnamnet som ska användas för att ansluta till SQL Database-instansen.
type	string: Microsoft.Sql/Server/Database	Anger vilken typ av indatakälla som innehåller referensdata. Krävs för PUT-begäranden (CreateOrReplace).

BlobReferenceInputDataSource

Beskriver en blobindatakälla som innehåller referensdata.

Name	Typ	Standardvärde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.container	string		Namnet på en container i det associerade lagringskontot. Den här containern innehåller antingen de blobar som ska läsas från eller skrivas till. Krävs för PUT-begäranden (CreateOrReplace).
properties.dateFormat	string		Datumformatet. Oavsett var {date} visas i pathPattern används värdet för den här egenskapen som datumformat i stället.
properties.pathPattern	string		Mönstret för blobsökväg. Inte ett reguljärt uttryck. Den representerar ett mönster som blobnamnen ska matchas mot för att avgöra om de ska inkluderas som indata eller utdata till jobbet eller inte. Se https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input eller https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output för en mer detaljerad förklaring och exempel.
properties.storageAccounts	StorageAccount[]		En lista över ett eller flera Azure Storage-konton. Krävs för PUT-begäranden (CreateOrReplace).
properties.timeFormat	string		Tidsformatet. Oavsett var {time} visas i pathPattern används värdet för den här egenskapen som tidsformat i stället.
type	string: Microsoft.Storage/Blob		Anger vilken typ av indatakälla som innehåller referensdata. Krävs för PUT-begäranden (CreateOrReplace).

BlobStreamInputDataSource

Beskriver en blobindatakälla som innehåller dataströmmar.

Name	Typ	Standardvärde	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.container	string		Namnet på en container i det associerade lagringskontot. Den här containern innehåller antingen de blobar som ska läsas från eller skrivas till. Krävs för PUT-begäranden (CreateOrReplace).
properties.dateFormat	string		Datumformatet. Oavsett var {date} visas i pathPattern används värdet för den här egenskapen som datumformat i stället.
properties.pathPattern	string		Mönstret för blobsökväg. Inte ett reguljärt uttryck. Den representerar ett mönster mot vilket blobnamn matchas för att avgöra om de ska inkluderas som indata eller utdata till jobbet. Se https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input eller https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output för en mer detaljerad förklaring och exempel.
properties.sourcePartitionCount	integer		Partitionsantalet för blobens indatakälla. Intervall 1 – 1024.
properties.storageAccounts	StorageAccount[]		En lista över ett eller flera Azure Storage-konton. Krävs för PUT-begäranden (CreateOrReplace).
properties.timeFormat	string		Tidsformatet. Oavsett var {time} visas i pathPattern används värdet för den här egenskapen som tidsformat i stället.
type	string: Microsoft.Storage/Blob		Anger vilken typ av indatakälla som innehåller strömdata. Krävs för PUT-begäranden (CreateOrReplace).

Compression

Beskriver hur indata komprimeras

Name	Typ	Standardvärde	Description
type	CompressionType	None	Anger vilken typ av komprimering som indata använder. Krävs för PUT-begäranden (CreateOrReplace).

CompressionType

Anger vilken typ av komprimering som indata använder. Krävs för PUT-begäranden (CreateOrReplace).

Name	Typ	Description
Deflate	string
GZip	string
None	string

CsvSerialization

Beskriver hur data från en indata serialiseras eller hur data serialiseras när de skrivs till utdata i CSV-format.

Name	Typ	Description
properties.encoding	Encoding	Anger kodningen av inkommande data vid indata och kodning av utgående data när det gäller utdata. Krävs för PUT-begäranden (CreateOrReplace).
properties.fieldDelimiter	string	Anger avgränsare som ska användas för att separera kommaavgränsade värdeposter (CSV). Se https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input eller https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output för en lista över värden som stöds. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Csv	Anger vilken typ av serialisering som indata eller utdata använder. Krävs för PUT-begäranden (CreateOrReplace).

DiagnosticCondition

Villkor som gäller för resursen, eller för jobbet överlag, som motiverar kundernas uppmärksamhet.

Name	Typ	Description
code	string	Den täckande diagnostikkoden.
message	string	Det läsbara meddelandet som beskriver villkoret i detalj. Lokaliserad i Accept-Language för klientbegäran.
since	string	UTC-tidsstämpeln för när villkoret startades. Kunder bör kunna hitta en motsvarande händelse i ops-loggen runt den här gången.

Diagnostics

Beskriver de villkor som gäller för indata, utdata eller det övergripande jobbet som berättigar till kund uppmärksamhet.

Name	Typ	Description
conditions	DiagnosticCondition[]	En samling med noll eller fler villkor som gäller för resursen, eller för jobbet som helhet, som motiverar kundernas uppmärksamhet.

Encoding

Anger kodningen av inkommande data vid indata och kodning av utgående data när det gäller utdata.

Name	Typ	Description
UTF8	string

Error

Vanlig felrepresentation.

Name	Typ	Description
error	Error	Egenskaper för feldefinition.

EventHubStreamInputDataSource

Beskriver en Händelsehubb-indatakälla som innehåller dataströmmar.

Name	Typ	Standardvärde	Description
authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.consumerGroupName	string		Namnet på en händelsehubbkonsumentgrupp som ska användas för att läsa händelser från händelsehubben. Genom att ange distinkta konsumentgruppnamn för flera indata kan var och en av dessa indata ta emot samma händelser från händelsehubben. Om inget anges använder indata händelsehubbens standardkonsumentgrupp.
properties.eventHubName	string		Namnet på händelsehubben. Krävs för PUT-begäranden (CreateOrReplace).
serviceBusNamespace	string		Namnområdet som är associerat med önskad händelsehubb, Service Bus-kö, Service Bus-ämne osv. Krävs för PUT-begäranden (CreateOrReplace).
sharedAccessPolicyKey	string		Principnyckeln för delad åtkomst för den angivna principen för delad åtkomst. Krävs för PUT-begäranden (CreateOrReplace).
sharedAccessPolicyName	string		Namnet på principen för delad åtkomst för Händelsehubb, Service Bus-kö, Service Bus-ämne osv. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Anger vilken typ av indatakälla som innehåller strömdata. Krävs för PUT-begäranden (CreateOrReplace).

EventHubV2StreamInputDataSource

Beskriver en Händelsehubb-indatakälla som innehåller dataströmmar.

Name	Typ	Standardvärde	Description
authenticationMode	AuthenticationMode	ConnectionString	Autentiseringsläge.
properties.consumerGroupName	string		Namnet på en händelsehubbkonsumentgrupp som ska användas för att läsa händelser från händelsehubben. Genom att ange distinkta konsumentgruppnamn för flera indata kan var och en av dessa indata ta emot samma händelser från händelsehubben. Om inget anges använder indata händelsehubbens standardkonsumentgrupp.
properties.eventHubName	string		Namnet på händelsehubben. Krävs för PUT-begäranden (CreateOrReplace).
serviceBusNamespace	string		Namnområdet som är associerat med önskad händelsehubb, Service Bus-kö, Service Bus-ämne osv. Krävs för PUT-begäranden (CreateOrReplace).
sharedAccessPolicyKey	string		Principnyckeln för delad åtkomst för den angivna principen för delad åtkomst. Krävs för PUT-begäranden (CreateOrReplace).
sharedAccessPolicyName	string		Namnet på principen för delad åtkomst för Händelsehubb, Service Bus-kö, Service Bus-ämne osv. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Anger vilken typ av indatakälla som innehåller strömdata. Krävs för PUT-begäranden (CreateOrReplace).

EventSerializationType

Anger vilken typ av serialisering som indata eller utdata använder. Krävs för PUT-begäranden (CreateOrReplace).

Name	Typ	Description
Avro	string
Csv	string
Json	string
Parquet	string

FileReferenceInputDataSource

Beskriver en filindatakälla som innehåller referensdata.

Name	Typ	Description
properties.path	string	Sökvägen till filen.
type	string: File	Anger vilken typ av indatakälla som innehåller referensdata. Krävs för PUT-begäranden (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Beskriver en blobindatakälla som innehåller dataströmmar.

Name	Typ	Description
properties.topic	string	Namnet på Service Bus-ämnet.
type	string: GatewayMessageBus	Anger vilken typ av indatakälla som innehåller dataström. Krävs för PUT-begäranden (CreateOrReplace).

Input

Ett indataobjekt som innehåller all information som är associerad med de namngivna indata. Alla indata finns under ett strömningsjobb.

Name	Typ	Description
id	string	Resurs-ID
name	string	Resursnamn
properties	InputProperties: ReferenceInputProperties StreamInputProperties	De egenskaper som är associerade med indata. Krävs för PUT-begäranden (CreateOrReplace).
type	string	Resurstyp

IoTHubStreamInputDataSource

Beskriver en IoT Hub indatakälla som innehåller dataströmmar.

Name	Typ	Description
properties.consumerGroupName	string	Namnet på en IoT Hub konsumentgrupp som ska användas för att läsa händelser från IoT Hub. Om inget anges använder indata Iot Hubs standardkonsumentgrupp.
properties.endpoint	string	Den IoT Hub slutpunkten som ska anslutas till (t.ex. meddelanden/händelser, meddelanden/åtgärderÖvervakaHändelse osv.).
properties.iotHubNamespace	string	Namnet eller URI:n för IoT Hub. Krävs för PUT-begäranden (CreateOrReplace).
properties.sharedAccessPolicyKey	string	Principnyckeln för delad åtkomst för den angivna principen för delad åtkomst. Krävs för PUT-begäranden (CreateOrReplace).
properties.sharedAccessPolicyName	string	Namnet på principen för delad åtkomst för IoT Hub. Den här principen måste innehålla minst behörigheten Tjänstanslutning. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Anger vilken typ av indatakälla som innehåller strömdata. Krävs för PUT-begäranden (CreateOrReplace).

JsonOutputSerializationFormat

Anger formatet för JSON som utdata ska skrivas i. De värden som stöds för närvarande är "lineSeparated" som anger att utdata kommer att formateras genom att varje JSON-objekt avgränsas med en ny rad och "matris" som anger att utdata kommer att formateras som en matris med JSON-objekt.

Name	Typ	Description
Array	string
LineSeparated	string

JsonSerialization

Beskriver hur data från en indata serialiseras eller hur data serialiseras när de skrivs till utdata i JSON-format.

Name	Typ	Description
properties.encoding	Encoding	Anger kodningen av inkommande data vid indata och kodning av utgående data när det gäller utdata. Krävs för PUT-begäranden (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Den här egenskapen gäller endast för JSON-serialisering av utdata. Det är inte tillämpligt på indata. Den här egenskapen anger formatet för JSON som utdata ska skrivas i. De värden som stöds för närvarande är "lineSeparated" som anger att utdata kommer att formateras genom att varje JSON-objekt avgränsas med en ny rad och "matris" som anger att utdata kommer att formateras som en matris med JSON-objekt. Standardvärdet är "lineSeparated" om det lämnas null.
type	string: Json	Anger vilken typ av serialisering som indata eller utdata använder. Krävs för PUT-begäranden (CreateOrReplace).

ParquetSerialization

Beskriver hur data från en indata serialiseras eller hur data serialiseras när de skrivs till utdata i Parquet-format.

Name	Typ	Description
type	string: Parquet	Anger vilken typ av serialisering som indata eller utdata använder. Krävs för PUT-begäranden (CreateOrReplace).

ReferenceInputProperties

De egenskaper som är associerade med indata som innehåller referensdata.

Name	Typ	Description
compression	Compression	Beskriver hur indata komprimeras
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Beskriver en indatakälla som innehåller referensdata. Krävs för PUT-begäranden (CreateOrReplace).
diagnostics	Diagnostics	Beskriver de villkor som gäller för indata, utdata eller det övergripande jobbet som berättigar till kund uppmärksamhet.
etag	string	Den aktuella entitetstaggen för indata. Det här är en täckande sträng. Du kan använda den för att identifiera om resursen har ändrats mellan begäranden. Du kan också använda den i rubrikerna If-Match eller If-None-Match för skrivåtgärder för optimistisk samtidighet.
partitionKey	string	partitionKey Beskriver en nyckel i indata som används för partitionering av indata
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beskriver hur data från indata serialiseras eller hur data serialiseras när de skrivs till utdata. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Reference	Anger om indata är en källa till referensdata eller dataströmmar. Krävs för PUT-begäranden (CreateOrReplace).

RefreshType

Anger typen av datauppdateringsalternativ.

Name	Typ	Description
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

StorageAccount

De egenskaper som är associerade med ett Azure Storage-konto

Name	Typ	Description
accountKey	string	Kontonyckeln för Azure Storage-kontot. Krävs för PUT-begäranden (CreateOrReplace).
accountName	string	Namnet på Azure Storage-kontot. Krävs för PUT-begäranden (CreateOrReplace).

StreamInputProperties

De egenskaper som är associerade med indata som innehåller dataströmmen.

Name	Typ	Description
compression	Compression	Beskriver hur indata komprimeras
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Beskriver en indatakälla som innehåller dataströmmar. Krävs för PUT-begäranden (CreateOrReplace).
diagnostics	Diagnostics	Beskriver de villkor som gäller för indata, utdata eller det övergripande jobbet som berättigar till kund uppmärksamhet.
etag	string	Den aktuella entitetstaggen för indata. Det här är en täckande sträng. Du kan använda den för att identifiera om resursen har ändrats mellan begäranden. Du kan också använda den i rubrikerna If-Match eller If-None-Match för skrivåtgärder för optimistisk samtidighet.
partitionKey	string	partitionKey Beskriver en nyckel i indata som används för partitionering av indata
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Beskriver hur data från indata serialiseras eller hur data serialiseras när de skrivs till utdata. Krävs för PUT-begäranden (CreateOrReplace).
type	string: Stream	Anger om indata är en källa till referensdata eller dataströmmar. Krävs för PUT-begäranden (CreateOrReplace).