Inputs - Create Or Replace

Usługa:: Stream Analytics

Wersja interfejsu API:: 2020-03-01

Tworzy dane wejściowe lub zastępuje już istniejące dane wejściowe w ramach istniejącego zadania przesyłania strumieniowego.

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

Parametry identyfikatora URI

Nazwa	W	Wymagane	Typ	Opis
inputName	path	True	string	Nazwa danych wejściowych.
jobName	path	True	string	Nazwa zadania przesyłania strumieniowego.
resourceGroupName	path	True	string minLength: 1 maxLength: 90 pattern: ^[-\w\._]+$	Nazwa grupy zasobów. Nazwa jest niewrażliwa na wielkość liter.
subscriptionId	path	True	string minLength: 1	Identyfikator subskrypcji docelowej.
api-version	query	True	string minLength: 1	Wersja interfejsu API do użycia dla tej operacji.

Nagłówek żądania

Nazwa	Wymagane	Typ	Opis
If-Match		string	Element ETag danych wejściowych. Pomiń tę wartość, aby zawsze zastępować bieżące dane wejściowe. Określ ostatnio widzianą wartość elementu ETag, aby zapobiec przypadkowemu zastępowaniu współbieżnych zmian.
If-None-Match		string	Ustaw wartość "*", aby zezwolić na utworzenie nowych danych wejściowych, ale aby zapobiec aktualizowaniu istniejących danych wejściowych. Inne wartości spowodują odpowiedź 412 Warunek wstępny Niepowodzenie.

Treść żądania

Nazwa	Typ	Opis
name	string	Nazwa zasobu
properties	InputProperties: StreamInputProperties ReferenceInputProperties	Właściwości skojarzone z danymi wejściowymi. Wymagane w żądaniach PUT (CreateOrReplace).

Odpowiedzi

Nazwa	Typ	Opis
200 OK	Input	Dane wejściowe zostały pomyślnie utworzone lub zastąpione. Nagłówki ETag: string
201 Created	Input	Dane wejściowe zostały pomyślnie utworzone lub zastąpione. Nagłówki ETag: string
Other Status Codes	Error	Błąd.

Nazwa

Typ

Opis

200 OK

Input

Dane wejściowe zostały pomyślnie utworzone lub zastąpione.

Nagłówki

ETag: string

201 Created

Input

Dane wejściowe zostały pomyślnie utworzone lub zastąpione.

Nagłówki

ETag: string

Other Status Codes

Error

Błąd.

Zabezpieczenia

azure_auth

Przepływ protokołu OAuth2 usługi Azure Active Directory

Typ: oauth2
Flow: implicit
Adres URL autoryzacji: https://login.microsoftonline.com/common/oauth2/authorize

Zakresy

Nazwa	Opis
user_impersonation	personifikacja konta użytkownika

Przykłady

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

Przykładowe żądanie

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


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

Przykładowa odpowiedź

Kod stanu:: 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"
      }
    }
  }
}

Kod stanu:: 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

Przykładowe żądanie

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


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

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

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

Przykładowa odpowiedź

Kod stanu:: 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"
      }
    }
  }
}

Kod stanu:: 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

Przykładowe żądanie

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


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

Przykładowa odpowiedź

Kod stanu:: 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"
      }
    }
  }
}

Kod stanu:: 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

Przykładowe żądanie

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


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

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

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

Przykładowa odpowiedź

Kod stanu:: 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"
      }
    }
  }
}

Kod stanu:: 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

Przykładowe żądanie

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


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

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

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

Przykładowa odpowiedź

Kod stanu:: 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"
      }
    }
  }
}

Kod stanu:: 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

Przykładowe żądanie

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


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

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

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

Przykładowa odpowiedź

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

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

Definicje

