Inputs - Create Or Replace

Service:

Stream Analytics

API Version:

2020-03-01

Membuat input atau mengganti input yang sudah ada di bawah pekerjaan streaming yang ada.

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

Parameter URI

Nama	Dalam	Diperlukan	Jenis	Deskripsi
inputName	path	True	string	Nama input.
jobName	path	True	string	Nama pekerjaan streaming.
resourceGroupName	path	True	string	Nama grup sumber daya. Nama tidak peka huruf besar/kecil. Regex pattern: ^[-\w\._\(\)]+$
subscriptionId	path	True	string	ID langganan target.
api-version	query	True	string	Versi API yang digunakan untuk operasi ini.

Header Permintaan

Nama	Diperlukan	Jenis	Deskripsi
If-Match		string	ETag input. Hilangkan nilai ini untuk selalu menimpa input saat ini. Tentukan nilai ETag yang terakhir dilihat untuk mencegah penimpaan perubahan bersamaan secara tidak sengaja.
If-None-Match		string	Atur ke '*' untuk mengizinkan input baru dibuat, tetapi untuk mencegah pembaruan input yang ada. Nilai lain akan menghasilkan respons 412 Pra-kondisi Gagal.

Isi Permintaan

Nama	Jenis	Deskripsi
name	string	Nama sumber daya
properties	InputProperties: StreamInputProperties ReferenceInputProperties	Properti yang terkait dengan input. Diperlukan pada permintaan PUT (CreateOrReplace).

Respons

Nama	Jenis	Deskripsi
200 OK	Input	Input berhasil dibuat atau diganti. Headers ETag: string
201 Created	Input	Input berhasil dibuat atau diganti. Headers ETag: string
Other Status Codes	Error	Kesalahan.

Keamanan

azure_auth

Alur OAuth2 Azure Active Directory

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

Scopes

Nama	Deskripsi
user_impersonation	meniru akun pengguna Anda

Contoh

Create a Gateway Message Bus input

Create a reference blob input with CSV serialization

Create a reference file input

Create a stream blob input with CSV serialization

Create a stream Event Hub input with JSON serialization

Create a stream IoT Hub input with Avro serialization

Create a Gateway Message Bus input

Sample Request

HTTP

PUT https://management.azure.com/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourcegroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970?api-version=2020-03-01

{
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "GatewayMessageBus",
      "properties": {
        "topic": "EdgeTopic1"
      }
    }
  }
}

Java

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

Go

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

JavaScript

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

Sample Response

Status code:

201

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

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970",
  "name": "input7970",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "GatewayMessageBus",
      "properties": {
        "topic": "EdgeTopic1"
      }
    }
  }
}

Status code:

200

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

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970",
  "name": "input7970",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "GatewayMessageBus",
      "properties": {
        "topic": "EdgeTopic1"
      }
    }
  }
}

Create a reference blob input with CSV serialization

Sample Request

HTTP

PUT https://management.azure.com/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourcegroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7225?api-version=2020-03-01