Nazwa	Opis
AuthenticationMode	Tryb uwierzytelniania. Prawidłowe tryby to `ConnectionString`, `Msi` i "UserToken".
AvroSerialization	Opisuje sposób serializacji danych wejściowych lub serializowanych danych podczas zapisywania danych wyjściowych w formacie Avro.
AzureSqlReferenceInputDataSource	Opisuje źródło danych wejściowych w bazie danych Azure SQL Database.
BlobReferenceInputDataSource	Opisuje źródło danych wejściowych obiektu blob, które zawiera dane referencyjne.
BlobStreamInputDataSource	Opisuje źródło danych wejściowych obiektu blob, które zawiera dane strumienia.
Compression	Opisuje sposób kompresji danych wejściowych
CompressionType	Wskazuje typ kompresji używanej przez dane wejściowe. Wymagane w żądaniach PUT (CreateOrReplace).
CsvSerialization	Opisuje, jak dane wejściowe są serializowane lub jak dane są serializowane podczas zapisywania w danych wyjściowych w formacie CSV.
DiagnosticCondition	Warunek mający zastosowanie do zasobu lub ogólnego zadania, który gwarantuje uwagę klienta.
Diagnostics	Opisuje warunki dotyczące danych wejściowych, wyjściowych lub ogólnego zadania, które uzasadniają uwagę klienta.
Encoding	Określa kodowanie danych przychodzących w przypadku danych wejściowych i kodowanie danych wychodzących w przypadku danych wyjściowych.
Error	Typowa reprezentacja błędu.
EventHubStreamInputDataSource	Opisuje źródło danych wejściowych centrum zdarzeń, które zawiera dane strumienia.
EventHubV2StreamInputDataSource	Opisuje źródło danych wejściowych centrum zdarzeń, które zawiera dane strumienia.
EventSerializationType	Wskazuje typ serializacji używanej przez dane wejściowe lub wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
FileReferenceInputDataSource	Opisuje źródło danych wejściowych pliku, które zawiera dane referencyjne.
GatewayMessageBusStreamInputDataSource	Opisuje źródło danych wejściowych obiektu blob, które zawiera dane strumienia.
Input	Obiekt wejściowy zawierający wszystkie informacje skojarzone z nazwanymi danymi wejściowymi. Wszystkie dane wejściowe są zawarte w zadaniu przesyłania strumieniowego.
IoTHubStreamInputDataSource	Opisuje źródło danych wejściowych usługi IoT Hub, które zawiera dane strumienia.
JsonOutputSerializationFormat	Określa format JSON, w który będą zapisywane dane wyjściowe. Obecnie obsługiwane wartości to "lineSeparated", co wskazuje, że dane wyjściowe będą formatowane przez każdy obiekt JSON oddzielony przez nowy wiersz i tablicę wskazującą, że dane wyjściowe będą formatowane jako tablica obiektów JSON.
JsonSerialization	Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie JSON.
ParquetSerialization	Opisuje sposób serializacji danych wejściowych lub serializowanych danych podczas zapisywania ich w danych wyjściowych w formacie Parquet.
ReferenceInputProperties	Właściwości skojarzone z danymi wejściowymi zawierającymi dane referencyjne.
RefreshType	Wskazuje typ opcji odświeżania danych.
StorageAccount	Właściwości skojarzone z kontem usługi Azure Storage
StreamInputProperties	Właściwości skojarzone z danymi wejściowymi zawierającymi dane strumienia.

AuthenticationMode

Wyliczanie

Tryb uwierzytelniania. Prawidłowe tryby to ConnectionString, Msi i "UserToken".

Wartość	Opis
Msi
UserToken
ConnectionString

AvroSerialization

Objekt

Opisuje sposób serializacji danych wejściowych lub serializowanych danych podczas zapisywania danych wyjściowych w formacie Avro.

Nazwa	Typ	Opis
type	string: Avro	Wskazuje typ serializacji używanej przez dane wejściowe lub wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

AzureSqlReferenceInputDataSource

Objekt

Opisuje źródło danych wejściowych w bazie danych Azure SQL Database.

Nazwa	Typ	Opis
properties.database	string	Ten element jest skojarzony z elementem źródła danych. Jest to nazwa bazy danych, do których zostaną zapisane dane wyjściowe.
properties.deltaSnapshotQuery	string	Ten element jest skojarzony z elementem źródła danych. To zapytanie służy do pobierania przyrostowych zmian z bazy danych SQL. Aby użyć tej opcji, zalecamy używanie tabel czasowych w usłudze Azure SQL Database.
properties.fullSnapshotQuery	string	Ten element jest skojarzony z elementem źródła danych. To zapytanie służy do pobierania danych z bazy danych SQL.
properties.password	string	Ten element jest skojarzony z elementem źródła danych. Jest to hasło, które będzie używane do nawiązywania połączenia z wystąpieniem usługi SQL Database.
properties.refreshRate	string	Ten element jest skojarzony z elementem źródła danych. Wskazuje to, jak często dane będą pobierane z bazy danych. Jest to format DateTime.
properties.refreshType	RefreshType	Wskazuje typ opcji odświeżania danych.
properties.server	string	Ten element jest skojarzony z elementem źródła danych. Jest to nazwa serwera, który zawiera bazę danych, do których zostanie zapisana.
properties.table	string	Ten element jest skojarzony z elementem źródła danych. Nazwa tabeli w bazie danych Azure SQL Database.
properties.user	string	Ten element jest skojarzony z elementem źródła danych. Jest to nazwa użytkownika, która będzie używana do nawiązywania połączenia z wystąpieniem usługi SQL Database.
type	string: Microsoft.Sql/Server/Database	Wskazuje typ wejściowego źródła danych zawierającego dane referencyjne. Wymagane w żądaniach PUT (CreateOrReplace).

BlobReferenceInputDataSource

Objekt

Opisuje źródło danych wejściowych obiektu blob, które zawiera dane referencyjne.

Nazwa	Typ	Domyślna wartość	Opis
properties.authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.container	string		Nazwa kontenera na skojarzonym koncie magazynu. Ten kontener zawiera obiekty blob do odczytu lub zapisu. Wymagane w żądaniach PUT (CreateOrReplace).
properties.dateFormat	string		Format daty. Gdziekolwiek {date} pojawia się w pathPattern, wartość tej właściwości jest używana jako format daty.
properties.pathPattern	string		Wzorzec ścieżki obiektu blob. Nie jest wyrażeniem regularnym. Reprezentuje wzorzec, względem którego nazwy obiektów blob będą dopasowywane w celu określenia, czy powinny one być uwzględniane jako dane wejściowe lub wyjściowe zadania. Aby uzyskać bardziej szczegółowe wyjaśnienie i przykład, zobacz https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input lub https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output.
properties.storageAccounts	StorageAccount[]		Lista co najmniej jednego konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
properties.timeFormat	string		Format godziny. Gdziekolwiek {time} pojawia się w pathPattern, wartość tej właściwości jest używana jako format czasu.
type	string: Microsoft.Storage/Blob		Wskazuje typ wejściowego źródła danych zawierającego dane referencyjne. Wymagane w żądaniach PUT (CreateOrReplace).

BlobStreamInputDataSource

Objekt

Opisuje źródło danych wejściowych obiektu blob, które zawiera dane strumienia.

Nazwa	Typ	Domyślna wartość	Opis
properties.authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.container	string		Nazwa kontenera na skojarzonym koncie magazynu. Ten kontener zawiera obiekty blob do odczytu lub zapisu. Wymagane w żądaniach PUT (CreateOrReplace).
properties.dateFormat	string		Format daty. Gdziekolwiek {date} pojawia się w pathPattern, wartość tej właściwości jest używana jako format daty.
properties.pathPattern	string		Wzorzec ścieżki obiektu blob. Nie jest wyrażeniem regularnym. Reprezentuje wzorzec, względem którego nazwy obiektów blob będą dopasowywane w celu określenia, czy powinny one być uwzględniane jako dane wejściowe lub wyjściowe zadania. Aby uzyskać bardziej szczegółowe wyjaśnienie i przykład, zobacz https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input lub https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output.
properties.sourcePartitionCount	integer (int32)		Liczba partycji źródła danych wejściowych obiektu blob. Zakres 1 – 1024.
properties.storageAccounts	StorageAccount[]		Lista co najmniej jednego konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
properties.timeFormat	string		Format godziny. Gdziekolwiek {time} pojawia się w pathPattern, wartość tej właściwości jest używana jako format czasu.
type	string: Microsoft.Storage/Blob		Wskazuje typ wejściowego źródła danych zawierającego dane strumienia. Wymagane w żądaniach PUT (CreateOrReplace).

Compression

Objekt

Opisuje sposób kompresji danych wejściowych

Nazwa	Typ	Domyślna wartość	Opis
type	CompressionType	None	Wskazuje typ kompresji używanej przez dane wejściowe. Wymagane w żądaniach PUT (CreateOrReplace).

CompressionType

Wyliczanie

Wskazuje typ kompresji używanej przez dane wejściowe. Wymagane w żądaniach PUT (CreateOrReplace).

Wartość	Opis
None
GZip
Deflate

CsvSerialization

Objekt

Opisuje, jak dane wejściowe są serializowane lub jak dane są serializowane podczas zapisywania w danych wyjściowych w formacie CSV.