{
  "properties": {
    "type": "Reference",
    "datasource": {
      "type": "Microsoft.Storage/Blob",
      "properties": {
        "storageAccounts": [
          {
            "accountName": "someAccountName",
            "accountKey": "someAccountKey=="
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

Java

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

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

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Reference_Blob_CSV.json
func ExampleInputsClient_CreateOrReplace_createAReferenceBlobInputWithCsvSerialization() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armstreamanalytics.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewInputsClient().CreateOrReplace(ctx, "sjrg8440", "sj9597", "input7225", armstreamanalytics.Input{
		Properties: &armstreamanalytics.ReferenceInputProperties{
			Type: to.Ptr("Reference"),
			Serialization: &armstreamanalytics.CSVSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
				Properties: &armstreamanalytics.CSVSerializationProperties{
					Encoding:       to.Ptr(armstreamanalytics.EncodingUTF8),
					FieldDelimiter: to.Ptr(","),
				},
			},
			Datasource: &armstreamanalytics.BlobReferenceInputDataSource{
				Type: to.Ptr("Microsoft.Storage/Blob"),
				Properties: &armstreamanalytics.BlobReferenceInputDataSourceProperties{
					Container:   to.Ptr("state"),
					DateFormat:  to.Ptr("yyyy/MM/dd"),
					PathPattern: to.Ptr("{date}/{time}"),
					StorageAccounts: []*armstreamanalytics.StorageAccount{
						{
							AccountKey:  to.Ptr("someAccountKey=="),
							AccountName: to.Ptr("someAccountName"),
						}},
					TimeFormat: to.Ptr("HH"),
				},
			},
		},
	}, &armstreamanalytics.InputsClientCreateOrReplaceOptions{IfMatch: nil,
		IfNoneMatch: nil,
	})
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.Input = armstreamanalytics.Input{
	// 	Name: to.Ptr("input7225"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7225"),
	// 	Properties: &armstreamanalytics.ReferenceInputProperties{
	// 		Type: to.Ptr("Reference"),
	// 		Serialization: &armstreamanalytics.CSVSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
	// 			Properties: &armstreamanalytics.CSVSerializationProperties{
	// 				Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
	// 				FieldDelimiter: to.Ptr(","),
	// 			},
	// 		},
	// 		Datasource: &armstreamanalytics.BlobReferenceInputDataSource{
	// 			Type: to.Ptr("Microsoft.Storage/Blob"),
	// 			Properties: &armstreamanalytics.BlobReferenceInputDataSourceProperties{
	// 				Container: to.Ptr("state"),
	// 				DateFormat: to.Ptr("yyyy/MM/dd"),
	// 				PathPattern: to.Ptr("{date}/{time}"),
	// 				StorageAccounts: []*armstreamanalytics.StorageAccount{
	// 					{
	// 						AccountName: to.Ptr("someAccountName"),
	// 				}},
	// 				TimeFormat: to.Ptr("HH"),
	// 			},
	// 		},
	// 	},
	// }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

JavaScript

const { StreamAnalyticsManagementClient } = require("@azure/arm-streamanalytics");
const { DefaultAzureCredential } = require("@azure/identity");

/**
 * This sample demonstrates how to Creates an input or replaces an already existing input under an existing streaming job.
 *
 * @summary Creates an input or replaces an already existing input under an existing streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Reference_Blob_CSV.json
 */
async function createAReferenceBlobInputWithCsvSerialization() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg8440";
  const jobName = "sj9597";
  const inputName = "input7225";
  const input = {
    properties: {
      type: "Reference",
      datasource: {
        type: "Microsoft.Storage/Blob",
        container: "state",
        dateFormat: "yyyy/MM/dd",
        pathPattern: "{date}/{time}",
        storageAccounts: [{ accountKey: "someAccountKey==", accountName: "someAccountName" }],
        timeFormat: "HH",
      },
      serialization: { type: "Csv", encoding: "UTF8", fieldDelimiter: "," },
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.createOrReplace(resourceGroupName, jobName, inputName, input);
  console.log(result);
}

createAReferenceBlobInputWithCsvSerialization().catch(console.error);

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Sample Response

Status code:

201

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

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7225",
  "name": "input7225",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Reference",
    "datasource": {
      "type": "Microsoft.Storage/Blob",
      "properties": {
        "storageAccounts": [
          {
            "accountName": "someAccountName"
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

Status code:

200

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

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7225",
  "name": "input7225",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Reference",
    "datasource": {
      "type": "Microsoft.Storage/Blob",
      "properties": {
        "storageAccounts": [
          {
            "accountName": "someAccountName"
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

Create a reference file input

Sample Request

HTTP

PUT https://management.azure.com/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourcegroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7225?api-version=2020-03-01

{
  "properties": {
    "type": "Reference",
    "datasource": {
      "type": "File",
      "properties": {
        "path": "my/path"
      }
    }
  }
}

Java

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

Go

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

JavaScript

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

Sample Response

Status code:

201

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

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7225",
  "name": "input7225",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Reference",
    "datasource": {
      "type": "File",
      "properties": {
        "path": "my/path"
      }
    }
  }
}

Status code:

200

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

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7225",
  "name": "input7225",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Reference",
    "datasource": {
      "type": "File",
      "properties": {
        "path": "my/path"
      }
    }
  }
}

Create a stream blob input with CSV serialization

Sample Request

HTTP

PUT https://management.azure.com/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourcegroups/sjrg8161/providers/Microsoft.StreamAnalytics/streamingjobs/sj6695/inputs/input8899?api-version=2020-03-01

{
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.Storage/Blob",
      "properties": {
        "storageAccounts": [
          {
            "accountName": "someAccountName",
            "accountKey": "someAccountKey=="
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH",
        "sourcePartitionCount": 16
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

Java

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

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

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_Blob_CSV.json
func ExampleInputsClient_CreateOrReplace_createAStreamBlobInputWithCsvSerialization() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armstreamanalytics.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewInputsClient().CreateOrReplace(ctx, "sjrg8161", "sj6695", "input8899", armstreamanalytics.Input{
		Properties: &armstreamanalytics.StreamInputProperties{
			Type: to.Ptr("Stream"),
			Serialization: &armstreamanalytics.CSVSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
				Properties: &armstreamanalytics.CSVSerializationProperties{
					Encoding:       to.Ptr(armstreamanalytics.EncodingUTF8),
					FieldDelimiter: to.Ptr(","),
				},
			},
			Datasource: &armstreamanalytics.BlobStreamInputDataSource{
				Type: to.Ptr("Microsoft.Storage/Blob"),
				Properties: &armstreamanalytics.BlobStreamInputDataSourceProperties{
					Container:   to.Ptr("state"),
					DateFormat:  to.Ptr("yyyy/MM/dd"),
					PathPattern: to.Ptr("{date}/{time}"),
					StorageAccounts: []*armstreamanalytics.StorageAccount{
						{
							AccountKey:  to.Ptr("someAccountKey=="),
							AccountName: to.Ptr("someAccountName"),
						}},
					TimeFormat:           to.Ptr("HH"),
					SourcePartitionCount: to.Ptr[int32](16),
				},
			},
		},
	}, &armstreamanalytics.InputsClientCreateOrReplaceOptions{IfMatch: nil,
		IfNoneMatch: nil,
	})
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.Input = armstreamanalytics.Input{
	// 	Name: to.Ptr("input8899"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8161/providers/Microsoft.StreamAnalytics/streamingjobs/sj6695/inputs/input8899"),
	// 	Properties: &armstreamanalytics.StreamInputProperties{
	// 		Type: to.Ptr("Stream"),
	// 		Serialization: &armstreamanalytics.CSVSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
	// 			Properties: &armstreamanalytics.CSVSerializationProperties{
	// 				Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
	// 				FieldDelimiter: to.Ptr(","),
	// 			},
	// 		},
	// 		Datasource: &armstreamanalytics.BlobStreamInputDataSource{
	// 			Type: to.Ptr("Microsoft.Storage/Blob"),
	// 			Properties: &armstreamanalytics.BlobStreamInputDataSourceProperties{
	// 				Container: to.Ptr("state"),
	// 				DateFormat: to.Ptr("yyyy/MM/dd"),
	// 				PathPattern: to.Ptr("{date}/{time}"),
	// 				StorageAccounts: []*armstreamanalytics.StorageAccount{
	// 					{
	// 						AccountName: to.Ptr("someAccountName"),
	// 				}},
	// 				TimeFormat: to.Ptr("HH"),
	// 				SourcePartitionCount: to.Ptr[int32](16),
	// 			},
	// 		},
	// 	},
	// }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

JavaScript

const { StreamAnalyticsManagementClient } = require("@azure/arm-streamanalytics");
const { DefaultAzureCredential } = require("@azure/identity");

/**
 * This sample demonstrates how to Creates an input or replaces an already existing input under an existing streaming job.
 *
 * @summary Creates an input or replaces an already existing input under an existing streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_Blob_CSV.json
 */
async function createAStreamBlobInputWithCsvSerialization() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg8161";
  const jobName = "sj6695";
  const inputName = "input8899";
  const input = {
    properties: {
      type: "Stream",
      datasource: {
        type: "Microsoft.Storage/Blob",
        container: "state",
        dateFormat: "yyyy/MM/dd",
        pathPattern: "{date}/{time}",
        sourcePartitionCount: 16,
        storageAccounts: [{ accountKey: "someAccountKey==", accountName: "someAccountName" }],
        timeFormat: "HH",
      },
      serialization: { type: "Csv", encoding: "UTF8", fieldDelimiter: "," },
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.createOrReplace(resourceGroupName, jobName, inputName, input);
  console.log(result);
}

createAStreamBlobInputWithCsvSerialization().catch(console.error);

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Sample Response

Status code:

201

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

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8161/providers/Microsoft.StreamAnalytics/streamingjobs/sj6695/inputs/input8899",
  "name": "input8899",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.Storage/Blob",
      "properties": {
        "sourcePartitionCount": 16,
        "storageAccounts": [
          {
            "accountName": "someAccountName"
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

Status code:

200

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

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8161/providers/Microsoft.StreamAnalytics/streamingjobs/sj6695/inputs/input8899",
  "name": "input8899",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.Storage/Blob",
      "properties": {
        "sourcePartitionCount": 16,
        "storageAccounts": [
          {
            "accountName": "someAccountName"
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

Create a stream Event Hub input with JSON serialization

Sample Request

HTTP

PUT https://management.azure.com/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourcegroups/sjrg3139/providers/Microsoft.StreamAnalytics/streamingjobs/sj197/inputs/input7425?api-version=2020-03-01

{
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.ServiceBus/EventHub",
      "properties": {
        "serviceBusNamespace": "sdktest",
        "sharedAccessPolicyName": "RootManageSharedAccessKey",
        "sharedAccessPolicyKey": "someSharedAccessPolicyKey==",
        "eventHubName": "sdkeventhub",
        "consumerGroupName": "sdkconsumergroup"
      }
    },
    "serialization": {
      "type": "Json",
      "properties": {
        "encoding": "UTF8"
      }
    }
  }
}

Java

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

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

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_EventHub_JSON.json
func ExampleInputsClient_CreateOrReplace_createAStreamEventHubInputWithJsonSerialization() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armstreamanalytics.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewInputsClient().CreateOrReplace(ctx, "sjrg3139", "sj197", "input7425", armstreamanalytics.Input{
		Properties: &armstreamanalytics.StreamInputProperties{
			Type: to.Ptr("Stream"),
			Serialization: &armstreamanalytics.JSONSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
				Properties: &armstreamanalytics.JSONSerializationProperties{
					Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
				},
			},
			Datasource: &armstreamanalytics.EventHubStreamInputDataSource{
				Type: to.Ptr("Microsoft.ServiceBus/EventHub"),
				Properties: &armstreamanalytics.EventHubStreamInputDataSourceProperties{
					ServiceBusNamespace:    to.Ptr("sdktest"),
					SharedAccessPolicyKey:  to.Ptr("someSharedAccessPolicyKey=="),
					SharedAccessPolicyName: to.Ptr("RootManageSharedAccessKey"),
					EventHubName:           to.Ptr("sdkeventhub"),
					ConsumerGroupName:      to.Ptr("sdkconsumergroup"),
				},
			},
		},
	}, &armstreamanalytics.InputsClientCreateOrReplaceOptions{IfMatch: nil,
		IfNoneMatch: nil,
	})
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.Input = armstreamanalytics.Input{
	// 	Name: to.Ptr("input7425"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3139/providers/Microsoft.StreamAnalytics/streamingjobs/sj197/inputs/input7425"),
	// 	Properties: &armstreamanalytics.StreamInputProperties{
	// 		Type: to.Ptr("Stream"),
	// 		Serialization: &armstreamanalytics.JSONSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
	// 			Properties: &armstreamanalytics.JSONSerializationProperties{
	// 				Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
	// 			},
	// 		},
	// 		Datasource: &armstreamanalytics.EventHubStreamInputDataSource{
	// 			Type: to.Ptr("Microsoft.ServiceBus/EventHub"),
	// 			Properties: &armstreamanalytics.EventHubStreamInputDataSourceProperties{
	// 				ServiceBusNamespace: to.Ptr("sdktest"),
	// 				SharedAccessPolicyName: to.Ptr("RootManageSharedAccessKey"),
	// 				EventHubName: to.Ptr("sdkeventhub"),
	// 				ConsumerGroupName: to.Ptr("sdkconsumergroup"),
	// 			},
	// 		},
	// 	},
	// }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

JavaScript

const { StreamAnalyticsManagementClient } = require("@azure/arm-streamanalytics");
const { DefaultAzureCredential } = require("@azure/identity");

/**
 * This sample demonstrates how to Creates an input or replaces an already existing input under an existing streaming job.
 *
 * @summary Creates an input or replaces an already existing input under an existing streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_EventHub_JSON.json
 */
async function createAStreamEventHubInputWithJsonSerialization() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg3139";
  const jobName = "sj197";
  const inputName = "input7425";
  const input = {
    properties: {
      type: "Stream",
      datasource: {
        type: "Microsoft.ServiceBus/EventHub",
        consumerGroupName: "sdkconsumergroup",
        eventHubName: "sdkeventhub",
        serviceBusNamespace: "sdktest",
        sharedAccessPolicyKey: "someSharedAccessPolicyKey==",
        sharedAccessPolicyName: "RootManageSharedAccessKey",
      },
      serialization: { type: "Json", encoding: "UTF8" },
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.createOrReplace(resourceGroupName, jobName, inputName, input);
  console.log(result);
}

createAStreamEventHubInputWithJsonSerialization().catch(console.error);

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Sample Response

Status code:

201

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

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3139/providers/Microsoft.StreamAnalytics/streamingjobs/sj197/inputs/input7425",
  "name": "input7425",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.ServiceBus/EventHub",
      "properties": {
        "eventHubName": "sdkeventhub",
        "consumerGroupName": "sdkconsumergroup",
        "serviceBusNamespace": "sdktest",
        "sharedAccessPolicyName": "RootManageSharedAccessKey"
      }
    },
    "serialization": {
      "type": "Json",
      "properties": {
        "encoding": "UTF8"
      }
    }
  }
}

Status code:

200

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

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3139/providers/Microsoft.StreamAnalytics/streamingjobs/sj197/inputs/input7425",
  "name": "input7425",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.ServiceBus/EventHub",
      "properties": {
        "eventHubName": "sdkeventhub",
        "consumerGroupName": "sdkconsumergroup",
        "serviceBusNamespace": "sdktest",
        "sharedAccessPolicyName": "RootManageSharedAccessKey"
      }
    },
    "serialization": {
      "type": "Json",
      "properties": {
        "encoding": "UTF8"
      }
    }
  }
}

Create a stream IoT Hub input with Avro serialization

Sample Request

HTTP

PUT https://management.azure.com/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourcegroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970?api-version=2020-03-01

{
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.Devices/IotHubs",
      "properties": {
        "iotHubNamespace": "iothub",
        "sharedAccessPolicyName": "owner",
        "sharedAccessPolicyKey": "sharedAccessPolicyKey=",
        "consumerGroupName": "sdkconsumergroup",
        "endpoint": "messages/events"
      }
    },
    "serialization": {
      "type": "Avro"
    }
  }
}

Java

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

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

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_IoTHub_Avro.json
func ExampleInputsClient_CreateOrReplace_createAStreamIoTHubInputWithAvroSerialization() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armstreamanalytics.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	res, err := clientFactory.NewInputsClient().CreateOrReplace(ctx, "sjrg3467", "sj9742", "input7970", armstreamanalytics.Input{
		Properties: &armstreamanalytics.StreamInputProperties{
			Type: to.Ptr("Stream"),
			Serialization: &armstreamanalytics.AvroSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeAvro),
			},
			Datasource: &armstreamanalytics.IoTHubStreamInputDataSource{
				Type: to.Ptr("Microsoft.Devices/IotHubs"),
				Properties: &armstreamanalytics.IoTHubStreamInputDataSourceProperties{
					ConsumerGroupName:      to.Ptr("sdkconsumergroup"),
					Endpoint:               to.Ptr("messages/events"),
					IotHubNamespace:        to.Ptr("iothub"),
					SharedAccessPolicyKey:  to.Ptr("sharedAccessPolicyKey="),
					SharedAccessPolicyName: to.Ptr("owner"),
				},
			},
		},
	}, &armstreamanalytics.InputsClientCreateOrReplaceOptions{IfMatch: nil,
		IfNoneMatch: nil,
	})
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.Input = armstreamanalytics.Input{
	// 	Name: to.Ptr("input7970"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970"),
	// 	Properties: &armstreamanalytics.StreamInputProperties{
	// 		Type: to.Ptr("Stream"),
	// 		Serialization: &armstreamanalytics.AvroSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeAvro),
	// 			Properties: map[string]any{
	// 			},
	// 		},
	// 		Datasource: &armstreamanalytics.IoTHubStreamInputDataSource{
	// 			Type: to.Ptr("Microsoft.Devices/IotHubs"),
	// 			Properties: &armstreamanalytics.IoTHubStreamInputDataSourceProperties{
	// 				ConsumerGroupName: to.Ptr("sdkconsumergroup"),
	// 				Endpoint: to.Ptr("messages/events"),
	// 				IotHubNamespace: to.Ptr("iothub"),
	// 				SharedAccessPolicyName: to.Ptr("owner"),
	// 			},
	// 		},
	// 	},
	// }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

JavaScript

const { StreamAnalyticsManagementClient } = require("@azure/arm-streamanalytics");
const { DefaultAzureCredential } = require("@azure/identity");

/**
 * This sample demonstrates how to Creates an input or replaces an already existing input under an existing streaming job.
 *
 * @summary Creates an input or replaces an already existing input under an existing streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_IoTHub_Avro.json
 */
async function createAStreamIoTHubInputWithAvroSerialization() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg3467";
  const jobName = "sj9742";
  const inputName = "input7970";
  const input = {
    properties: {
      type: "Stream",
      datasource: {
        type: "Microsoft.Devices/IotHubs",
        consumerGroupName: "sdkconsumergroup",
        endpoint: "messages/events",
        iotHubNamespace: "iothub",
        sharedAccessPolicyKey: "sharedAccessPolicyKey=",
        sharedAccessPolicyName: "owner",
      },
      serialization: { type: "Avro" },
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.createOrReplace(resourceGroupName, jobName, inputName, input);
  console.log(result);
}

createAStreamIoTHubInputWithAvroSerialization().catch(console.error);

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Sample Response

Status code:

201

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

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970",
  "name": "input7970",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.Devices/IotHubs",
      "properties": {
        "iotHubNamespace": "iothub",
        "sharedAccessPolicyName": "owner",
        "endpoint": "messages/events",
        "consumerGroupName": "sdkconsumergroup"
      }
    },
    "serialization": {
      "type": "Avro",
      "properties": {}
    }
  }
}

Status code:

200

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

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970",
  "name": "input7970",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.Devices/IotHubs",
      "properties": {
        "iotHubNamespace": "iothub",
        "sharedAccessPolicyName": "owner",
        "endpoint": "messages/events",
        "consumerGroupName": "sdkconsumergroup"
      }
    },
    "serialization": {
      "type": "Avro",
      "properties": {}
    }
  }
}

Definisi

Nama	Deskripsi
AuthenticationMode	Mode Autentikasi. Mode yang valid adalah ConnectionString, Msi dan 'UserToken'.
AvroSerialization	Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format Avro.
AzureSqlReferenceInputDataSource	Menjelaskan sumber data input referensi database Azure SQL.
BlobReferenceInputDataSource	Menjelaskan sumber data input blob yang berisi data referensi.
BlobStreamInputDataSource	Menjelaskan sumber data input blob yang berisi data aliran.
Compression	Menjelaskan bagaimana data input dikompresi
CompressionType	Menunjukkan jenis kompresi yang digunakan input. Diperlukan pada permintaan PUT (CreateOrReplace).
CsvSerialization	Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format CSV.
DiagnosticCondition	Kondisi yang berlaku untuk sumber daya, atau untuk pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.
Diagnostics	Menjelaskan kondisi yang berlaku untuk Input, Output, atau pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.
Encoding	Menentukan pengodean data masuk dalam kasus input dan pengodean data keluar dalam kasus output.
Error	Representasi kesalahan umum.
EventHubStreamInputDataSource	Menjelaskan sumber data input Pusat Aktivitas yang berisi data aliran.
EventHubV2StreamInputDataSource	Menjelaskan sumber data input Pusat Aktivitas yang berisi data aliran.
EventSerializationType	Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).
FileReferenceInputDataSource	Menjelaskan sumber data input file yang berisi data referensi.
GatewayMessageBusStreamInputDataSource	Menjelaskan sumber data input blob yang berisi data aliran.
Input	Objek input, berisi semua informasi yang terkait dengan input bernama. Semua input terkandung di bawah pekerjaan streaming.
IoTHubStreamInputDataSource	Menjelaskan sumber data input IoT Hub yang berisi data aliran.
JsonOutputSerializationFormat	Menentukan format JSON tempat output akan ditulis. Nilai yang saat ini didukung adalah 'lineSeparated' yang menunjukkan output akan diformat dengan memisahkan setiap objek JSON yang dipisahkan oleh baris baru dan 'array' yang menunjukkan output akan diformat sebagai array objek JSON.
JsonSerialization	Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format JSON.
ParquetSerialization	Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format Parquet.
ReferenceInputProperties	Properti yang terkait dengan input yang berisi data referensi.
RefreshType	Menunjukkan jenis opsi refresh data.
StorageAccount	Properti yang terkait dengan akun Azure Storage
StreamInputProperties	Properti yang terkait dengan input yang berisi data aliran.

AuthenticationMode

Mode Autentikasi. Mode yang valid adalah ConnectionString, Msi dan 'UserToken'.

Nama	Jenis	Deskripsi
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format Avro.

Nama	Jenis	Deskripsi
type	string: Avro	Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).

AzureSqlReferenceInputDataSource

Menjelaskan sumber data input referensi database Azure SQL.

Nama	Jenis	Deskripsi
properties.database	string	Elemen ini dikaitkan dengan elemen sumber data. Ini adalah nama database tempat output akan ditulis.
properties.deltaSnapshotQuery	string	Elemen ini dikaitkan dengan elemen sumber data. Kueri ini digunakan untuk mengambil perubahan inkremental dari database SQL. Untuk menggunakan opsi ini, sebaiknya gunakan tabel temporal di Azure SQL Database.
properties.fullSnapshotQuery	string	Elemen ini dikaitkan dengan elemen sumber data. Kueri ini digunakan untuk mengambil data dari database sql.
properties.password	string	Elemen ini dikaitkan dengan elemen sumber data. Ini adalah kata sandi yang akan digunakan untuk menyambungkan ke instans SQL Database.
properties.refreshRate	string	Elemen ini dikaitkan dengan elemen sumber data. Ini menunjukkan seberapa sering data akan diambil dari database. Ini adalah format DateTime.
properties.refreshType	RefreshType	Menunjukkan jenis opsi refresh data.
properties.server	string	Elemen ini dikaitkan dengan elemen sumber data. Ini adalah nama server yang berisi database yang akan ditulis.
properties.table	string	Elemen ini dikaitkan dengan elemen sumber data. Nama tabel dalam database Azure SQL..
properties.user	string	Elemen ini dikaitkan dengan elemen sumber data. Ini adalah nama pengguna yang akan digunakan untuk menyambungkan ke instans SQL Database.
type	string: Microsoft.Sql/Server/Database	Menunjukkan jenis sumber data input yang berisi data referensi. Diperlukan pada permintaan PUT (CreateOrReplace).

BlobReferenceInputDataSource

Menjelaskan sumber data input blob yang berisi data referensi.

Nama	Jenis	Nilai Default	Deskripsi
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode Autentikasi.
properties.container	string		Nama kontainer dalam akun Penyimpanan terkait. Kontainer ini berisi blob yang akan dibaca atau ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.dateFormat	string		Format tanggal. Di mana pun {date} muncul di pathPattern, nilai properti ini digunakan sebagai format tanggal sebagai gantinya.
properties.pathPattern	string		Pola jalur blob. Bukan ekspresi reguler. Ini mewakili pola terhadap nama blob mana yang akan dicocokkan untuk menentukan apakah nama tersebut harus disertakan sebagai input atau output ke pekerjaan atau tidak. Lihat https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input atau https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output untuk penjelasan dan contoh yang lebih rinci.
properties.storageAccounts	StorageAccount[]		Daftar satu atau beberapa akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.timeFormat	string		Format waktu. Di mana pun {time} muncul di pathPattern, nilai properti ini digunakan sebagai format waktu sebagai gantinya.
type	string: Microsoft.Storage/Blob		Menunjukkan jenis sumber data input yang berisi data referensi. Diperlukan pada permintaan PUT (CreateOrReplace).

BlobStreamInputDataSource

Menjelaskan sumber data input blob yang berisi data aliran.

Nama	Jenis	Nilai Default	Deskripsi
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode Autentikasi.
properties.container	string		Nama kontainer dalam akun Penyimpanan terkait. Kontainer ini berisi blob yang akan dibaca atau ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.dateFormat	string		Format tanggal. Di mana pun {date} muncul di pathPattern, nilai properti ini digunakan sebagai format tanggal sebagai gantinya.
properties.pathPattern	string		Pola jalur blob. Bukan ekspresi reguler. Ini mewakili pola yang mencocokkan nama blob mana yang akan dicocokkan untuk menentukan apakah nama tersebut harus disertakan sebagai input atau output ke pekerjaan atau tidak. Lihat https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input atau https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output untuk penjelasan dan contoh yang lebih rinci.
properties.sourcePartitionCount	integer		Jumlah partisi sumber data input blob. Rentang 1 - 1024.
properties.storageAccounts	StorageAccount[]		Daftar satu atau beberapa akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.timeFormat	string		Format waktu. Di mana pun {time} muncul di pathPattern, nilai properti ini digunakan sebagai format waktu sebagai gantinya.
type	string: Microsoft.Storage/Blob		Menunjukkan jenis sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

Compression

Menjelaskan bagaimana data input dikompresi

Nama	Jenis	Nilai Default	Deskripsi
type	CompressionType	None	Menunjukkan jenis kompresi yang digunakan input. Diperlukan pada permintaan PUT (CreateOrReplace).

CompressionType

Menunjukkan jenis kompresi yang digunakan input. Diperlukan pada permintaan PUT (CreateOrReplace).

Nama	Jenis	Deskripsi
Deflate	string
GZip	string
None	string

CsvSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format CSV.

Nama	Jenis	Deskripsi
properties.encoding	Encoding	Menentukan pengodean data masuk dalam kasus input dan pengodean data keluar dalam kasus output. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.fieldDelimiter	string	Menentukan pemisah yang akan digunakan untuk memisahkan rekaman nilai yang dipisahkan koma (CSV). Lihat https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input atau https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output untuk daftar nilai yang didukung. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Csv	Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).

DiagnosticCondition

Kondisi yang berlaku untuk sumber daya, atau untuk pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.

Nama	Jenis	Deskripsi
code	string	Kode diagnostik buram.
message	string	Pesan yang dapat dibaca manusia yang menjelaskan kondisi secara rinci. Dilokalkan dalam Accept-Language permintaan klien.
since	string	Tanda waktu UTC saat kondisi dimulai. Pelanggan harus dapat menemukan peristiwa yang sesuai dalam log ops sekitar waktu ini.

Diagnostics

Menjelaskan kondisi yang berlaku untuk Input, Output, atau pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.

Nama	Jenis	Deskripsi
conditions	DiagnosticCondition[]	Kumpulan nol atau lebih kondisi yang berlaku untuk sumber daya, atau untuk pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.

Encoding

Menentukan pengodean data masuk dalam kasus input dan pengodean data keluar dalam kasus output.

Nama	Jenis	Deskripsi
UTF8	string

Error

Representasi kesalahan umum.

Nama	Jenis	Deskripsi
error	Error	Properti definisi kesalahan.

EventHubStreamInputDataSource

Menjelaskan sumber data input Pusat Aktivitas yang berisi data aliran.

Nama	Jenis	Nilai Default	Deskripsi
authenticationMode	AuthenticationMode	ConnectionString	Mode Autentikasi.
properties.consumerGroupName	string		Nama Grup Konsumen Pusat Aktivitas yang harus digunakan untuk membaca peristiwa dari Pusat Aktivitas. Menentukan nama grup konsumen yang berbeda untuk beberapa input memungkinkan masing-masing input tersebut menerima peristiwa yang sama dari Pusat Aktivitas. Jika tidak ditentukan, input menggunakan grup konsumen default Pusat Aktivitas.
properties.eventHubName	string		Nama Pusat Aktivitas. Diperlukan pada permintaan PUT (CreateOrReplace).
serviceBusNamespace	string		Namespace layanan yang terkait dengan Event Hub yang diinginkan, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Kunci kebijakan akses bersama untuk kebijakan akses bersama yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nama kebijakan akses bersama untuk Pusat Aktivitas, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Menunjukkan jenis sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

EventHubV2StreamInputDataSource

Menjelaskan sumber data input Pusat Aktivitas yang berisi data aliran.

Nama	Jenis	Nilai Default	Deskripsi
authenticationMode	AuthenticationMode	ConnectionString	Mode Autentikasi.
properties.consumerGroupName	string		Nama Grup Konsumen Pusat Aktivitas yang harus digunakan untuk membaca peristiwa dari Pusat Aktivitas. Menentukan nama grup konsumen yang berbeda untuk beberapa input memungkinkan masing-masing input tersebut menerima peristiwa yang sama dari Pusat Aktivitas. Jika tidak ditentukan, input menggunakan grup konsumen default Pusat Aktivitas.
properties.eventHubName	string		Nama Pusat Aktivitas. Diperlukan pada permintaan PUT (CreateOrReplace).
serviceBusNamespace	string		Namespace layanan yang terkait dengan Event Hub yang diinginkan, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Kunci kebijakan akses bersama untuk kebijakan akses bersama yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nama kebijakan akses bersama untuk Pusat Aktivitas, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Menunjukkan jenis sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

EventSerializationType

Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).

Nama	Jenis	Deskripsi
Avro	string
Csv	string
Json	string
Parquet	string

FileReferenceInputDataSource

Menjelaskan sumber data input file yang berisi data referensi.

Nama	Jenis	Deskripsi
properties.path	string	Jalur file.
type	string: File	Menunjukkan jenis sumber data input yang berisi data referensi. Diperlukan pada permintaan PUT (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Menjelaskan sumber data input blob yang berisi data aliran.

Nama	Jenis	Deskripsi
properties.topic	string	Nama topik Bus Layanan.
type	string: GatewayMessageBus	Menunjukkan jenis sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

Input

Objek input, berisi semua informasi yang terkait dengan input bernama. Semua input terkandung di bawah pekerjaan streaming.

Nama	Jenis	Deskripsi
id	string	ID sumber daya
name	string	Nama sumber daya
properties	InputProperties: ReferenceInputProperties StreamInputProperties	Properti yang terkait dengan input. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string	Jenis Sumber Daya

IoTHubStreamInputDataSource

Menjelaskan sumber data input IoT Hub yang berisi data aliran.

Nama	Jenis	Deskripsi
properties.consumerGroupName	string	Nama Grup Konsumen IoT Hub yang harus digunakan untuk membaca peristiwa dari IoT Hub. Jika tidak ditentukan, input menggunakan grup konsumen default Iot Hub.
properties.endpoint	string	Titik akhir IoT Hub untuk disambungkan (yaitu pesan/peristiwa, pesan/operasiMonitoringEvents, dll.).
properties.iotHubNamespace	string	Nama atau URI IoT Hub. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string	Kunci kebijakan akses bersama untuk kebijakan akses bersama yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string	Nama kebijakan akses bersama untuk IoT Hub. Kebijakan ini harus berisi setidaknya izin Sambungan layanan. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Menunjukkan jenis sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

JsonOutputSerializationFormat

Menentukan format JSON tempat output akan ditulis. Nilai yang saat ini didukung adalah 'lineSeparated' yang menunjukkan output akan diformat dengan memisahkan setiap objek JSON yang dipisahkan oleh baris baru dan 'array' yang menunjukkan output akan diformat sebagai array objek JSON.

Nama	Jenis	Deskripsi
Array	string
LineSeparated	string

JsonSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format JSON.

Nama	Jenis	Deskripsi
properties.encoding	Encoding	Menentukan pengodean data masuk dalam kasus input dan pengodean data keluar dalam kasus output. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Properti ini hanya berlaku untuk serialisasi JSON output saja. Ini tidak berlaku untuk input. Properti ini menentukan format JSON tempat output akan ditulis. Nilai yang saat ini didukung adalah 'lineSeparated' yang menunjukkan output akan diformat dengan memisahkan setiap objek JSON yang dipisahkan oleh baris baru dan 'array' yang menunjukkan output akan diformat sebagai array objek JSON. Nilai defaultnya adalah 'lineSeparated' jika dibiarkan null.
type	string: Json	Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).

ParquetSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format Parquet.

Nama	Jenis	Deskripsi
type	string: Parquet	Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).

ReferenceInputProperties

Properti yang terkait dengan input yang berisi data referensi.

Nama	Jenis	Deskripsi
compression	Compression	Menjelaskan bagaimana data input dikompresi
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Menjelaskan sumber data input yang berisi data referensi. Diperlukan pada permintaan PUT (CreateOrReplace).
diagnostics	Diagnostics	Menjelaskan kondisi yang berlaku untuk Input, Output, atau pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.
etag	string	Tag entitas saat ini untuk input. Ini adalah string buram. Anda dapat menggunakannya untuk mendeteksi apakah sumber daya telah berubah di antara permintaan. Anda juga dapat menggunakannya di header If-Match atau If-None-Match untuk operasi tulis untuk konkurensi optimis.
partitionKey	string	partitionKey Menjelaskan kunci dalam data input yang digunakan untuk mempartisi data input
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Reference	Menunjukkan apakah input adalah sumber data referensi atau data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

RefreshType

Menunjukkan jenis opsi refresh data.

Nama	Jenis	Deskripsi
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

StorageAccount

Properti yang terkait dengan akun Azure Storage

Nama	Jenis	Deskripsi
accountKey	string	Kunci akun untuk akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).
accountName	string	Nama akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).

StreamInputProperties

Properti yang terkait dengan input yang berisi data aliran.

Nama	Jenis	Deskripsi
compression	Compression	Menjelaskan bagaimana data input dikompresi
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Menjelaskan sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).
diagnostics	Diagnostics	Menjelaskan kondisi yang berlaku untuk Input, Output, atau pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.
etag	string	Tag entitas saat ini untuk input. Ini adalah string buram. Anda dapat menggunakannya untuk mendeteksi apakah sumber daya telah berubah di antara permintaan. Anda juga dapat menggunakannya di header If-Match atau If-None-Match untuk operasi tulis untuk konkurensi optimis.
partitionKey	string	partitionKey Menjelaskan kunci dalam data input yang digunakan untuk mempartisi data input
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Stream	Menunjukkan apakah input adalah sumber data referensi atau data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).