Nazwa	Typ	Opis
properties.encoding	Encoding	Określa kodowanie danych przychodzących w przypadku danych wejściowych i kodowanie danych wychodzących w przypadku danych wyjściowych. Wymagane w żądaniach PUT (CreateOrReplace).
properties.fieldDelimiter	string	Określa ogranicznik, który będzie używany do oddzielania rekordów wartości rozdzielanych przecinkami (CSV). Aby uzyskać listę obsługiwanych wartości, zobacz https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input lub https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Csv	Wskazuje typ serializacji używanej przez dane wejściowe lub wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

DiagnosticCondition

Objekt

Warunek mający zastosowanie do zasobu lub ogólnego zadania, który gwarantuje uwagę klienta.

Nazwa	Typ	Opis
code	string	Nieprzezroczysty kod diagnostyczny.
message	string	Czytelny dla człowieka komunikat opisujący szczegółowo warunek. Zlokalizowane w Accept-Language żądania klienta.
since	string	Sygnatura czasowa UTC czasu rozpoczęcia warunku. Klienci powinni mieć możliwość znalezienia odpowiedniego zdarzenia w dzienniku operacji w tym czasie.

Diagnostics

Objekt

Opisuje warunki dotyczące danych wejściowych, wyjściowych lub ogólnego zadania, które uzasadniają uwagę klienta.

Nazwa	Typ	Opis
conditions	DiagnosticCondition[]	Kolekcja zera lub większej liczby warunków mających zastosowanie do zasobu lub ogólnego zadania, które uzasadniają uwagę klienta.

Encoding

Wyliczanie

Określa kodowanie danych przychodzących w przypadku danych wejściowych i kodowanie danych wychodzących w przypadku danych wyjściowych.

Wartość	Opis
UTF8

Error

Objekt

Typowa reprezentacja błędu.

Nazwa	Typ	Opis
error	Error	Właściwości definicji błędu.

EventHubStreamInputDataSource

Objekt

Opisuje źródło danych wejściowych centrum zdarzeń, które zawiera dane strumienia.

Nazwa	Typ	Domyślna wartość	Opis
authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.consumerGroupName	string		Nazwa grupy odbiorców centrum zdarzeń, która powinna służyć do odczytywania zdarzeń z centrum zdarzeń. Określanie unikatowych nazw grup odbiorców dla wielu danych wejściowych umożliwia każdemu z tych danych wejściowych odbieranie tych samych zdarzeń z centrum zdarzeń. Jeśli nie zostanie określony, dane wejściowe używają domyślnej grupy odbiorców centrum zdarzeń.
properties.eventHubName	string		Nazwa centrum zdarzeń. Wymagane w żądaniach PUT (CreateOrReplace).
serviceBusNamespace	string		Przestrzeń nazw skojarzona z żądanym centrum zdarzeń, kolejką usługi Service Bus, tematem usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Klucz zasad dostępu współdzielonego dla określonych zasad dostępu współdzielonego. Wymagane w żądaniach PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nazwa zasad dostępu współdzielonego dla centrum zdarzeń, kolejki usługi Service Bus, tematu usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Wskazuje typ wejściowego źródła danych zawierającego dane strumienia. Wymagane w żądaniach PUT (CreateOrReplace).

EventHubV2StreamInputDataSource

Objekt

Opisuje źródło danych wejściowych centrum zdarzeń, które zawiera dane strumienia.

Nazwa	Typ	Domyślna wartość	Opis
authenticationMode	AuthenticationMode	ConnectionString	Tryb uwierzytelniania.
properties.consumerGroupName	string		Nazwa grupy odbiorców centrum zdarzeń, która powinna służyć do odczytywania zdarzeń z centrum zdarzeń. Określanie unikatowych nazw grup odbiorców dla wielu danych wejściowych umożliwia każdemu z tych danych wejściowych odbieranie tych samych zdarzeń z centrum zdarzeń. Jeśli nie zostanie określony, dane wejściowe używają domyślnej grupy odbiorców centrum zdarzeń.
properties.eventHubName	string		Nazwa centrum zdarzeń. Wymagane w żądaniach PUT (CreateOrReplace).
serviceBusNamespace	string		Przestrzeń nazw skojarzona z żądanym centrum zdarzeń, kolejką usługi Service Bus, tematem usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Klucz zasad dostępu współdzielonego dla określonych zasad dostępu współdzielonego. Wymagane w żądaniach PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nazwa zasad dostępu współdzielonego dla centrum zdarzeń, kolejki usługi Service Bus, tematu usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Wskazuje typ wejściowego źródła danych zawierającego dane strumienia. Wymagane w żądaniach PUT (CreateOrReplace).

EventSerializationType

Wyliczanie

Wskazuje typ serializacji używanej przez dane wejściowe lub wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

Wartość	Opis
Csv
Avro
Json
Parquet

FileReferenceInputDataSource

Objekt

Opisuje źródło danych wejściowych pliku, które zawiera dane referencyjne.

Nazwa	Typ	Opis
properties.path	string	Ścieżka pliku.
type	string: File	Wskazuje typ wejściowego źródła danych zawierającego dane referencyjne. Wymagane w żądaniach PUT (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Objekt

Opisuje źródło danych wejściowych obiektu blob, które zawiera dane strumienia.

Nazwa	Typ	Opis
properties.topic	string	Nazwa tematu usługi Service Bus.
type	string: GatewayMessageBus	Wskazuje typ wejściowego źródła danych zawierającego dane strumienia. Wymagane w żądaniach PUT (CreateOrReplace).

Input

Objekt

Obiekt wejściowy zawierający wszystkie informacje skojarzone z nazwanymi danymi wejściowymi. Wszystkie dane wejściowe są zawarte w zadaniu przesyłania strumieniowego.

Nazwa	Typ	Opis
id	string	Identyfikator zasobu
name	string	Nazwa zasobu
properties	InputProperties: ReferenceInputProperties StreamInputProperties	Właściwości skojarzone z danymi wejściowymi. Wymagane w żądaniach PUT (CreateOrReplace).
type	string	Typ zasobu

IoTHubStreamInputDataSource

Objekt

Opisuje źródło danych wejściowych usługi IoT Hub, które zawiera dane strumienia.

Nazwa	Typ	Opis
properties.consumerGroupName	string	Nazwa grupy odbiorców usługi IoT Hub, która powinna służyć do odczytywania zdarzeń z usługi IoT Hub. Jeśli nie zostanie określony, dane wejściowe używają domyślnej grupy odbiorców usługi Iot Hub.
properties.endpoint	string	Punkt końcowy usługi IoT Hub do nawiązania połączenia (tj. komunikaty/zdarzenia, komunikaty/operacjeMonitorowanieEvents itp.).
properties.iotHubNamespace	string	Nazwa lub identyfikator URI usługi IoT Hub. Wymagane w żądaniach PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string	Klucz zasad dostępu współdzielonego dla określonych zasad dostępu współdzielonego. Wymagane w żądaniach PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string	Nazwa zasad dostępu współdzielonego dla usługi IoT Hub. Te zasady muszą zawierać co najmniej uprawnienie Service Connect. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Wskazuje typ wejściowego źródła danych zawierającego dane strumienia. Wymagane w żądaniach PUT (CreateOrReplace).

JsonOutputSerializationFormat

Wyliczanie

Określa format JSON, w który będą zapisywane dane wyjściowe. Obecnie obsługiwane wartości to "lineSeparated", co wskazuje, że dane wyjściowe będą formatowane przez każdy obiekt JSON oddzielony przez nowy wiersz i tablicę wskazującą, że dane wyjściowe będą formatowane jako tablica obiektów JSON.

Wartość	Opis
LineSeparated
Array

JsonSerialization

Objekt

Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie JSON.

Nazwa	Typ	Opis
properties.encoding	Encoding	Określa kodowanie danych przychodzących w przypadku danych wejściowych i kodowanie danych wychodzących w przypadku danych wyjściowych. Wymagane w żądaniach PUT (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Ta właściwość dotyczy tylko serializacji danych wyjściowych w formacie JSON. Nie ma zastosowania do danych wejściowych. Ta właściwość określa format JSON, w który będą zapisywane dane wyjściowe. Obecnie obsługiwane wartości to "lineSeparated", co wskazuje, że dane wyjściowe będą formatowane przez każdy obiekt JSON oddzielony przez nowy wiersz i tablicę wskazującą, że dane wyjściowe będą formatowane jako tablica obiektów JSON. Wartość domyślna to "lineSeparated", jeśli pozostawiono wartość null.
type	string: Json	Wskazuje typ serializacji używanej przez dane wejściowe lub wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

ParquetSerialization

Objekt

Opisuje sposób serializacji danych wejściowych lub serializowanych danych podczas zapisywania ich w danych wyjściowych w formacie Parquet.

Nazwa	Typ	Opis
type	string: Parquet	Wskazuje typ serializacji używanej przez dane wejściowe lub wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).

ReferenceInputProperties

Objekt

Właściwości skojarzone z danymi wejściowymi zawierającymi dane referencyjne.

Nazwa	Typ	Opis
compression	Compression	Opisuje sposób kompresji danych wejściowych
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Opisuje wejściowe źródło danych zawierające dane referencyjne. Wymagane w żądaniach PUT (CreateOrReplace).
diagnostics	Diagnostics	Opisuje warunki dotyczące danych wejściowych, wyjściowych lub ogólnego zadania, które uzasadniają uwagę klienta.
etag	string	Bieżący tag jednostki dla danych wejściowych. Jest to nieprzezroczystym ciągiem. Można go użyć do wykrywania, czy zasób zmienił się między żądaniami. Można go również używać w nagłówkach If-Match lub If-None-Match na potrzeby operacji zapisu w celu uzyskania optymistycznej współbieżności.
partitionKey	string	partitionKey opisuje klucz w danych wejściowych, które są używane do partycjonowania danych wejściowych
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Opisuje sposób serializacji danych wejściowych lub serializowanych danych podczas zapisywania w danych wyjściowych. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Reference	Wskazuje, czy dane wejściowe są źródłem danych referencyjnych, czy strumienia danych. Wymagane w żądaniach PUT (CreateOrReplace).

RefreshType

Wyliczanie

Wskazuje typ opcji odświeżania danych.

Wartość	Opis
Static
RefreshPeriodicallyWithFull
RefreshPeriodicallyWithDelta

StorageAccount

Objekt

Właściwości skojarzone z kontem usługi Azure Storage

Nazwa	Typ	Opis
accountKey	string	Klucz konta dla konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
accountName	string	Nazwa konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).

StreamInputProperties

Objekt

Właściwości skojarzone z danymi wejściowymi zawierającymi dane strumienia.

Nazwa	Typ	Opis
compression	Compression	Opisuje sposób kompresji danych wejściowych
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Opisuje wejściowe źródło danych, które zawiera dane strumienia. Wymagane w żądaniach PUT (CreateOrReplace).
diagnostics	Diagnostics	Opisuje warunki dotyczące danych wejściowych, wyjściowych lub ogólnego zadania, które uzasadniają uwagę klienta.
etag	string	Bieżący tag jednostki dla danych wejściowych. Jest to nieprzezroczystym ciągiem. Można go użyć do wykrywania, czy zasób zmienił się między żądaniami. Można go również używać w nagłówkach If-Match lub If-None-Match na potrzeby operacji zapisu w celu uzyskania optymistycznej współbieżności.
partitionKey	string	partitionKey opisuje klucz w danych wejściowych, które są używane do partycjonowania danych wejściowych
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Opisuje sposób serializacji danych wejściowych lub serializowanych danych podczas zapisywania w danych wyjściowych. Wymagane w żądaniach PUT (CreateOrReplace).
type	string: Stream	Wskazuje, czy dane wejściowe są źródłem danych referencyjnych, czy strumienia danych. Wymagane w żądaniach PUT (CreateOrReplace).

Udostępnij przez

Inputs - Create Or Replace

Parametry identyfikatora URI

Nagłówek żądania

Treść żądania

Odpowiedzi

Zabezpieczenia

azure_auth

Zakresy

Przykłady

Create a Gateway Message Bus input

Przykładowe żądanie

Przykładowa odpowiedź

Create a reference blob input with CSV serialization

Przykładowe żądanie

Przykładowa odpowiedź

Create a reference file input

Przykładowe żądanie

Przykładowa odpowiedź

Create a stream blob input with CSV serialization

Przykładowe żądanie

Przykładowa odpowiedź

Create a stream Event Hub input with JSON serialization

Przykładowe żądanie

Przykładowa odpowiedź

Create a stream IoT Hub input with Avro serialization

Przykładowe żądanie

Przykładowa odpowiedź

Definicje

AuthenticationMode

AvroSerialization

AzureSqlReferenceInputDataSource

BlobReferenceInputDataSource

BlobStreamInputDataSource

Compression

CompressionType

CsvSerialization

DiagnosticCondition

Diagnostics

Encoding

Error

EventHubStreamInputDataSource

EventHubV2StreamInputDataSource

EventSerializationType

FileReferenceInputDataSource

GatewayMessageBusStreamInputDataSource

Input

IoTHubStreamInputDataSource

JsonOutputSerializationFormat

JsonSerialization

ParquetSerialization

ReferenceInputProperties

RefreshType

StorageAccount

StreamInputProperties