Broker - Create Or Update

Tjänst:

IoT Operations

API-version:

2024-11-01

Skapa en BrokerResource

PUT https://management.azure.com/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.IoTOperations/instances/{instanceName}/brokers/{brokerName}?api-version=2024-11-01

URI-parametrar

Name	I	Obligatorisk	Typ	Description
brokerName	path	True	string minLength: 3 maxLength: 63 pattern: ^[a-z0-9][a-z0-9-]*[a-z0-9]$	Namnet på asynkron meddelandekö.
instanceName	path	True	string minLength: 3 maxLength: 63 pattern: ^[a-z0-9][a-z0-9-]*[a-z0-9]$	Namnet på instansen.
resourceGroupName	path	True	string minLength: 1 maxLength: 90	Namnet på resursgruppen. Namnet är skiftlägesokänsligt.
subscriptionId	path	True	string (uuid)	ID för målprenumerationen. Värdet måste vara ett UUID.
api-version	query	True	string minLength: 1	DEN API-version som ska användas för den här åtgärden.

Begärandetext

Name	Obligatorisk	Typ	Description
extendedLocation	True	ExtendedLocation	Resursens gränsplats.
properties		BrokerProperties	Resursspecifika egenskaper för den här resursen.

Svar

Name	Typ	Description
200 OK	BrokerResource	Resursen "BrokerResource"-uppdateringsåtgärden lyckades
201 Created	BrokerResource	Resursen "BrokerResource"-åtgärden lyckades Sidhuvuden Azure-AsyncOperation: string Retry-After: integer
Other Status Codes	ErrorResponse	Ett oväntat felsvar.

Säkerhet

azure_auth

Azure Active Directory OAuth2 Flow.

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

Omfattningar

Name	Description
user_impersonation	personifiera ditt användarkonto

Exempel

Broker_CreateOrUpdate

Broker_CreateOrUpdate_Complex

Broker_CreateOrUpdate_Minimal

Broker_CreateOrUpdate_Simple

Broker_CreateOrUpdate

Exempelbegäran

HTTP

PUT https://management.azure.com/subscriptions/F8C729F9-DF9C-4743-848F-96EE433D8E53/resourceGroups/rgiotoperations/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123?api-version=2024-11-01

{
  "properties": {
    "advanced": {
      "clients": {
        "maxSessionExpirySeconds": 3859,
        "maxMessageExpirySeconds": 3263,
        "maxPacketSizeBytes": 3029,
        "subscriberQueueLimit": {
          "length": 6,
          "strategy": "None"
        },
        "maxReceiveMaximum": 2365,
        "maxKeepAliveSeconds": 3744
      },
      "encryptInternalTraffic": "Enabled",
      "internalCerts": {
        "duration": "bchrc",
        "renewBefore": "xkafmpgjfifkwwrhkswtopdnne",
        "privateKey": {
          "algorithm": "Ec256",
          "rotationPolicy": "Always"
        }
      }
    },
    "cardinality": {
      "backendChain": {
        "partitions": 11,
        "redundancyFactor": 5,
        "workers": 15
      },
      "frontend": {
        "replicas": 2,
        "workers": 6
      }
    },
    "diagnostics": {
      "logs": {
        "level": "rnmwokumdmebpmfxxxzvvjfdywotav"
      },
      "metrics": {
        "prometheusPort": 7581
      },
      "selfCheck": {
        "mode": "Enabled",
        "intervalSeconds": 158,
        "timeoutSeconds": 14
      },
      "traces": {
        "mode": "Enabled",
        "cacheSizeMegabytes": 28,
        "selfTracing": {
          "mode": "Enabled",
          "intervalSeconds": 22
        },
        "spanChannelCapacity": 1000
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "500M",
      "ephemeralVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      },
      "persistentVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      }
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Tiny"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  }
}

Java

import com.azure.resourcemanager.iotoperations.models.AdvancedSettings;
import com.azure.resourcemanager.iotoperations.models.BackendChain;
import com.azure.resourcemanager.iotoperations.models.BrokerDiagnostics;
import com.azure.resourcemanager.iotoperations.models.BrokerMemoryProfile;
import com.azure.resourcemanager.iotoperations.models.BrokerProperties;
import com.azure.resourcemanager.iotoperations.models.Cardinality;
import com.azure.resourcemanager.iotoperations.models.CertManagerCertOptions;
import com.azure.resourcemanager.iotoperations.models.CertManagerPrivateKey;
import com.azure.resourcemanager.iotoperations.models.ClientConfig;
import com.azure.resourcemanager.iotoperations.models.DiagnosticsLogs;
import com.azure.resourcemanager.iotoperations.models.DiskBackedMessageBuffer;
import com.azure.resourcemanager.iotoperations.models.ExtendedLocation;
import com.azure.resourcemanager.iotoperations.models.ExtendedLocationType;
import com.azure.resourcemanager.iotoperations.models.Frontend;
import com.azure.resourcemanager.iotoperations.models.GenerateResourceLimits;
import com.azure.resourcemanager.iotoperations.models.KubernetesReference;
import com.azure.resourcemanager.iotoperations.models.LocalKubernetesReference;
import com.azure.resourcemanager.iotoperations.models.Metrics;
import com.azure.resourcemanager.iotoperations.models.OperationalMode;
import com.azure.resourcemanager.iotoperations.models.OperatorValues;
import com.azure.resourcemanager.iotoperations.models.PrivateKeyAlgorithm;
import com.azure.resourcemanager.iotoperations.models.PrivateKeyRotationPolicy;
import com.azure.resourcemanager.iotoperations.models.SelfCheck;
import com.azure.resourcemanager.iotoperations.models.SelfTracing;
import com.azure.resourcemanager.iotoperations.models.SubscriberMessageDropStrategy;
import com.azure.resourcemanager.iotoperations.models.SubscriberQueueLimit;
import com.azure.resourcemanager.iotoperations.models.Traces;
import com.azure.resourcemanager.iotoperations.models.VolumeClaimResourceRequirements;
import com.azure.resourcemanager.iotoperations.models.VolumeClaimSpec;
import com.azure.resourcemanager.iotoperations.models.VolumeClaimSpecSelector;
import com.azure.resourcemanager.iotoperations.models.VolumeClaimSpecSelectorMatchExpressions;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

/**
 * Samples for Broker CreateOrUpdate.
 */
public final class Main {
    /*
     * x-ms-original-file: 2024-11-01/Broker_CreateOrUpdate_MaximumSet_Gen.json
     */
    /**
     * Sample code: Broker_CreateOrUpdate.
     * 
     * @param manager Entry point to IoTOperationsManager.
     */
    public static void brokerCreateOrUpdate(com.azure.resourcemanager.iotoperations.IoTOperationsManager manager) {
        manager
            .brokers().define("resource-name123").withExistingInstance("rgiotoperations",
                "resource-name123")
            .withExtendedLocation(new ExtendedLocation().withName(
                "qmbrfwcpwwhggszhrdjv").withType(
                    ExtendedLocationType.CUSTOM_LOCATION))
            .withProperties(
                new BrokerProperties()
                    .withAdvanced(new AdvancedSettings()
                        .withClients(new ClientConfig().withMaxSessionExpirySeconds(3859)
                            .withMaxMessageExpirySeconds(3263).withMaxPacketSizeBytes(3029)
                            .withSubscriberQueueLimit(new SubscriberQueueLimit()
                                .withLength(6L).withStrategy(SubscriberMessageDropStrategy.NONE))
                            .withMaxReceiveMaximum(2365).withMaxKeepAliveSeconds(3744))
                        .withEncryptInternalTraffic(OperationalMode.ENABLED)
                        .withInternalCerts(new CertManagerCertOptions().withDuration("bchrc")
                            .withRenewBefore("xkafmpgjfifkwwrhkswtopdnne")
                            .withPrivateKey(new CertManagerPrivateKey().withAlgorithm(PrivateKeyAlgorithm.EC256)
                                .withRotationPolicy(PrivateKeyRotationPolicy.ALWAYS))))
                    .withCardinality(new Cardinality().withBackendChain(
                        new BackendChain().withPartitions(11).withRedundancyFactor(5).withWorkers(15))
                        .withFrontend(new Frontend().withReplicas(2).withWorkers(6)))
                    .withDiagnostics(new BrokerDiagnostics().withLogs(
                        new DiagnosticsLogs().withLevel("rnmwokumdmebpmfxxxzvvjfdywotav"))
                        .withMetrics(new Metrics().withPrometheusPort(7581))
                        .withSelfCheck(new SelfCheck().withMode(OperationalMode.ENABLED).withIntervalSeconds(158)
                            .withTimeoutSeconds(14))
                        .withTraces(new Traces().withMode(OperationalMode.ENABLED).withCacheSizeMegabytes(28)
                            .withSelfTracing(new SelfTracing()
                                .withMode(OperationalMode.ENABLED).withIntervalSeconds(22))
                            .withSpanChannelCapacity(1000)))
                    .withDiskBackedMessageBuffer(new DiskBackedMessageBuffer().withMaxSize("500M")
                        .withEphemeralVolumeClaimSpec(
                            new VolumeClaimSpec().withVolumeName("c").withVolumeMode("rxvpksjuuugqnqzeiprocknbn")
                                .withStorageClassName("sseyhrjptkhrqvpdpjmornkqvon")
                                .withAccessModes(Arrays.asList("nuluhigrbb"))
                                .withDataSource(new LocalKubernetesReference().withApiGroup("npqapyksvvpkohujx")
                                    .withKind("wazgyb").withName("cwhsgxxcxsyppoefm"))
                                .withDataSourceRef(new KubernetesReference()
                                    .withApiGroup("mnfnykznjjsoqpfsgdqioupt").withKind("odynqzekfzsnawrctaxg")
                                    .withName("envszivbbmixbyddzg").withNamespace("etcfzvxqd"))
                                .withResources(new VolumeClaimResourceRequirements()
                                    .withLimits(mapOf("key2719", "fakeTokenPlaceholder"))
                                    .withRequests(mapOf("key2909", "fakeTokenPlaceholder")))
                                .withSelector(new VolumeClaimSpecSelector()
                                    .withMatchExpressions(Arrays.asList(new VolumeClaimSpecSelectorMatchExpressions()
                                        .withKey("fakeTokenPlaceholder").withOperator(OperatorValues.IN)
                                        .withValues(Arrays.asList("slmpajlywqvuyknipgztsonqyybt"))))
                                    .withMatchLabels(mapOf("key6673", "fakeTokenPlaceholder"))))
                        .withPersistentVolumeClaimSpec(
                            new VolumeClaimSpec().withVolumeName("c").withVolumeMode("rxvpksjuuugqnqzeiprocknbn")
                                .withStorageClassName("sseyhrjptkhrqvpdpjmornkqvon")
                                .withAccessModes(Arrays.asList("nuluhigrbb"))
                                .withDataSource(new LocalKubernetesReference().withApiGroup("npqapyksvvpkohujx")
                                    .withKind("wazgyb").withName("cwhsgxxcxsyppoefm"))
                                .withDataSourceRef(new KubernetesReference()
                                    .withApiGroup("mnfnykznjjsoqpfsgdqioupt").withKind("odynqzekfzsnawrctaxg")
                                    .withName("envszivbbmixbyddzg").withNamespace("etcfzvxqd"))
                                .withResources(new VolumeClaimResourceRequirements()
                                    .withLimits(mapOf("key2719", "fakeTokenPlaceholder"))
                                    .withRequests(mapOf("key2909", "fakeTokenPlaceholder")))
                                .withSelector(new VolumeClaimSpecSelector()
                                    .withMatchExpressions(Arrays.asList(new VolumeClaimSpecSelectorMatchExpressions()
                                        .withKey("fakeTokenPlaceholder").withOperator(OperatorValues.IN)
                                        .withValues(Arrays.asList("slmpajlywqvuyknipgztsonqyybt"))))
                                    .withMatchLabels(mapOf("key6673", "fakeTokenPlaceholder")))))
                    .withGenerateResourceLimits(new GenerateResourceLimits().withCpu(OperationalMode.ENABLED))
                    .withMemoryProfile(BrokerMemoryProfile.TINY))
            .create();
    }

    // Use "Map.of" if available
    @SuppressWarnings("unchecked")
    private static <T> Map<String, T> mapOf(Object... inputs) {
        Map<String, T> map = new HashMap<>();
        for (int i = 0; i < inputs.length; i += 2) {
            String key = (String) inputs[i];
            T value = (T) inputs[i + 1];
            map.put(key, value);
        }
        return map;
    }
}

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

Python

from azure.identity import DefaultAzureCredential

from azure.mgmt.iotoperations import IoTOperationsMgmtClient

"""
# PREREQUISITES
    pip install azure-identity
    pip install azure-mgmt-iotoperations
# USAGE
    python broker_create_or_update_maximum_set_gen.py

    Before run the sample, please set the values of the client ID, tenant ID and client secret
    of the AAD application as environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID,
    AZURE_CLIENT_SECRET. For more info about how to get the value, please see:
    https://docs.microsoft.com/azure/active-directory/develop/howto-create-service-principal-portal
"""


def main():
    client = IoTOperationsMgmtClient(
        credential=DefaultAzureCredential(),
        subscription_id="SUBSCRIPTION_ID",
    )

    response = client.broker.begin_create_or_update(
        resource_group_name="rgiotoperations",
        instance_name="resource-name123",
        broker_name="resource-name123",
        resource={
            "extendedLocation": {"name": "qmbrfwcpwwhggszhrdjv", "type": "CustomLocation"},
            "properties": {
                "advanced": {
                    "clients": {
                        "maxKeepAliveSeconds": 3744,
                        "maxMessageExpirySeconds": 3263,
                        "maxPacketSizeBytes": 3029,
                        "maxReceiveMaximum": 2365,
                        "maxSessionExpirySeconds": 3859,
                        "subscriberQueueLimit": {"length": 6, "strategy": "None"},
                    },
                    "encryptInternalTraffic": "Enabled",
                    "internalCerts": {
                        "duration": "bchrc",
                        "privateKey": {"algorithm": "Ec256", "rotationPolicy": "Always"},
                        "renewBefore": "xkafmpgjfifkwwrhkswtopdnne",
                    },
                },
                "cardinality": {
                    "backendChain": {"partitions": 11, "redundancyFactor": 5, "workers": 15},
                    "frontend": {"replicas": 2, "workers": 6},
                },
                "diagnostics": {
                    "logs": {"level": "rnmwokumdmebpmfxxxzvvjfdywotav"},
                    "metrics": {"prometheusPort": 7581},
                    "selfCheck": {"intervalSeconds": 158, "mode": "Enabled", "timeoutSeconds": 14},
                    "traces": {
                        "cacheSizeMegabytes": 28,
                        "mode": "Enabled",
                        "selfTracing": {"intervalSeconds": 22, "mode": "Enabled"},
                        "spanChannelCapacity": 1000,
                    },
                },
                "diskBackedMessageBuffer": {
                    "ephemeralVolumeClaimSpec": {
                        "accessModes": ["nuluhigrbb"],
                        "dataSource": {"apiGroup": "npqapyksvvpkohujx", "kind": "wazgyb", "name": "cwhsgxxcxsyppoefm"},
                        "dataSourceRef": {
                            "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
                            "kind": "odynqzekfzsnawrctaxg",
                            "name": "envszivbbmixbyddzg",
                            "namespace": "etcfzvxqd",
                        },
                        "resources": {"limits": {"key2719": "hmphcrgctu"}, "requests": {"key2909": "txocprnyrsgvhfrg"}},
                        "selector": {
                            "matchExpressions": [
                                {"key": "e", "operator": "In", "values": ["slmpajlywqvuyknipgztsonqyybt"]}
                            ],
                            "matchLabels": {"key6673": "wlngfalznwxnurzpgxomcxhbqefpr"},
                        },
                        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
                        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
                        "volumeName": "c",
                    },
                    "maxSize": "500M",
                    "persistentVolumeClaimSpec": {
                        "accessModes": ["nuluhigrbb"],
                        "dataSource": {"apiGroup": "npqapyksvvpkohujx", "kind": "wazgyb", "name": "cwhsgxxcxsyppoefm"},
                        "dataSourceRef": {
                            "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
                            "kind": "odynqzekfzsnawrctaxg",
                            "name": "envszivbbmixbyddzg",
                            "namespace": "etcfzvxqd",
                        },
                        "resources": {"limits": {"key2719": "hmphcrgctu"}, "requests": {"key2909": "txocprnyrsgvhfrg"}},
                        "selector": {
                            "matchExpressions": [
                                {"key": "e", "operator": "In", "values": ["slmpajlywqvuyknipgztsonqyybt"]}
                            ],
                            "matchLabels": {"key6673": "wlngfalznwxnurzpgxomcxhbqefpr"},
                        },
                        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
                        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
                        "volumeName": "c",
                    },
                },
                "generateResourceLimits": {"cpu": "Enabled"},
                "memoryProfile": "Tiny",
            },
        },
    ).result()
    print(response)


# x-ms-original-file: 2024-11-01/Broker_CreateOrUpdate_MaximumSet_Gen.json
if __name__ == "__main__":
    main()

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 armiotoperations_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/iotoperations/armiotoperations"
)

// Generated from example definition: 2024-11-01/Broker_CreateOrUpdate_MaximumSet_Gen.json
func ExampleBrokerClient_BeginCreateOrUpdate_brokerCreateOrUpdate() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armiotoperations.NewClientFactory("F8C729F9-DF9C-4743-848F-96EE433D8E53", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	poller, err := clientFactory.NewBrokerClient().BeginCreateOrUpdate(ctx, "rgiotoperations", "resource-name123", "resource-name123", armiotoperations.BrokerResource{
		Properties: &armiotoperations.BrokerProperties{
			Advanced: &armiotoperations.AdvancedSettings{
				Clients: &armiotoperations.ClientConfig{
					MaxSessionExpirySeconds: to.Ptr[int32](3859),
					MaxMessageExpirySeconds: to.Ptr[int32](3263),
					MaxPacketSizeBytes:      to.Ptr[int32](3029),
					SubscriberQueueLimit: &armiotoperations.SubscriberQueueLimit{
						Length:   to.Ptr[int64](6),
						Strategy: to.Ptr(armiotoperations.SubscriberMessageDropStrategyNone),
					},
					MaxReceiveMaximum:   to.Ptr[int32](2365),
					MaxKeepAliveSeconds: to.Ptr[int32](3744),
				},
				EncryptInternalTraffic: to.Ptr(armiotoperations.OperationalModeEnabled),
				InternalCerts: &armiotoperations.CertManagerCertOptions{
					Duration:    to.Ptr("bchrc"),
					RenewBefore: to.Ptr("xkafmpgjfifkwwrhkswtopdnne"),
					PrivateKey: &armiotoperations.CertManagerPrivateKey{
						Algorithm:      to.Ptr(armiotoperations.PrivateKeyAlgorithmEc256),
						RotationPolicy: to.Ptr(armiotoperations.PrivateKeyRotationPolicyAlways),
					},
				},
			},
			Cardinality: &armiotoperations.Cardinality{
				BackendChain: &armiotoperations.BackendChain{
					Partitions:       to.Ptr[int32](11),
					RedundancyFactor: to.Ptr[int32](5),
					Workers:          to.Ptr[int32](15),
				},
				Frontend: &armiotoperations.Frontend{
					Replicas: to.Ptr[int32](2),
					Workers:  to.Ptr[int32](6),
				},
			},
			Diagnostics: &armiotoperations.BrokerDiagnostics{
				Logs: &armiotoperations.DiagnosticsLogs{
					Level: to.Ptr("rnmwokumdmebpmfxxxzvvjfdywotav"),
				},
				Metrics: &armiotoperations.Metrics{
					PrometheusPort: to.Ptr[int32](7581),
				},
				SelfCheck: &armiotoperations.SelfCheck{
					Mode:            to.Ptr(armiotoperations.OperationalModeEnabled),
					IntervalSeconds: to.Ptr[int32](158),
					TimeoutSeconds:  to.Ptr[int32](14),
				},
				Traces: &armiotoperations.Traces{
					Mode:               to.Ptr(armiotoperations.OperationalModeEnabled),
					CacheSizeMegabytes: to.Ptr[int32](28),
					SelfTracing: &armiotoperations.SelfTracing{
						Mode:            to.Ptr(armiotoperations.OperationalModeEnabled),
						IntervalSeconds: to.Ptr[int32](22),
					},
					SpanChannelCapacity: to.Ptr[int32](1000),
				},
			},
			DiskBackedMessageBuffer: &armiotoperations.DiskBackedMessageBuffer{
				MaxSize: to.Ptr("500M"),
				EphemeralVolumeClaimSpec: &armiotoperations.VolumeClaimSpec{
					VolumeName:       to.Ptr("c"),
					VolumeMode:       to.Ptr("rxvpksjuuugqnqzeiprocknbn"),
					StorageClassName: to.Ptr("sseyhrjptkhrqvpdpjmornkqvon"),
					AccessModes: []*string{
						to.Ptr("nuluhigrbb"),
					},
					DataSource: &armiotoperations.LocalKubernetesReference{
						APIGroup: to.Ptr("npqapyksvvpkohujx"),
						Kind:     to.Ptr("wazgyb"),
						Name:     to.Ptr("cwhsgxxcxsyppoefm"),
					},
					DataSourceRef: &armiotoperations.KubernetesReference{
						APIGroup:  to.Ptr("mnfnykznjjsoqpfsgdqioupt"),
						Kind:      to.Ptr("odynqzekfzsnawrctaxg"),
						Name:      to.Ptr("envszivbbmixbyddzg"),
						Namespace: to.Ptr("etcfzvxqd"),
					},
					Resources: &armiotoperations.VolumeClaimResourceRequirements{
						Limits: map[string]*string{
							"key2719": to.Ptr("hmphcrgctu"),
						},
						Requests: map[string]*string{
							"key2909": to.Ptr("txocprnyrsgvhfrg"),
						},
					},
					Selector: &armiotoperations.VolumeClaimSpecSelector{
						MatchExpressions: []*armiotoperations.VolumeClaimSpecSelectorMatchExpressions{
							{
								Key:      to.Ptr("e"),
								Operator: to.Ptr(armiotoperations.OperatorValuesIn),
								Values: []*string{
									to.Ptr("slmpajlywqvuyknipgztsonqyybt"),
								},
							},
						},
						MatchLabels: map[string]*string{
							"key6673": to.Ptr("wlngfalznwxnurzpgxomcxhbqefpr"),
						},
					},
				},
				PersistentVolumeClaimSpec: &armiotoperations.VolumeClaimSpec{
					VolumeName:       to.Ptr("c"),
					VolumeMode:       to.Ptr("rxvpksjuuugqnqzeiprocknbn"),
					StorageClassName: to.Ptr("sseyhrjptkhrqvpdpjmornkqvon"),
					AccessModes: []*string{
						to.Ptr("nuluhigrbb"),
					},
					DataSource: &armiotoperations.LocalKubernetesReference{
						APIGroup: to.Ptr("npqapyksvvpkohujx"),
						Kind:     to.Ptr("wazgyb"),
						Name:     to.Ptr("cwhsgxxcxsyppoefm"),
					},
					DataSourceRef: &armiotoperations.KubernetesReference{
						APIGroup:  to.Ptr("mnfnykznjjsoqpfsgdqioupt"),
						Kind:      to.Ptr("odynqzekfzsnawrctaxg"),
						Name:      to.Ptr("envszivbbmixbyddzg"),
						Namespace: to.Ptr("etcfzvxqd"),
					},
					Resources: &armiotoperations.VolumeClaimResourceRequirements{
						Limits: map[string]*string{
							"key2719": to.Ptr("hmphcrgctu"),
						},
						Requests: map[string]*string{
							"key2909": to.Ptr("txocprnyrsgvhfrg"),
						},
					},
					Selector: &armiotoperations.VolumeClaimSpecSelector{
						MatchExpressions: []*armiotoperations.VolumeClaimSpecSelectorMatchExpressions{
							{
								Key:      to.Ptr("e"),
								Operator: to.Ptr(armiotoperations.OperatorValuesIn),
								Values: []*string{
									to.Ptr("slmpajlywqvuyknipgztsonqyybt"),
								},
							},
						},
						MatchLabels: map[string]*string{
							"key6673": to.Ptr("wlngfalznwxnurzpgxomcxhbqefpr"),
						},
					},
				},
			},
			GenerateResourceLimits: &armiotoperations.GenerateResourceLimits{
				CPU: to.Ptr(armiotoperations.OperationalModeEnabled),
			},
			MemoryProfile: to.Ptr(armiotoperations.BrokerMemoryProfileTiny),
		},
		ExtendedLocation: &armiotoperations.ExtendedLocation{
			Name: to.Ptr("qmbrfwcpwwhggszhrdjv"),
			Type: to.Ptr(armiotoperations.ExtendedLocationTypeCustomLocation),
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %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 = armiotoperations.BrokerClientCreateOrUpdateResponse{
	// 	BrokerResource: &armiotoperations.BrokerResource{
	// 		Properties: &armiotoperations.BrokerProperties{
	// 			Advanced: &armiotoperations.AdvancedSettings{
	// 				Clients: &armiotoperations.ClientConfig{
	// 					MaxSessionExpirySeconds: to.Ptr[int32](3859),
	// 					MaxMessageExpirySeconds: to.Ptr[int32](3263),
	// 					MaxPacketSizeBytes: to.Ptr[int32](3029),
	// 					SubscriberQueueLimit: &armiotoperations.SubscriberQueueLimit{
	// 						Length: to.Ptr[int64](6),
	// 						Strategy: to.Ptr(armiotoperations.SubscriberMessageDropStrategyNone),
	// 					},
	// 					MaxReceiveMaximum: to.Ptr[int32](2365),
	// 					MaxKeepAliveSeconds: to.Ptr[int32](3744),
	// 				},
	// 				EncryptInternalTraffic: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 				InternalCerts: &armiotoperations.CertManagerCertOptions{
	// 					Duration: to.Ptr("bchrc"),
	// 					RenewBefore: to.Ptr("xkafmpgjfifkwwrhkswtopdnne"),
	// 					PrivateKey: &armiotoperations.CertManagerPrivateKey{
	// 						Algorithm: to.Ptr(armiotoperations.PrivateKeyAlgorithmEc256),
	// 						RotationPolicy: to.Ptr(armiotoperations.PrivateKeyRotationPolicyAlways),
	// 					},
	// 				},
	// 			},
	// 			Cardinality: &armiotoperations.Cardinality{
	// 				BackendChain: &armiotoperations.BackendChain{
	// 					Partitions: to.Ptr[int32](11),
	// 					RedundancyFactor: to.Ptr[int32](5),
	// 					Workers: to.Ptr[int32](15),
	// 				},
	// 				Frontend: &armiotoperations.Frontend{
	// 					Replicas: to.Ptr[int32](2),
	// 					Workers: to.Ptr[int32](6),
	// 				},
	// 			},
	// 			Diagnostics: &armiotoperations.BrokerDiagnostics{
	// 				Logs: &armiotoperations.DiagnosticsLogs{
	// 					Level: to.Ptr("rnmwokumdmebpmfxxxzvvjfdywotav"),
	// 				},
	// 				Metrics: &armiotoperations.Metrics{
	// 					PrometheusPort: to.Ptr[int32](7581),
	// 				},
	// 				SelfCheck: &armiotoperations.SelfCheck{
	// 					Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 					IntervalSeconds: to.Ptr[int32](158),
	// 					TimeoutSeconds: to.Ptr[int32](14),
	// 				},
	// 				Traces: &armiotoperations.Traces{
	// 					Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 					CacheSizeMegabytes: to.Ptr[int32](28),
	// 					SelfTracing: &armiotoperations.SelfTracing{
	// 						Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 						IntervalSeconds: to.Ptr[int32](22),
	// 					},
	// 					SpanChannelCapacity: to.Ptr[int32](1000),
	// 				},
	// 			},
	// 			DiskBackedMessageBuffer: &armiotoperations.DiskBackedMessageBuffer{
	// 				MaxSize: to.Ptr("500M"),
	// 				EphemeralVolumeClaimSpec: &armiotoperations.VolumeClaimSpec{
	// 					VolumeName: to.Ptr("c"),
	// 					VolumeMode: to.Ptr("rxvpksjuuugqnqzeiprocknbn"),
	// 					StorageClassName: to.Ptr("sseyhrjptkhrqvpdpjmornkqvon"),
	// 					AccessModes: []*string{
	// 						to.Ptr("nuluhigrbb"),
	// 					},
	// 					DataSource: &armiotoperations.LocalKubernetesReference{
	// 						APIGroup: to.Ptr("npqapyksvvpkohujx"),
	// 						Kind: to.Ptr("wazgyb"),
	// 						Name: to.Ptr("cwhsgxxcxsyppoefm"),
	// 					},
	// 					DataSourceRef: &armiotoperations.KubernetesReference{
	// 						APIGroup: to.Ptr("mnfnykznjjsoqpfsgdqioupt"),
	// 						Kind: to.Ptr("odynqzekfzsnawrctaxg"),
	// 						Name: to.Ptr("envszivbbmixbyddzg"),
	// 						Namespace: to.Ptr("etcfzvxqd"),
	// 					},
	// 					Resources: &armiotoperations.VolumeClaimResourceRequirements{
	// 						Limits: map[string]*string{
	// 							"key2719": to.Ptr("hmphcrgctu"),
	// 						},
	// 						Requests: map[string]*string{
	// 							"key2909": to.Ptr("txocprnyrsgvhfrg"),
	// 						},
	// 					},
	// 					Selector: &armiotoperations.VolumeClaimSpecSelector{
	// 						MatchExpressions: []*armiotoperations.VolumeClaimSpecSelectorMatchExpressions{
	// 							{
	// 								Key: to.Ptr("e"),
	// 								Operator: to.Ptr(armiotoperations.OperatorValuesIn),
	// 								Values: []*string{
	// 									to.Ptr("slmpajlywqvuyknipgztsonqyybt"),
	// 								},
	// 							},
	// 						},
	// 						MatchLabels: map[string]*string{
	// 							"key6673": to.Ptr("wlngfalznwxnurzpgxomcxhbqefpr"),
	// 						},
	// 					},
	// 				},
	// 				PersistentVolumeClaimSpec: &armiotoperations.VolumeClaimSpec{
	// 					VolumeName: to.Ptr("c"),
	// 					VolumeMode: to.Ptr("rxvpksjuuugqnqzeiprocknbn"),
	// 					StorageClassName: to.Ptr("sseyhrjptkhrqvpdpjmornkqvon"),
	// 					AccessModes: []*string{
	// 						to.Ptr("nuluhigrbb"),
	// 					},
	// 					DataSource: &armiotoperations.LocalKubernetesReference{
	// 						APIGroup: to.Ptr("npqapyksvvpkohujx"),
	// 						Kind: to.Ptr("wazgyb"),
	// 						Name: to.Ptr("cwhsgxxcxsyppoefm"),
	// 					},
	// 					DataSourceRef: &armiotoperations.KubernetesReference{
	// 						APIGroup: to.Ptr("mnfnykznjjsoqpfsgdqioupt"),
	// 						Kind: to.Ptr("odynqzekfzsnawrctaxg"),
	// 						Name: to.Ptr("envszivbbmixbyddzg"),
	// 						Namespace: to.Ptr("etcfzvxqd"),
	// 					},
	// 					Resources: &armiotoperations.VolumeClaimResourceRequirements{
	// 						Limits: map[string]*string{
	// 							"key2719": to.Ptr("hmphcrgctu"),
	// 						},
	// 						Requests: map[string]*string{
	// 							"key2909": to.Ptr("txocprnyrsgvhfrg"),
	// 						},
	// 					},
	// 					Selector: &armiotoperations.VolumeClaimSpecSelector{
	// 						MatchExpressions: []*armiotoperations.VolumeClaimSpecSelectorMatchExpressions{
	// 							{
	// 								Key: to.Ptr("e"),
	// 								Operator: to.Ptr(armiotoperations.OperatorValuesIn),
	// 								Values: []*string{
	// 									to.Ptr("slmpajlywqvuyknipgztsonqyybt"),
	// 								},
	// 							},
	// 						},
	// 						MatchLabels: map[string]*string{
	// 							"key6673": to.Ptr("wlngfalznwxnurzpgxomcxhbqefpr"),
	// 						},
	// 					},
	// 				},
	// 			},
	// 			GenerateResourceLimits: &armiotoperations.GenerateResourceLimits{
	// 				CPU: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 			},
	// 			MemoryProfile: to.Ptr(armiotoperations.BrokerMemoryProfileTiny),
	// 			ProvisioningState: to.Ptr(armiotoperations.ProvisioningStateSucceeded),
	// 		},
	// 		ExtendedLocation: &armiotoperations.ExtendedLocation{
	// 			Name: to.Ptr("qmbrfwcpwwhggszhrdjv"),
	// 			Type: to.Ptr(armiotoperations.ExtendedLocationTypeCustomLocation),
	// 		},
	// 		ID: to.Ptr("/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123"),
	// 		Name: to.Ptr("dowrkel"),
	// 		Type: to.Ptr("xshjnsdgadygb"),
	// 		SystemData: &armiotoperations.SystemData{
	// 			CreatedBy: to.Ptr("ssvaslsmudloholronopqyxjcu"),
	// 			CreatedByType: to.Ptr(armiotoperations.CreatedByTypeUser),
	// 			CreatedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2024-08-09T18:13:29.389Z"); return t}()),
	// 			LastModifiedBy: to.Ptr("gnicpuszwd"),
	// 			LastModifiedByType: to.Ptr(armiotoperations.CreatedByTypeUser),
	// 			LastModifiedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2024-08-09T18:13:29.389Z"); return t}()),
	// 		},
	// 	},
	// }
}

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

dotnet

using Azure;
using Azure.ResourceManager;
using System;
using System.Threading.Tasks;
using Azure.Core;
using Azure.Identity;
using Azure.ResourceManager.IotOperations.Models;
using Azure.ResourceManager.IotOperations;

// Generated from example definition: 2024-11-01/Broker_CreateOrUpdate_MaximumSet_Gen.json
// this example is just showing the usage of "BrokerResource_CreateOrUpdate" operation, for the dependent resources, they will have to be created separately.

// get your azure access token, for more details of how Azure SDK get your access token, please refer to https://learn.microsoft.com/en-us/dotnet/azure/sdk/authentication?tabs=command-line
TokenCredential cred = new DefaultAzureCredential();
// authenticate your client
ArmClient client = new ArmClient(cred);

// this example assumes you already have this IotOperationsBrokerResource created on azure
// for more information of creating IotOperationsBrokerResource, please refer to the document of IotOperationsBrokerResource
string subscriptionId = "F8C729F9-DF9C-4743-848F-96EE433D8E53";
string resourceGroupName = "rgiotoperations";
string instanceName = "resource-name123";
string brokerName = "resource-name123";
ResourceIdentifier iotOperationsBrokerResourceId = IotOperationsBrokerResource.CreateResourceIdentifier(subscriptionId, resourceGroupName, instanceName, brokerName);
IotOperationsBrokerResource iotOperationsBroker = client.GetIotOperationsBrokerResource(iotOperationsBrokerResourceId);

// invoke the operation
IotOperationsBrokerData data = new IotOperationsBrokerData(new IotOperationsExtendedLocation("qmbrfwcpwwhggszhrdjv", IotOperationsExtendedLocationType.CustomLocation))
{
    Properties = new IotOperationsBrokerProperties
    {
        Advanced = new BrokerAdvancedSettings
        {
            Clients = new BrokerClientConfig
            {
                MaxSessionExpirySeconds = 3859,
                MaxMessageExpirySeconds = 3263,
                MaxPacketSizeBytes = 3029,
                SubscriberQueueLimit = new SubscriberQueueLimit
                {
                    Length = 6L,
                    Strategy = SubscriberMessageDropStrategy.None,
                },
                MaxReceiveMaximum = 2365,
                MaxKeepAliveSeconds = 3744,
            },
            EncryptInternalTraffic = IotOperationsOperationalMode.Enabled,
            InternalCerts = new CertManagerCertConfig("bchrc", "xkafmpgjfifkwwrhkswtopdnne", new CertManagerPrivateKey(PrivateKeyAlgorithm.Ec256, PrivateKeyRotationPolicy.Always)),
        },
        Cardinality = new BrokerCardinality(new BrokerBackendChain(11, 5)
        {
            Workers = 15,
        }, new BrokerFrontend(2)
        {
            Workers = 6,
        }),
        Diagnostics = new BrokerDiagnostics
        {
            LogsLevel = "rnmwokumdmebpmfxxxzvvjfdywotav",
            MetricsPrometheusPort = 7581,
            SelfCheck = new BrokerDiagnosticSelfCheck
            {
                Mode = IotOperationsOperationalMode.Enabled,
                IntervalSeconds = 158,
                TimeoutSeconds = 14,
            },
            Traces = new BrokerDiagnosticTraces
            {
                Mode = IotOperationsOperationalMode.Enabled,
                CacheSizeMegabytes = 28,
                SelfTracing = new DiagnosticSelfTracing
                {
                    Mode = IotOperationsOperationalMode.Enabled,
                    IntervalSeconds = 22,
                },
                SpanChannelCapacity = 1000,
            },
        },
        DiskBackedMessageBuffer = new DiskBackedMessageBuffer("500M")
        {
            EphemeralVolumeClaimSpec = new VolumeClaimSpec
            {
                VolumeName = "c",
                VolumeMode = "rxvpksjuuugqnqzeiprocknbn",
                StorageClassName = "sseyhrjptkhrqvpdpjmornkqvon",
                AccessModes = { "nuluhigrbb" },
                DataSource = new LocalKubernetesReference("wazgyb", "cwhsgxxcxsyppoefm")
                {
                    ApiGroup = "npqapyksvvpkohujx",
                },
                DataSourceRef = new KubernetesReference("odynqzekfzsnawrctaxg", "envszivbbmixbyddzg")
                {
                    ApiGroup = "mnfnykznjjsoqpfsgdqioupt",
                    Namespace = "etcfzvxqd",
                },
                Resources = new VolumeClaimResourceRequirements
                {
                    Limits =
                    {
                    ["key2719"] = "hmphcrgctu"
                    },
                    Requests =
                    {
                    ["key2909"] = "txocprnyrsgvhfrg"
                    },
                },
                Selector = new VolumeClaimSpecSelector
                {
                    MatchExpressions = {new VolumeClaimSpecSelectorMatchExpressions("e", BrokerOperatorValue.In)
                    {
                    Values = {"slmpajlywqvuyknipgztsonqyybt"},
                    }},
                    MatchLabels =
                    {
                    ["key6673"] = "wlngfalznwxnurzpgxomcxhbqefpr"
                    },
                },
            },
            PersistentVolumeClaimSpec = new VolumeClaimSpec
            {
                VolumeName = "c",
                VolumeMode = "rxvpksjuuugqnqzeiprocknbn",
                StorageClassName = "sseyhrjptkhrqvpdpjmornkqvon",
                AccessModes = { "nuluhigrbb" },
                DataSource = new LocalKubernetesReference("wazgyb", "cwhsgxxcxsyppoefm")
                {
                    ApiGroup = "npqapyksvvpkohujx",
                },
                DataSourceRef = new KubernetesReference("odynqzekfzsnawrctaxg", "envszivbbmixbyddzg")
                {
                    ApiGroup = "mnfnykznjjsoqpfsgdqioupt",
                    Namespace = "etcfzvxqd",
                },
                Resources = new VolumeClaimResourceRequirements
                {
                    Limits =
                    {
                    ["key2719"] = "hmphcrgctu"
                    },
                    Requests =
                    {
                    ["key2909"] = "txocprnyrsgvhfrg"
                    },
                },
                Selector = new VolumeClaimSpecSelector
                {
                    MatchExpressions = {new VolumeClaimSpecSelectorMatchExpressions("e", BrokerOperatorValue.In)
                    {
                    Values = {"slmpajlywqvuyknipgztsonqyybt"},
                    }},
                    MatchLabels =
                    {
                    ["key6673"] = "wlngfalznwxnurzpgxomcxhbqefpr"
                    },
                },
            },
        },
        GenerateResourceLimitsCpu = IotOperationsOperationalMode.Enabled,
        MemoryProfile = BrokerMemoryProfile.Tiny,
    },
};
ArmOperation<IotOperationsBrokerResource> lro = await iotOperationsBroker.UpdateAsync(WaitUntil.Completed, data);
IotOperationsBrokerResource result = lro.Value;

// the variable result is a resource, you could call other operations on this instance as well
// but just for demo, we get its data from this resource instance
IotOperationsBrokerData resourceData = result.Data;
// for demo we just print out the id
Console.WriteLine($"Succeeded on id: {resourceData.Id}");

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

Exempelsvar

Statuskod:

200

{
  "properties": {
    "advanced": {
      "clients": {
        "maxSessionExpirySeconds": 3859,
        "maxMessageExpirySeconds": 3263,
        "maxPacketSizeBytes": 3029,
        "subscriberQueueLimit": {
          "length": 6,
          "strategy": "None"
        },
        "maxReceiveMaximum": 2365,
        "maxKeepAliveSeconds": 3744
      },
      "encryptInternalTraffic": "Enabled",
      "internalCerts": {
        "duration": "bchrc",
        "renewBefore": "xkafmpgjfifkwwrhkswtopdnne",
        "privateKey": {
          "algorithm": "Ec256",
          "rotationPolicy": "Always"
        }
      }
    },
    "cardinality": {
      "backendChain": {
        "partitions": 11,
        "redundancyFactor": 5,
        "workers": 15
      },
      "frontend": {
        "replicas": 2,
        "workers": 6
      }
    },
    "diagnostics": {
      "logs": {
        "level": "rnmwokumdmebpmfxxxzvvjfdywotav"
      },
      "metrics": {
        "prometheusPort": 7581
      },
      "selfCheck": {
        "mode": "Enabled",
        "intervalSeconds": 158,
        "timeoutSeconds": 14
      },
      "traces": {
        "mode": "Enabled",
        "cacheSizeMegabytes": 28,
        "selfTracing": {
          "mode": "Enabled",
          "intervalSeconds": 22
        },
        "spanChannelCapacity": 1000
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "500M",
      "ephemeralVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      },
      "persistentVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      }
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Tiny",
    "provisioningState": "Succeeded"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  },
  "id": "/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123",
  "name": "dowrkel",
  "type": "xshjnsdgadygb",
  "systemData": {
    "createdBy": "ssvaslsmudloholronopqyxjcu",
    "createdByType": "User",
    "createdAt": "2024-08-09T18:13:29.389Z",
    "lastModifiedBy": "gnicpuszwd",
    "lastModifiedByType": "User",
    "lastModifiedAt": "2024-08-09T18:13:29.389Z"
  }
}

Statuskod:

201

Azure-AsyncOperation: https://contoso.com/operationstatus

{
  "properties": {
    "advanced": {
      "clients": {
        "maxSessionExpirySeconds": 3859,
        "maxMessageExpirySeconds": 3263,
        "maxPacketSizeBytes": 3029,
        "subscriberQueueLimit": {
          "length": 6,
          "strategy": "None"
        },
        "maxReceiveMaximum": 2365,
        "maxKeepAliveSeconds": 3744
      },
      "encryptInternalTraffic": "Enabled",
      "internalCerts": {
        "duration": "bchrc",
        "renewBefore": "xkafmpgjfifkwwrhkswtopdnne",
        "privateKey": {
          "algorithm": "Ec256",
          "rotationPolicy": "Always"
        }
      }
    },
    "cardinality": {
      "backendChain": {
        "partitions": 11,
        "redundancyFactor": 5,
        "workers": 15
      },
      "frontend": {
        "replicas": 2,
        "workers": 6
      }
    },
    "diagnostics": {
      "logs": {
        "level": "rnmwokumdmebpmfxxxzvvjfdywotav"
      },
      "metrics": {
        "prometheusPort": 7581
      },
      "selfCheck": {
        "mode": "Enabled",
        "intervalSeconds": 158,
        "timeoutSeconds": 14
      },
      "traces": {
        "mode": "Enabled",
        "cacheSizeMegabytes": 28,
        "selfTracing": {
          "mode": "Enabled",
          "intervalSeconds": 22
        },
        "spanChannelCapacity": 1000
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "500M",
      "ephemeralVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      },
      "persistentVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      }
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Tiny",
    "provisioningState": "Succeeded"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  },
  "id": "/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123",
  "name": "dowrkel",
  "type": "xshjnsdgadygb",
  "systemData": {
    "createdBy": "ssvaslsmudloholronopqyxjcu",
    "createdByType": "User",
    "createdAt": "2024-08-09T18:13:29.389Z",
    "lastModifiedBy": "gnicpuszwd",
    "lastModifiedByType": "User",
    "lastModifiedAt": "2024-08-09T18:13:29.389Z"
  }
}

Broker_CreateOrUpdate_Complex

Exempelbegäran

HTTP

PUT https://management.azure.com/subscriptions/F8C729F9-DF9C-4743-848F-96EE433D8E53/resourceGroups/rgiotoperations/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123?api-version=2024-11-01

{
  "properties": {
    "cardinality": {
      "backendChain": {
        "partitions": 2,
        "redundancyFactor": 2,
        "workers": 2
      },
      "frontend": {
        "replicas": 2,
        "workers": 2
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "50M"
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Medium"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  }
}

Java

import com.azure.resourcemanager.iotoperations.models.BackendChain;
import com.azure.resourcemanager.iotoperations.models.BrokerMemoryProfile;
import com.azure.resourcemanager.iotoperations.models.BrokerProperties;
import com.azure.resourcemanager.iotoperations.models.Cardinality;
import com.azure.resourcemanager.iotoperations.models.DiskBackedMessageBuffer;
import com.azure.resourcemanager.iotoperations.models.ExtendedLocation;
import com.azure.resourcemanager.iotoperations.models.ExtendedLocationType;
import com.azure.resourcemanager.iotoperations.models.Frontend;
import com.azure.resourcemanager.iotoperations.models.GenerateResourceLimits;
import com.azure.resourcemanager.iotoperations.models.OperationalMode;
import java.util.HashMap;
import java.util.Map;

/**
 * Samples for Broker CreateOrUpdate.
 */
public final class Main {
    /*
     * x-ms-original-file: 2024-11-01/Broker_CreateOrUpdate_Complex.json
     */
    /**
     * Sample code: Broker_CreateOrUpdate_Complex.
     * 
     * @param manager Entry point to IoTOperationsManager.
     */
    public static void
        brokerCreateOrUpdateComplex(com.azure.resourcemanager.iotoperations.IoTOperationsManager manager) {
        manager
            .brokers().define(
                "resource-name123")
            .withExistingInstance("rgiotoperations", "resource-name123")
            .withExtendedLocation(new ExtendedLocation().withName("qmbrfwcpwwhggszhrdjv")
                .withType(ExtendedLocationType.CUSTOM_LOCATION))
            .withProperties(new BrokerProperties()
                .withCardinality(new Cardinality()
                    .withBackendChain(new BackendChain().withPartitions(2).withRedundancyFactor(2).withWorkers(2))
                    .withFrontend(new Frontend().withReplicas(2).withWorkers(2)))
                .withDiskBackedMessageBuffer(new DiskBackedMessageBuffer().withMaxSize("50M"))
                .withGenerateResourceLimits(new GenerateResourceLimits().withCpu(OperationalMode.ENABLED))
                .withMemoryProfile(BrokerMemoryProfile.MEDIUM))
            .create();
    }

    // Use "Map.of" if available
    @SuppressWarnings("unchecked")
    private static <T> Map<String, T> mapOf(Object... inputs) {
        Map<String, T> map = new HashMap<>();
        for (int i = 0; i < inputs.length; i += 2) {
            String key = (String) inputs[i];
            T value = (T) inputs[i + 1];
            map.put(key, value);
        }
        return map;
    }
}

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

Python

from azure.identity import DefaultAzureCredential

from azure.mgmt.iotoperations import IoTOperationsMgmtClient

"""
# PREREQUISITES
    pip install azure-identity
    pip install azure-mgmt-iotoperations
# USAGE
    python broker_create_or_update_complex.py

    Before run the sample, please set the values of the client ID, tenant ID and client secret
    of the AAD application as environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID,
    AZURE_CLIENT_SECRET. For more info about how to get the value, please see:
    https://docs.microsoft.com/azure/active-directory/develop/howto-create-service-principal-portal
"""


def main():
    client = IoTOperationsMgmtClient(
        credential=DefaultAzureCredential(),
        subscription_id="SUBSCRIPTION_ID",
    )

    response = client.broker.begin_create_or_update(
        resource_group_name="rgiotoperations",
        instance_name="resource-name123",
        broker_name="resource-name123",
        resource={
            "extendedLocation": {"name": "qmbrfwcpwwhggszhrdjv", "type": "CustomLocation"},
            "properties": {
                "cardinality": {
                    "backendChain": {"partitions": 2, "redundancyFactor": 2, "workers": 2},
                    "frontend": {"replicas": 2, "workers": 2},
                },
                "diskBackedMessageBuffer": {"maxSize": "50M"},
                "generateResourceLimits": {"cpu": "Enabled"},
                "memoryProfile": "Medium",
            },
        },
    ).result()
    print(response)


# x-ms-original-file: 2024-11-01/Broker_CreateOrUpdate_Complex.json
if __name__ == "__main__":
    main()

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 armiotoperations_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/iotoperations/armiotoperations"
)

// Generated from example definition: 2024-11-01/Broker_CreateOrUpdate_Complex.json
func ExampleBrokerClient_BeginCreateOrUpdate_brokerCreateOrUpdateComplex() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armiotoperations.NewClientFactory("F8C729F9-DF9C-4743-848F-96EE433D8E53", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	poller, err := clientFactory.NewBrokerClient().BeginCreateOrUpdate(ctx, "rgiotoperations", "resource-name123", "resource-name123", armiotoperations.BrokerResource{
		Properties: &armiotoperations.BrokerProperties{
			Cardinality: &armiotoperations.Cardinality{
				BackendChain: &armiotoperations.BackendChain{
					Partitions:       to.Ptr[int32](2),
					RedundancyFactor: to.Ptr[int32](2),
					Workers:          to.Ptr[int32](2),
				},
				Frontend: &armiotoperations.Frontend{
					Replicas: to.Ptr[int32](2),
					Workers:  to.Ptr[int32](2),
				},
			},
			DiskBackedMessageBuffer: &armiotoperations.DiskBackedMessageBuffer{
				MaxSize: to.Ptr("50M"),
			},
			GenerateResourceLimits: &armiotoperations.GenerateResourceLimits{
				CPU: to.Ptr(armiotoperations.OperationalModeEnabled),
			},
			MemoryProfile: to.Ptr(armiotoperations.BrokerMemoryProfileMedium),
		},
		ExtendedLocation: &armiotoperations.ExtendedLocation{
			Name: to.Ptr("qmbrfwcpwwhggszhrdjv"),
			Type: to.Ptr(armiotoperations.ExtendedLocationTypeCustomLocation),
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %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 = armiotoperations.BrokerClientCreateOrUpdateResponse{
	// 	BrokerResource: &armiotoperations.BrokerResource{
	// 		Properties: &armiotoperations.BrokerProperties{
	// 			Cardinality: &armiotoperations.Cardinality{
	// 				BackendChain: &armiotoperations.BackendChain{
	// 					Partitions: to.Ptr[int32](2),
	// 					RedundancyFactor: to.Ptr[int32](2),
	// 					Workers: to.Ptr[int32](2),
	// 				},
	// 				Frontend: &armiotoperations.Frontend{
	// 					Replicas: to.Ptr[int32](2),
	// 					Workers: to.Ptr[int32](2),
	// 				},
	// 			},
	// 			DiskBackedMessageBuffer: &armiotoperations.DiskBackedMessageBuffer{
	// 				MaxSize: to.Ptr("50M"),
	// 			},
	// 			GenerateResourceLimits: &armiotoperations.GenerateResourceLimits{
	// 				CPU: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 			},
	// 			MemoryProfile: to.Ptr(armiotoperations.BrokerMemoryProfileMedium),
	// 			ProvisioningState: to.Ptr(armiotoperations.ProvisioningStateSucceeded),
	// 		},
	// 		ExtendedLocation: &armiotoperations.ExtendedLocation{
	// 			Name: to.Ptr("qmbrfwcpwwhggszhrdjv"),
	// 			Type: to.Ptr(armiotoperations.ExtendedLocationTypeCustomLocation),
	// 		},
	// 		ID: to.Ptr("/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123"),
	// 		Name: to.Ptr("llptmlifnqqwairx"),
	// 		Type: to.Ptr("qwrfzxjfxvismlqvigot"),
	// 		SystemData: &armiotoperations.SystemData{
	// 			CreatedBy: to.Ptr("ssvaslsmudloholronopqyxjcu"),
	// 			CreatedByType: to.Ptr(armiotoperations.CreatedByTypeUser),
	// 			CreatedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2024-08-09T18:13:29.389Z"); return t}()),
	// 			LastModifiedBy: to.Ptr("gnicpuszwd"),
	// 			LastModifiedByType: to.Ptr(armiotoperations.CreatedByTypeUser),
	// 			LastModifiedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2024-08-09T18:13:29.389Z"); return t}()),
	// 		},
	// 	},
	// }
}

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

dotnet

using Azure;
using Azure.ResourceManager;
using System;
using System.Threading.Tasks;
using Azure.Core;
using Azure.Identity;
using Azure.ResourceManager.IotOperations.Models;
using Azure.ResourceManager.IotOperations;

// Generated from example definition: 2024-11-01/Broker_CreateOrUpdate_Complex.json
// this example is just showing the usage of "BrokerResource_CreateOrUpdate" operation, for the dependent resources, they will have to be created separately.

// get your azure access token, for more details of how Azure SDK get your access token, please refer to https://learn.microsoft.com/en-us/dotnet/azure/sdk/authentication?tabs=command-line
TokenCredential cred = new DefaultAzureCredential();
// authenticate your client
ArmClient client = new ArmClient(cred);

// this example assumes you already have this IotOperationsBrokerResource created on azure
// for more information of creating IotOperationsBrokerResource, please refer to the document of IotOperationsBrokerResource
string subscriptionId = "F8C729F9-DF9C-4743-848F-96EE433D8E53";
string resourceGroupName = "rgiotoperations";
string instanceName = "resource-name123";
string brokerName = "resource-name123";
ResourceIdentifier iotOperationsBrokerResourceId = IotOperationsBrokerResource.CreateResourceIdentifier(subscriptionId, resourceGroupName, instanceName, brokerName);
IotOperationsBrokerResource iotOperationsBroker = client.GetIotOperationsBrokerResource(iotOperationsBrokerResourceId);

// invoke the operation
IotOperationsBrokerData data = new IotOperationsBrokerData(new IotOperationsExtendedLocation("qmbrfwcpwwhggszhrdjv", IotOperationsExtendedLocationType.CustomLocation))
{
    Properties = new IotOperationsBrokerProperties
    {
        Cardinality = new BrokerCardinality(new BrokerBackendChain(2, 2)
        {
            Workers = 2,
        }, new BrokerFrontend(2)
        {
            Workers = 2,
        }),
        DiskBackedMessageBuffer = new DiskBackedMessageBuffer("50M"),
        GenerateResourceLimitsCpu = IotOperationsOperationalMode.Enabled,
        MemoryProfile = BrokerMemoryProfile.Medium,
    },
};
ArmOperation<IotOperationsBrokerResource> lro = await iotOperationsBroker.UpdateAsync(WaitUntil.Completed, data);
IotOperationsBrokerResource result = lro.Value;

// the variable result is a resource, you could call other operations on this instance as well
// but just for demo, we get its data from this resource instance
IotOperationsBrokerData resourceData = result.Data;
// for demo we just print out the id
Console.WriteLine($"Succeeded on id: {resourceData.Id}");

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

Exempelsvar

Statuskod:

200

{
  "properties": {
    "cardinality": {
      "backendChain": {
        "partitions": 2,
        "redundancyFactor": 2,
        "workers": 2
      },
      "frontend": {
        "replicas": 2,
        "workers": 2
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "50M"
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Medium",
    "provisioningState": "Succeeded"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  },
  "id": "/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123",
  "name": "llptmlifnqqwairx",
  "type": "qwrfzxjfxvismlqvigot",
  "systemData": {
    "createdBy": "ssvaslsmudloholronopqyxjcu",
    "createdByType": "User",
    "createdAt": "2024-08-09T18:13:29.389Z",
    "lastModifiedBy": "gnicpuszwd",
    "lastModifiedByType": "User",
    "lastModifiedAt": "2024-08-09T18:13:29.389Z"
  }
}

Statuskod:

201

Azure-AsyncOperation: https://contoso.com/operationstatus

{
  "properties": {
    "cardinality": {
      "backendChain": {
        "partitions": 2,
        "redundancyFactor": 2,
        "workers": 2
      },
      "frontend": {
        "replicas": 2,
        "workers": 2
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "50M"
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Medium",
    "provisioningState": "Accepted"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  },
  "id": "/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123",
  "name": "llptmlifnqqwairx",
  "type": "qwrfzxjfxvismlqvigot",
  "systemData": {
    "createdBy": "ssvaslsmudloholronopqyxjcu",
    "createdByType": "User",
    "createdAt": "2024-08-09T18:13:29.389Z",
    "lastModifiedBy": "gnicpuszwd",
    "lastModifiedByType": "User",
    "lastModifiedAt": "2024-08-09T18:13:29.389Z"
  }
}

Broker_CreateOrUpdate_Minimal

Exempelbegäran

HTTP

PUT https://management.azure.com/subscriptions/F8C729F9-DF9C-4743-848F-96EE433D8E53/resourceGroups/rgiotoperations/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123?api-version=2024-11-01

{
  "properties": {
    "memoryProfile": "Tiny"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  }
}

Java

import com.azure.resourcemanager.iotoperations.models.BrokerMemoryProfile;
import com.azure.resourcemanager.iotoperations.models.BrokerProperties;
import com.azure.resourcemanager.iotoperations.models.ExtendedLocation;
import com.azure.resourcemanager.iotoperations.models.ExtendedLocationType;
import java.util.HashMap;
import java.util.Map;

/**
 * Samples for Broker CreateOrUpdate.
 */
public final class Main {
    /*
     * x-ms-original-file: 2024-11-01/Broker_CreateOrUpdate_Minimal.json
     */
    /**
     * Sample code: Broker_CreateOrUpdate_Minimal.
     * 
     * @param manager Entry point to IoTOperationsManager.
     */
    public static void
        brokerCreateOrUpdateMinimal(com.azure.resourcemanager.iotoperations.IoTOperationsManager manager) {
        manager.brokers().define("resource-name123").withExistingInstance("rgiotoperations", "resource-name123")
            .withExtendedLocation(
                new ExtendedLocation().withName("qmbrfwcpwwhggszhrdjv").withType(ExtendedLocationType.CUSTOM_LOCATION))
            .withProperties(new BrokerProperties().withMemoryProfile(BrokerMemoryProfile.TINY)).create();
    }

    // Use "Map.of" if available
    @SuppressWarnings("unchecked")
    private static <T> Map<String, T> mapOf(Object... inputs) {
        Map<String, T> map = new HashMap<>();
        for (int i = 0; i < inputs.length; i += 2) {
            String key = (String) inputs[i];
            T value = (T) inputs[i + 1];
            map.put(key, value);
        }
        return map;
    }
}

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

Python

from azure.identity import DefaultAzureCredential

from azure.mgmt.iotoperations import IoTOperationsMgmtClient

"""
# PREREQUISITES
    pip install azure-identity
    pip install azure-mgmt-iotoperations
# USAGE
    python broker_create_or_update_minimal.py

    Before run the sample, please set the values of the client ID, tenant ID and client secret
    of the AAD application as environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID,
    AZURE_CLIENT_SECRET. For more info about how to get the value, please see:
    https://docs.microsoft.com/azure/active-directory/develop/howto-create-service-principal-portal
"""


def main():
    client = IoTOperationsMgmtClient(
        credential=DefaultAzureCredential(),
        subscription_id="SUBSCRIPTION_ID",
    )

    response = client.broker.begin_create_or_update(
        resource_group_name="rgiotoperations",
        instance_name="resource-name123",
        broker_name="resource-name123",
        resource={
            "extendedLocation": {"name": "qmbrfwcpwwhggszhrdjv", "type": "CustomLocation"},
            "properties": {"memoryProfile": "Tiny"},
        },
    ).result()
    print(response)


# x-ms-original-file: 2024-11-01/Broker_CreateOrUpdate_Minimal.json
if __name__ == "__main__":
    main()

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 armiotoperations_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/iotoperations/armiotoperations"
)

// Generated from example definition: 2024-11-01/Broker_CreateOrUpdate_Minimal.json
func ExampleBrokerClient_BeginCreateOrUpdate_brokerCreateOrUpdateMinimal() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armiotoperations.NewClientFactory("F8C729F9-DF9C-4743-848F-96EE433D8E53", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	poller, err := clientFactory.NewBrokerClient().BeginCreateOrUpdate(ctx, "rgiotoperations", "resource-name123", "resource-name123", armiotoperations.BrokerResource{
		Properties: &armiotoperations.BrokerProperties{
			MemoryProfile: to.Ptr(armiotoperations.BrokerMemoryProfileTiny),
		},
		ExtendedLocation: &armiotoperations.ExtendedLocation{
			Name: to.Ptr("qmbrfwcpwwhggszhrdjv"),
			Type: to.Ptr(armiotoperations.ExtendedLocationTypeCustomLocation),
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %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 = armiotoperations.BrokerClientCreateOrUpdateResponse{
	// 	BrokerResource: &armiotoperations.BrokerResource{
	// 		Properties: &armiotoperations.BrokerProperties{
	// 			Advanced: &armiotoperations.AdvancedSettings{
	// 				Clients: &armiotoperations.ClientConfig{
	// 					MaxSessionExpirySeconds: to.Ptr[int32](3859),
	// 					MaxMessageExpirySeconds: to.Ptr[int32](3263),
	// 					MaxPacketSizeBytes: to.Ptr[int32](3029),
	// 					SubscriberQueueLimit: &armiotoperations.SubscriberQueueLimit{
	// 						Length: to.Ptr[int64](6),
	// 						Strategy: to.Ptr(armiotoperations.SubscriberMessageDropStrategyNone),
	// 					},
	// 					MaxReceiveMaximum: to.Ptr[int32](2365),
	// 					MaxKeepAliveSeconds: to.Ptr[int32](3744),
	// 				},
	// 				EncryptInternalTraffic: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 				InternalCerts: &armiotoperations.CertManagerCertOptions{
	// 					Duration: to.Ptr("bchrc"),
	// 					RenewBefore: to.Ptr("xkafmpgjfifkwwrhkswtopdnne"),
	// 					PrivateKey: &armiotoperations.CertManagerPrivateKey{
	// 						Algorithm: to.Ptr(armiotoperations.PrivateKeyAlgorithmEc256),
	// 						RotationPolicy: to.Ptr(armiotoperations.PrivateKeyRotationPolicyAlways),
	// 					},
	// 				},
	// 			},
	// 			Cardinality: &armiotoperations.Cardinality{
	// 				BackendChain: &armiotoperations.BackendChain{
	// 					Partitions: to.Ptr[int32](11),
	// 					RedundancyFactor: to.Ptr[int32](5),
	// 					Workers: to.Ptr[int32](15),
	// 				},
	// 				Frontend: &armiotoperations.Frontend{
	// 					Replicas: to.Ptr[int32](2),
	// 					Workers: to.Ptr[int32](6),
	// 				},
	// 			},
	// 			Diagnostics: &armiotoperations.BrokerDiagnostics{
	// 				Logs: &armiotoperations.DiagnosticsLogs{
	// 					Level: to.Ptr("rnmwokumdmebpmfxxxzvvjfdywotav"),
	// 				},
	// 				Metrics: &armiotoperations.Metrics{
	// 					PrometheusPort: to.Ptr[int32](7581),
	// 				},
	// 				SelfCheck: &armiotoperations.SelfCheck{
	// 					Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 					IntervalSeconds: to.Ptr[int32](158),
	// 					TimeoutSeconds: to.Ptr[int32](14),
	// 				},
	// 				Traces: &armiotoperations.Traces{
	// 					Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 					CacheSizeMegabytes: to.Ptr[int32](28),
	// 					SelfTracing: &armiotoperations.SelfTracing{
	// 						Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 						IntervalSeconds: to.Ptr[int32](22),
	// 					},
	// 					SpanChannelCapacity: to.Ptr[int32](1000),
	// 				},
	// 			},
	// 			DiskBackedMessageBuffer: &armiotoperations.DiskBackedMessageBuffer{
	// 				MaxSize: to.Ptr("500M"),
	// 				EphemeralVolumeClaimSpec: &armiotoperations.VolumeClaimSpec{
	// 					VolumeName: to.Ptr("c"),
	// 					VolumeMode: to.Ptr("rxvpksjuuugqnqzeiprocknbn"),
	// 					StorageClassName: to.Ptr("sseyhrjptkhrqvpdpjmornkqvon"),
	// 					AccessModes: []*string{
	// 						to.Ptr("nuluhigrbb"),
	// 					},
	// 					DataSource: &armiotoperations.LocalKubernetesReference{
	// 						APIGroup: to.Ptr("npqapyksvvpkohujx"),
	// 						Kind: to.Ptr("wazgyb"),
	// 						Name: to.Ptr("cwhsgxxcxsyppoefm"),
	// 					},
	// 					DataSourceRef: &armiotoperations.KubernetesReference{
	// 						APIGroup: to.Ptr("mnfnykznjjsoqpfsgdqioupt"),
	// 						Kind: to.Ptr("odynqzekfzsnawrctaxg"),
	// 						Name: to.Ptr("envszivbbmixbyddzg"),
	// 						Namespace: to.Ptr("etcfzvxqd"),
	// 					},
	// 					Resources: &armiotoperations.VolumeClaimResourceRequirements{
	// 						Limits: map[string]*string{
	// 							"key2719": to.Ptr("hmphcrgctu"),
	// 						},
	// 						Requests: map[string]*string{
	// 							"key2909": to.Ptr("txocprnyrsgvhfrg"),
	// 						},
	// 					},
	// 					Selector: &armiotoperations.VolumeClaimSpecSelector{
	// 						MatchExpressions: []*armiotoperations.VolumeClaimSpecSelectorMatchExpressions{
	// 							{
	// 								Key: to.Ptr("e"),
	// 								Operator: to.Ptr(armiotoperations.OperatorValuesIn),
	// 								Values: []*string{
	// 									to.Ptr("slmpajlywqvuyknipgztsonqyybt"),
	// 								},
	// 							},
	// 						},
	// 						MatchLabels: map[string]*string{
	// 							"key6673": to.Ptr("wlngfalznwxnurzpgxomcxhbqefpr"),
	// 						},
	// 					},
	// 				},
	// 				PersistentVolumeClaimSpec: &armiotoperations.VolumeClaimSpec{
	// 					VolumeName: to.Ptr("c"),
	// 					VolumeMode: to.Ptr("rxvpksjuuugqnqzeiprocknbn"),
	// 					StorageClassName: to.Ptr("sseyhrjptkhrqvpdpjmornkqvon"),
	// 					AccessModes: []*string{
	// 						to.Ptr("nuluhigrbb"),
	// 					},
	// 					DataSource: &armiotoperations.LocalKubernetesReference{
	// 						APIGroup: to.Ptr("npqapyksvvpkohujx"),
	// 						Kind: to.Ptr("wazgyb"),
	// 						Name: to.Ptr("cwhsgxxcxsyppoefm"),
	// 					},
	// 					DataSourceRef: &armiotoperations.KubernetesReference{
	// 						APIGroup: to.Ptr("mnfnykznjjsoqpfsgdqioupt"),
	// 						Kind: to.Ptr("odynqzekfzsnawrctaxg"),
	// 						Name: to.Ptr("envszivbbmixbyddzg"),
	// 						Namespace: to.Ptr("etcfzvxqd"),
	// 					},
	// 					Resources: &armiotoperations.VolumeClaimResourceRequirements{
	// 						Limits: map[string]*string{
	// 							"key2719": to.Ptr("hmphcrgctu"),
	// 						},
	// 						Requests: map[string]*string{
	// 							"key2909": to.Ptr("txocprnyrsgvhfrg"),
	// 						},
	// 					},
	// 					Selector: &armiotoperations.VolumeClaimSpecSelector{
	// 						MatchExpressions: []*armiotoperations.VolumeClaimSpecSelectorMatchExpressions{
	// 							{
	// 								Key: to.Ptr("e"),
	// 								Operator: to.Ptr(armiotoperations.OperatorValuesIn),
	// 								Values: []*string{
	// 									to.Ptr("slmpajlywqvuyknipgztsonqyybt"),
	// 								},
	// 							},
	// 						},
	// 						MatchLabels: map[string]*string{
	// 							"key6673": to.Ptr("wlngfalznwxnurzpgxomcxhbqefpr"),
	// 						},
	// 					},
	// 				},
	// 			},
	// 			GenerateResourceLimits: &armiotoperations.GenerateResourceLimits{
	// 				CPU: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 			},
	// 			MemoryProfile: to.Ptr(armiotoperations.BrokerMemoryProfileTiny),
	// 			ProvisioningState: to.Ptr(armiotoperations.ProvisioningStateSucceeded),
	// 		},
	// 		ExtendedLocation: &armiotoperations.ExtendedLocation{
	// 			Name: to.Ptr("qmbrfwcpwwhggszhrdjv"),
	// 			Type: to.Ptr(armiotoperations.ExtendedLocationTypeCustomLocation),
	// 		},
	// 		ID: to.Ptr("/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123"),
	// 		Name: to.Ptr("dowrkel"),
	// 		Type: to.Ptr("xshjnsdgadygb"),
	// 		SystemData: &armiotoperations.SystemData{
	// 			CreatedBy: to.Ptr("ssvaslsmudloholronopqyxjcu"),
	// 			CreatedByType: to.Ptr(armiotoperations.CreatedByTypeUser),
	// 			CreatedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2024-08-09T18:13:29.389Z"); return t}()),
	// 			LastModifiedBy: to.Ptr("gnicpuszwd"),
	// 			LastModifiedByType: to.Ptr(armiotoperations.CreatedByTypeUser),
	// 			LastModifiedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2024-08-09T18:13:29.389Z"); return t}()),
	// 		},
	// 	},
	// }
}

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

dotnet

using Azure;
using Azure.ResourceManager;
using System;
using System.Threading.Tasks;
using Azure.Core;
using Azure.Identity;
using Azure.ResourceManager.IotOperations.Models;
using Azure.ResourceManager.IotOperations;

// Generated from example definition: 2024-11-01/Broker_CreateOrUpdate_Minimal.json
// this example is just showing the usage of "BrokerResource_CreateOrUpdate" operation, for the dependent resources, they will have to be created separately.

// get your azure access token, for more details of how Azure SDK get your access token, please refer to https://learn.microsoft.com/en-us/dotnet/azure/sdk/authentication?tabs=command-line
TokenCredential cred = new DefaultAzureCredential();
// authenticate your client
ArmClient client = new ArmClient(cred);

// this example assumes you already have this IotOperationsBrokerResource created on azure
// for more information of creating IotOperationsBrokerResource, please refer to the document of IotOperationsBrokerResource
string subscriptionId = "F8C729F9-DF9C-4743-848F-96EE433D8E53";
string resourceGroupName = "rgiotoperations";
string instanceName = "resource-name123";
string brokerName = "resource-name123";
ResourceIdentifier iotOperationsBrokerResourceId = IotOperationsBrokerResource.CreateResourceIdentifier(subscriptionId, resourceGroupName, instanceName, brokerName);
IotOperationsBrokerResource iotOperationsBroker = client.GetIotOperationsBrokerResource(iotOperationsBrokerResourceId);

// invoke the operation
IotOperationsBrokerData data = new IotOperationsBrokerData(new IotOperationsExtendedLocation("qmbrfwcpwwhggszhrdjv", IotOperationsExtendedLocationType.CustomLocation))
{
    Properties = new IotOperationsBrokerProperties
    {
        MemoryProfile = BrokerMemoryProfile.Tiny,
    },
};
ArmOperation<IotOperationsBrokerResource> lro = await iotOperationsBroker.UpdateAsync(WaitUntil.Completed, data);
IotOperationsBrokerResource result = lro.Value;

// the variable result is a resource, you could call other operations on this instance as well
// but just for demo, we get its data from this resource instance
IotOperationsBrokerData resourceData = result.Data;
// for demo we just print out the id
Console.WriteLine($"Succeeded on id: {resourceData.Id}");

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

Exempelsvar

Statuskod:

200

{
  "properties": {
    "advanced": {
      "clients": {
        "maxSessionExpirySeconds": 3859,
        "maxMessageExpirySeconds": 3263,
        "maxPacketSizeBytes": 3029,
        "subscriberQueueLimit": {
          "length": 6,
          "strategy": "None"
        },
        "maxReceiveMaximum": 2365,
        "maxKeepAliveSeconds": 3744
      },
      "encryptInternalTraffic": "Enabled",
      "internalCerts": {
        "duration": "bchrc",
        "renewBefore": "xkafmpgjfifkwwrhkswtopdnne",
        "privateKey": {
          "algorithm": "Ec256",
          "rotationPolicy": "Always"
        }
      }
    },
    "cardinality": {
      "backendChain": {
        "partitions": 11,
        "redundancyFactor": 5,
        "workers": 15
      },
      "frontend": {
        "replicas": 2,
        "workers": 6
      }
    },
    "diagnostics": {
      "logs": {
        "level": "rnmwokumdmebpmfxxxzvvjfdywotav"
      },
      "metrics": {
        "prometheusPort": 7581
      },
      "selfCheck": {
        "mode": "Enabled",
        "intervalSeconds": 158,
        "timeoutSeconds": 14
      },
      "traces": {
        "mode": "Enabled",
        "cacheSizeMegabytes": 28,
        "selfTracing": {
          "mode": "Enabled",
          "intervalSeconds": 22
        },
        "spanChannelCapacity": 1000
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "500M",
      "ephemeralVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      },
      "persistentVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      }
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Tiny",
    "provisioningState": "Succeeded"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  },
  "id": "/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123",
  "name": "dowrkel",
  "type": "xshjnsdgadygb",
  "systemData": {
    "createdBy": "ssvaslsmudloholronopqyxjcu",
    "createdByType": "User",
    "createdAt": "2024-08-09T18:13:29.389Z",
    "lastModifiedBy": "gnicpuszwd",
    "lastModifiedByType": "User",
    "lastModifiedAt": "2024-08-09T18:13:29.389Z"
  }
}

Statuskod:

201

Azure-AsyncOperation: https://contoso.com/operationstatus

{
  "properties": {
    "advanced": {
      "clients": {
        "maxSessionExpirySeconds": 3859,
        "maxMessageExpirySeconds": 3263,
        "maxPacketSizeBytes": 3029,
        "subscriberQueueLimit": {
          "length": 6,
          "strategy": "None"
        },
        "maxReceiveMaximum": 2365,
        "maxKeepAliveSeconds": 3744
      },
      "encryptInternalTraffic": "Enabled",
      "internalCerts": {
        "duration": "bchrc",
        "renewBefore": "xkafmpgjfifkwwrhkswtopdnne",
        "privateKey": {
          "algorithm": "Ec256",
          "rotationPolicy": "Always"
        }
      }
    },
    "cardinality": {
      "backendChain": {
        "partitions": 11,
        "redundancyFactor": 5,
        "workers": 15
      },
      "frontend": {
        "replicas": 2,
        "workers": 6
      }
    },
    "diagnostics": {
      "logs": {
        "level": "rnmwokumdmebpmfxxxzvvjfdywotav"
      },
      "metrics": {
        "prometheusPort": 7581
      },
      "selfCheck": {
        "mode": "Enabled",
        "intervalSeconds": 158,
        "timeoutSeconds": 14
      },
      "traces": {
        "mode": "Enabled",
        "cacheSizeMegabytes": 28,
        "selfTracing": {
          "mode": "Enabled",
          "intervalSeconds": 22
        },
        "spanChannelCapacity": 1000
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "500M",
      "ephemeralVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      },
      "persistentVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      }
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Tiny",
    "provisioningState": "Succeeded"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  },
  "id": "/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123",
  "name": "dowrkel",
  "type": "xshjnsdgadygb",
  "systemData": {
    "createdBy": "ssvaslsmudloholronopqyxjcu",
    "createdByType": "User",
    "createdAt": "2024-08-09T18:13:29.389Z",
    "lastModifiedBy": "gnicpuszwd",
    "lastModifiedByType": "User",
    "lastModifiedAt": "2024-08-09T18:13:29.389Z"
  }
}

Broker_CreateOrUpdate_Simple

Exempelbegäran

HTTP

PUT https://management.azure.com/subscriptions/F8C729F9-DF9C-4743-848F-96EE433D8E53/resourceGroups/rgiotoperations/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123?api-version=2024-11-01

{
  "properties": {
    "cardinality": {
      "backendChain": {
        "partitions": 2,
        "redundancyFactor": 2,
        "workers": 2
      },
      "frontend": {
        "replicas": 2,
        "workers": 2
      }
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Low"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  }
}

Java

import com.azure.resourcemanager.iotoperations.models.BackendChain;
import com.azure.resourcemanager.iotoperations.models.BrokerMemoryProfile;
import com.azure.resourcemanager.iotoperations.models.BrokerProperties;
import com.azure.resourcemanager.iotoperations.models.Cardinality;
import com.azure.resourcemanager.iotoperations.models.ExtendedLocation;
import com.azure.resourcemanager.iotoperations.models.ExtendedLocationType;
import com.azure.resourcemanager.iotoperations.models.Frontend;
import com.azure.resourcemanager.iotoperations.models.GenerateResourceLimits;
import com.azure.resourcemanager.iotoperations.models.OperationalMode;
import java.util.HashMap;
import java.util.Map;

/**
 * Samples for Broker CreateOrUpdate.
 */
public final class Main {
    /*
     * x-ms-original-file: 2024-11-01/Broker_CreateOrUpdate_Simple.json
     */
    /**
     * Sample code: Broker_CreateOrUpdate_Simple.
     * 
     * @param manager Entry point to IoTOperationsManager.
     */
    public static void
        brokerCreateOrUpdateSimple(com.azure.resourcemanager.iotoperations.IoTOperationsManager manager) {
        manager
            .brokers().define(
                "resource-name123")
            .withExistingInstance("rgiotoperations", "resource-name123")
            .withExtendedLocation(new ExtendedLocation().withName("qmbrfwcpwwhggszhrdjv")
                .withType(ExtendedLocationType.CUSTOM_LOCATION))
            .withProperties(new BrokerProperties()
                .withCardinality(new Cardinality()
                    .withBackendChain(new BackendChain().withPartitions(2).withRedundancyFactor(2).withWorkers(2))
                    .withFrontend(new Frontend().withReplicas(2).withWorkers(2)))
                .withGenerateResourceLimits(new GenerateResourceLimits().withCpu(OperationalMode.ENABLED))
                .withMemoryProfile(BrokerMemoryProfile.LOW))
            .create();
    }

    // Use "Map.of" if available
    @SuppressWarnings("unchecked")
    private static <T> Map<String, T> mapOf(Object... inputs) {
        Map<String, T> map = new HashMap<>();
        for (int i = 0; i < inputs.length; i += 2) {
            String key = (String) inputs[i];
            T value = (T) inputs[i + 1];
            map.put(key, value);
        }
        return map;
    }
}

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

Python

from azure.identity import DefaultAzureCredential

from azure.mgmt.iotoperations import IoTOperationsMgmtClient

"""
# PREREQUISITES
    pip install azure-identity
    pip install azure-mgmt-iotoperations
# USAGE
    python broker_create_or_update_simple.py

    Before run the sample, please set the values of the client ID, tenant ID and client secret
    of the AAD application as environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID,
    AZURE_CLIENT_SECRET. For more info about how to get the value, please see:
    https://docs.microsoft.com/azure/active-directory/develop/howto-create-service-principal-portal
"""


def main():
    client = IoTOperationsMgmtClient(
        credential=DefaultAzureCredential(),
        subscription_id="SUBSCRIPTION_ID",
    )

    response = client.broker.begin_create_or_update(
        resource_group_name="rgiotoperations",
        instance_name="resource-name123",
        broker_name="resource-name123",
        resource={
            "extendedLocation": {"name": "qmbrfwcpwwhggszhrdjv", "type": "CustomLocation"},
            "properties": {
                "cardinality": {
                    "backendChain": {"partitions": 2, "redundancyFactor": 2, "workers": 2},
                    "frontend": {"replicas": 2, "workers": 2},
                },
                "generateResourceLimits": {"cpu": "Enabled"},
                "memoryProfile": "Low",
            },
        },
    ).result()
    print(response)


# x-ms-original-file: 2024-11-01/Broker_CreateOrUpdate_Simple.json
if __name__ == "__main__":
    main()

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 armiotoperations_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/iotoperations/armiotoperations"
)

// Generated from example definition: 2024-11-01/Broker_CreateOrUpdate_Simple.json
func ExampleBrokerClient_BeginCreateOrUpdate_brokerCreateOrUpdateSimple() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armiotoperations.NewClientFactory("F8C729F9-DF9C-4743-848F-96EE433D8E53", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	poller, err := clientFactory.NewBrokerClient().BeginCreateOrUpdate(ctx, "rgiotoperations", "resource-name123", "resource-name123", armiotoperations.BrokerResource{
		Properties: &armiotoperations.BrokerProperties{
			Cardinality: &armiotoperations.Cardinality{
				BackendChain: &armiotoperations.BackendChain{
					Partitions:       to.Ptr[int32](2),
					RedundancyFactor: to.Ptr[int32](2),
					Workers:          to.Ptr[int32](2),
				},
				Frontend: &armiotoperations.Frontend{
					Replicas: to.Ptr[int32](2),
					Workers:  to.Ptr[int32](2),
				},
			},
			GenerateResourceLimits: &armiotoperations.GenerateResourceLimits{
				CPU: to.Ptr(armiotoperations.OperationalModeEnabled),
			},
			MemoryProfile: to.Ptr(armiotoperations.BrokerMemoryProfileLow),
		},
		ExtendedLocation: &armiotoperations.ExtendedLocation{
			Name: to.Ptr("qmbrfwcpwwhggszhrdjv"),
			Type: to.Ptr(armiotoperations.ExtendedLocationTypeCustomLocation),
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %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 = armiotoperations.BrokerClientCreateOrUpdateResponse{
	// 	BrokerResource: &armiotoperations.BrokerResource{
	// 		Properties: &armiotoperations.BrokerProperties{
	// 			Advanced: &armiotoperations.AdvancedSettings{
	// 				Clients: &armiotoperations.ClientConfig{
	// 					MaxSessionExpirySeconds: to.Ptr[int32](3859),
	// 					MaxMessageExpirySeconds: to.Ptr[int32](3263),
	// 					MaxPacketSizeBytes: to.Ptr[int32](3029),
	// 					SubscriberQueueLimit: &armiotoperations.SubscriberQueueLimit{
	// 						Length: to.Ptr[int64](6),
	// 						Strategy: to.Ptr(armiotoperations.SubscriberMessageDropStrategyNone),
	// 					},
	// 					MaxReceiveMaximum: to.Ptr[int32](2365),
	// 					MaxKeepAliveSeconds: to.Ptr[int32](3744),
	// 				},
	// 				EncryptInternalTraffic: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 				InternalCerts: &armiotoperations.CertManagerCertOptions{
	// 					Duration: to.Ptr("bchrc"),
	// 					RenewBefore: to.Ptr("xkafmpgjfifkwwrhkswtopdnne"),
	// 					PrivateKey: &armiotoperations.CertManagerPrivateKey{
	// 						Algorithm: to.Ptr(armiotoperations.PrivateKeyAlgorithmEc256),
	// 						RotationPolicy: to.Ptr(armiotoperations.PrivateKeyRotationPolicyAlways),
	// 					},
	// 				},
	// 			},
	// 			Cardinality: &armiotoperations.Cardinality{
	// 				BackendChain: &armiotoperations.BackendChain{
	// 					Partitions: to.Ptr[int32](11),
	// 					RedundancyFactor: to.Ptr[int32](5),
	// 					Workers: to.Ptr[int32](15),
	// 				},
	// 				Frontend: &armiotoperations.Frontend{
	// 					Replicas: to.Ptr[int32](2),
	// 					Workers: to.Ptr[int32](6),
	// 				},
	// 			},
	// 			Diagnostics: &armiotoperations.BrokerDiagnostics{
	// 				Logs: &armiotoperations.DiagnosticsLogs{
	// 					Level: to.Ptr("rnmwokumdmebpmfxxxzvvjfdywotav"),
	// 				},
	// 				Metrics: &armiotoperations.Metrics{
	// 					PrometheusPort: to.Ptr[int32](7581),
	// 				},
	// 				SelfCheck: &armiotoperations.SelfCheck{
	// 					Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 					IntervalSeconds: to.Ptr[int32](158),
	// 					TimeoutSeconds: to.Ptr[int32](14),
	// 				},
	// 				Traces: &armiotoperations.Traces{
	// 					Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 					CacheSizeMegabytes: to.Ptr[int32](28),
	// 					SelfTracing: &armiotoperations.SelfTracing{
	// 						Mode: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 						IntervalSeconds: to.Ptr[int32](22),
	// 					},
	// 					SpanChannelCapacity: to.Ptr[int32](1000),
	// 				},
	// 			},
	// 			DiskBackedMessageBuffer: &armiotoperations.DiskBackedMessageBuffer{
	// 				MaxSize: to.Ptr("500M"),
	// 				EphemeralVolumeClaimSpec: &armiotoperations.VolumeClaimSpec{
	// 					VolumeName: to.Ptr("c"),
	// 					VolumeMode: to.Ptr("rxvpksjuuugqnqzeiprocknbn"),
	// 					StorageClassName: to.Ptr("sseyhrjptkhrqvpdpjmornkqvon"),
	// 					AccessModes: []*string{
	// 						to.Ptr("nuluhigrbb"),
	// 					},
	// 					DataSource: &armiotoperations.LocalKubernetesReference{
	// 						APIGroup: to.Ptr("npqapyksvvpkohujx"),
	// 						Kind: to.Ptr("wazgyb"),
	// 						Name: to.Ptr("cwhsgxxcxsyppoefm"),
	// 					},
	// 					DataSourceRef: &armiotoperations.KubernetesReference{
	// 						APIGroup: to.Ptr("mnfnykznjjsoqpfsgdqioupt"),
	// 						Kind: to.Ptr("odynqzekfzsnawrctaxg"),
	// 						Name: to.Ptr("envszivbbmixbyddzg"),
	// 						Namespace: to.Ptr("etcfzvxqd"),
	// 					},
	// 					Resources: &armiotoperations.VolumeClaimResourceRequirements{
	// 						Limits: map[string]*string{
	// 							"key2719": to.Ptr("hmphcrgctu"),
	// 						},
	// 						Requests: map[string]*string{
	// 							"key2909": to.Ptr("txocprnyrsgvhfrg"),
	// 						},
	// 					},
	// 					Selector: &armiotoperations.VolumeClaimSpecSelector{
	// 						MatchExpressions: []*armiotoperations.VolumeClaimSpecSelectorMatchExpressions{
	// 							{
	// 								Key: to.Ptr("e"),
	// 								Operator: to.Ptr(armiotoperations.OperatorValuesIn),
	// 								Values: []*string{
	// 									to.Ptr("slmpajlywqvuyknipgztsonqyybt"),
	// 								},
	// 							},
	// 						},
	// 						MatchLabels: map[string]*string{
	// 							"key6673": to.Ptr("wlngfalznwxnurzpgxomcxhbqefpr"),
	// 						},
	// 					},
	// 				},
	// 				PersistentVolumeClaimSpec: &armiotoperations.VolumeClaimSpec{
	// 					VolumeName: to.Ptr("c"),
	// 					VolumeMode: to.Ptr("rxvpksjuuugqnqzeiprocknbn"),
	// 					StorageClassName: to.Ptr("sseyhrjptkhrqvpdpjmornkqvon"),
	// 					AccessModes: []*string{
	// 						to.Ptr("nuluhigrbb"),
	// 					},
	// 					DataSource: &armiotoperations.LocalKubernetesReference{
	// 						APIGroup: to.Ptr("npqapyksvvpkohujx"),
	// 						Kind: to.Ptr("wazgyb"),
	// 						Name: to.Ptr("cwhsgxxcxsyppoefm"),
	// 					},
	// 					DataSourceRef: &armiotoperations.KubernetesReference{
	// 						APIGroup: to.Ptr("mnfnykznjjsoqpfsgdqioupt"),
	// 						Kind: to.Ptr("odynqzekfzsnawrctaxg"),
	// 						Name: to.Ptr("envszivbbmixbyddzg"),
	// 						Namespace: to.Ptr("etcfzvxqd"),
	// 					},
	// 					Resources: &armiotoperations.VolumeClaimResourceRequirements{
	// 						Limits: map[string]*string{
	// 							"key2719": to.Ptr("hmphcrgctu"),
	// 						},
	// 						Requests: map[string]*string{
	// 							"key2909": to.Ptr("txocprnyrsgvhfrg"),
	// 						},
	// 					},
	// 					Selector: &armiotoperations.VolumeClaimSpecSelector{
	// 						MatchExpressions: []*armiotoperations.VolumeClaimSpecSelectorMatchExpressions{
	// 							{
	// 								Key: to.Ptr("e"),
	// 								Operator: to.Ptr(armiotoperations.OperatorValuesIn),
	// 								Values: []*string{
	// 									to.Ptr("slmpajlywqvuyknipgztsonqyybt"),
	// 								},
	// 							},
	// 						},
	// 						MatchLabels: map[string]*string{
	// 							"key6673": to.Ptr("wlngfalznwxnurzpgxomcxhbqefpr"),
	// 						},
	// 					},
	// 				},
	// 			},
	// 			GenerateResourceLimits: &armiotoperations.GenerateResourceLimits{
	// 				CPU: to.Ptr(armiotoperations.OperationalModeEnabled),
	// 			},
	// 			MemoryProfile: to.Ptr(armiotoperations.BrokerMemoryProfileTiny),
	// 			ProvisioningState: to.Ptr(armiotoperations.ProvisioningStateSucceeded),
	// 		},
	// 		ExtendedLocation: &armiotoperations.ExtendedLocation{
	// 			Name: to.Ptr("qmbrfwcpwwhggszhrdjv"),
	// 			Type: to.Ptr(armiotoperations.ExtendedLocationTypeCustomLocation),
	// 		},
	// 		ID: to.Ptr("/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123"),
	// 		Name: to.Ptr("dowrkel"),
	// 		Type: to.Ptr("xshjnsdgadygb"),
	// 		SystemData: &armiotoperations.SystemData{
	// 			CreatedBy: to.Ptr("ssvaslsmudloholronopqyxjcu"),
	// 			CreatedByType: to.Ptr(armiotoperations.CreatedByTypeUser),
	// 			CreatedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2024-08-09T18:13:29.389Z"); return t}()),
	// 			LastModifiedBy: to.Ptr("gnicpuszwd"),
	// 			LastModifiedByType: to.Ptr(armiotoperations.CreatedByTypeUser),
	// 			LastModifiedAt: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2024-08-09T18:13:29.389Z"); return t}()),
	// 		},
	// 	},
	// }
}

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

dotnet

using Azure;
using Azure.ResourceManager;
using System;
using System.Threading.Tasks;
using Azure.Core;
using Azure.Identity;
using Azure.ResourceManager.IotOperations.Models;
using Azure.ResourceManager.IotOperations;

// Generated from example definition: 2024-11-01/Broker_CreateOrUpdate_Simple.json
// this example is just showing the usage of "BrokerResource_CreateOrUpdate" operation, for the dependent resources, they will have to be created separately.

// get your azure access token, for more details of how Azure SDK get your access token, please refer to https://learn.microsoft.com/en-us/dotnet/azure/sdk/authentication?tabs=command-line
TokenCredential cred = new DefaultAzureCredential();
// authenticate your client
ArmClient client = new ArmClient(cred);

// this example assumes you already have this IotOperationsBrokerResource created on azure
// for more information of creating IotOperationsBrokerResource, please refer to the document of IotOperationsBrokerResource
string subscriptionId = "F8C729F9-DF9C-4743-848F-96EE433D8E53";
string resourceGroupName = "rgiotoperations";
string instanceName = "resource-name123";
string brokerName = "resource-name123";
ResourceIdentifier iotOperationsBrokerResourceId = IotOperationsBrokerResource.CreateResourceIdentifier(subscriptionId, resourceGroupName, instanceName, brokerName);
IotOperationsBrokerResource iotOperationsBroker = client.GetIotOperationsBrokerResource(iotOperationsBrokerResourceId);

// invoke the operation
IotOperationsBrokerData data = new IotOperationsBrokerData(new IotOperationsExtendedLocation("qmbrfwcpwwhggszhrdjv", IotOperationsExtendedLocationType.CustomLocation))
{
    Properties = new IotOperationsBrokerProperties
    {
        Cardinality = new BrokerCardinality(new BrokerBackendChain(2, 2)
        {
            Workers = 2,
        }, new BrokerFrontend(2)
        {
            Workers = 2,
        }),
        GenerateResourceLimitsCpu = IotOperationsOperationalMode.Enabled,
        MemoryProfile = BrokerMemoryProfile.Low,
    },
};
ArmOperation<IotOperationsBrokerResource> lro = await iotOperationsBroker.UpdateAsync(WaitUntil.Completed, data);
IotOperationsBrokerResource result = lro.Value;

// the variable result is a resource, you could call other operations on this instance as well
// but just for demo, we get its data from this resource instance
IotOperationsBrokerData resourceData = result.Data;
// for demo we just print out the id
Console.WriteLine($"Succeeded on id: {resourceData.Id}");

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

Exempelsvar

Statuskod:

200

{
  "properties": {
    "advanced": {
      "clients": {
        "maxSessionExpirySeconds": 3859,
        "maxMessageExpirySeconds": 3263,
        "maxPacketSizeBytes": 3029,
        "subscriberQueueLimit": {
          "length": 6,
          "strategy": "None"
        },
        "maxReceiveMaximum": 2365,
        "maxKeepAliveSeconds": 3744
      },
      "encryptInternalTraffic": "Enabled",
      "internalCerts": {
        "duration": "bchrc",
        "renewBefore": "xkafmpgjfifkwwrhkswtopdnne",
        "privateKey": {
          "algorithm": "Ec256",
          "rotationPolicy": "Always"
        }
      }
    },
    "cardinality": {
      "backendChain": {
        "partitions": 11,
        "redundancyFactor": 5,
        "workers": 15
      },
      "frontend": {
        "replicas": 2,
        "workers": 6
      }
    },
    "diagnostics": {
      "logs": {
        "level": "rnmwokumdmebpmfxxxzvvjfdywotav"
      },
      "metrics": {
        "prometheusPort": 7581
      },
      "selfCheck": {
        "mode": "Enabled",
        "intervalSeconds": 158,
        "timeoutSeconds": 14
      },
      "traces": {
        "mode": "Enabled",
        "cacheSizeMegabytes": 28,
        "selfTracing": {
          "mode": "Enabled",
          "intervalSeconds": 22
        },
        "spanChannelCapacity": 1000
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "500M",
      "ephemeralVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      },
      "persistentVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      }
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Tiny",
    "provisioningState": "Succeeded"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  },
  "id": "/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123",
  "name": "dowrkel",
  "type": "xshjnsdgadygb",
  "systemData": {
    "createdBy": "ssvaslsmudloholronopqyxjcu",
    "createdByType": "User",
    "createdAt": "2024-08-09T18:13:29.389Z",
    "lastModifiedBy": "gnicpuszwd",
    "lastModifiedByType": "User",
    "lastModifiedAt": "2024-08-09T18:13:29.389Z"
  }
}

Statuskod:

201

Azure-AsyncOperation: https://contoso.com/operationstatus

{
  "properties": {
    "advanced": {
      "clients": {
        "maxSessionExpirySeconds": 3859,
        "maxMessageExpirySeconds": 3263,
        "maxPacketSizeBytes": 3029,
        "subscriberQueueLimit": {
          "length": 6,
          "strategy": "None"
        },
        "maxReceiveMaximum": 2365,
        "maxKeepAliveSeconds": 3744
      },
      "encryptInternalTraffic": "Enabled",
      "internalCerts": {
        "duration": "bchrc",
        "renewBefore": "xkafmpgjfifkwwrhkswtopdnne",
        "privateKey": {
          "algorithm": "Ec256",
          "rotationPolicy": "Always"
        }
      }
    },
    "cardinality": {
      "backendChain": {
        "partitions": 11,
        "redundancyFactor": 5,
        "workers": 15
      },
      "frontend": {
        "replicas": 2,
        "workers": 6
      }
    },
    "diagnostics": {
      "logs": {
        "level": "rnmwokumdmebpmfxxxzvvjfdywotav"
      },
      "metrics": {
        "prometheusPort": 7581
      },
      "selfCheck": {
        "mode": "Enabled",
        "intervalSeconds": 158,
        "timeoutSeconds": 14
      },
      "traces": {
        "mode": "Enabled",
        "cacheSizeMegabytes": 28,
        "selfTracing": {
          "mode": "Enabled",
          "intervalSeconds": 22
        },
        "spanChannelCapacity": 1000
      }
    },
    "diskBackedMessageBuffer": {
      "maxSize": "500M",
      "ephemeralVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      },
      "persistentVolumeClaimSpec": {
        "volumeName": "c",
        "volumeMode": "rxvpksjuuugqnqzeiprocknbn",
        "storageClassName": "sseyhrjptkhrqvpdpjmornkqvon",
        "accessModes": [
          "nuluhigrbb"
        ],
        "dataSource": {
          "apiGroup": "npqapyksvvpkohujx",
          "kind": "wazgyb",
          "name": "cwhsgxxcxsyppoefm"
        },
        "dataSourceRef": {
          "apiGroup": "mnfnykznjjsoqpfsgdqioupt",
          "kind": "odynqzekfzsnawrctaxg",
          "name": "envszivbbmixbyddzg",
          "namespace": "etcfzvxqd"
        },
        "resources": {
          "limits": {
            "key2719": "hmphcrgctu"
          },
          "requests": {
            "key2909": "txocprnyrsgvhfrg"
          }
        },
        "selector": {
          "matchExpressions": [
            {
              "key": "e",
              "operator": "In",
              "values": [
                "slmpajlywqvuyknipgztsonqyybt"
              ]
            }
          ],
          "matchLabels": {
            "key6673": "wlngfalznwxnurzpgxomcxhbqefpr"
          }
        }
      }
    },
    "generateResourceLimits": {
      "cpu": "Enabled"
    },
    "memoryProfile": "Tiny",
    "provisioningState": "Succeeded"
  },
  "extendedLocation": {
    "name": "qmbrfwcpwwhggszhrdjv",
    "type": "CustomLocation"
  },
  "id": "/subscriptions/0000000-0000-0000-0000-000000000000/resourceGroups/resourceGroup123/providers/Microsoft.IoTOperations/instances/resource-name123/brokers/resource-name123",
  "name": "dowrkel",
  "type": "xshjnsdgadygb",
  "systemData": {
    "createdBy": "ssvaslsmudloholronopqyxjcu",
    "createdByType": "User",
    "createdAt": "2024-08-09T18:13:29.389Z",
    "lastModifiedBy": "gnicpuszwd",
    "lastModifiedByType": "User",
    "lastModifiedAt": "2024-08-09T18:13:29.389Z"
  }
}

Definitioner

Name	Description
AdvancedSettings	Avancerade inställningar för broker
BackendChain	Önskade egenskaper för serverdelsinstanserna för asynkron meddelandekö
BrokerDiagnostics	Egenskaper för asynkron diagnostikinställning
BrokerMemoryProfile	Inställningarna för minnesprofilen för Broker
BrokerProperties	Egenskaper för broker-resurs
BrokerResource	Instans broker-resurs
Cardinality	Kardinalitetsegenskaper
CertManagerCertOptions	Cert Manager-certifikategenskaper
CertManagerPrivateKey	Egenskaper för privat nyckel i Cert Manager
ClientConfig	Inställningarna för Klientkonfiguration.
createdByType	Den typ av identitet som skapade resursen.
DiagnosticsLogs	Egenskaper för diagnostiklogg
DiskBackedMessageBuffer	DiskBackedMessageBuffer-egenskaper
ErrorAdditionalInfo	Ytterligare information om resurshanteringsfelet.
ErrorDetail	Felinformationen.
ErrorResponse	Felsvar
ExtendedLocation	Utökad plats är ett tillägg av Azure-platser. De tillhandahåller ett sätt att använda sina Azure ARC-aktiverade Kubernetes-kluster som målplatser för distribution av Azure-tjänstinstanser.
ExtendedLocationType	Den uppräkningsdefinieringstyp för ExtendedLocation som accepteras.
Frontend	De önskade egenskaperna för klientdelsinstanserna i Broker
GenerateResourceLimits	Egenskaper för GenerateResourceLimits
KubernetesReference	Kubernetes-referens
LocalKubernetesReference	Kubernetes-referens
Metrics	Egenskaper för diagnostikmått
OperationalMode	Lägesegenskaper
OperatorValues	Giltiga operatorer är In, NotIn, Exists och DoesNotExist.
PrivateKeyAlgorithm	Algoritmtyper för privata nycklar.
PrivateKeyRotationPolicy	Roteringsprincip för privat nyckel.
ProvisioningState	Uppräkningen som definierar status för resursen.
SelfCheck	Egenskaper för broker Diagnostic Self check
SelfTracing	Egenskaper för självspårning av diagnostik
SubscriberMessageDropStrategy	Uppräkningen definierar strategier för att ta bort meddelanden från prenumerantkön.
SubscriberQueueLimit	Inställningarna för kögräns för prenumeranter.
systemData	Metadata som rör skapande och senaste ändring av resursen.
Traces	Egenskaper för asynkron diagnostikspårning
VolumeClaimResourceRequirements	VolumeClaimResourceRequirements-egenskaper
VolumeClaimSpec	VolumeClaimSpec-egenskaper
VolumeClaimSpecSelector	Egenskaper för VolumeClaimSpecSelector
VolumeClaimSpecSelectorMatchExpressions	VolumeClaimSpecSelectorMatchExpressions-egenskaper

AdvancedSettings

Objekt

Avancerade inställningar för broker

Name	Typ	Standardvärde	Description
clients	ClientConfig		Konfigurationer relaterade till alla klienter.
encryptInternalTraffic	OperationalMode	Enabled	Inställningen för att aktivera eller inaktivera kryptering av intern trafik.
internalCerts	CertManagerCertOptions		Certifikatrotation och konfiguration av privat nyckel.

BackendChain

Objekt

Önskade egenskaper för serverdelsinstanserna för asynkron meddelandekö

Name	Typ	Standardvärde	Description
partitions	integer (int32) minimum: 1 maximum: 16		Önskat antal fysiska serverdelspartitioner.
redundancyFactor	integer (int32) minimum: 1 maximum: 5		Önskat antal serverdelsrepliker (poddar) i en fysisk partition.
workers	integer (int32) minimum: 1 maximum: 16	1	Antal logiska serverdelsarbetare per replik (podd).

BrokerDiagnostics

Objekt

Egenskaper för asynkron diagnostikinställning

Name	Typ	Description
logs	DiagnosticsLogs	Diagnostiklogginställningar för resursen.
metrics	Metrics	Måttinställningarna för resursen.
selfCheck	SelfCheck	Egenskaperna för självkontroll.
traces	Traces	Spårningsegenskaperna.

BrokerMemoryProfile

Uppräkning

Inställningarna för minnesprofilen för Broker

Värde	Description
High	Hög minnesprofil.
Low	Låg minnesprofil.
Medium	Medelhög minnesprofil.
Tiny	Liten minnesprofil.

BrokerProperties

Objekt

Egenskaper för broker-resurs

Name	Typ	Standardvärde	Description
advanced	AdvancedSettings		Avancerade inställningar för Broker.
cardinality	Cardinality		Kardinalitetsinformationen för asynkron meddelandekö.
diagnostics	BrokerDiagnostics		Specifikationen definierar önskade identiteter för diagnostikinställningar för Broker.
diskBackedMessageBuffer	DiskBackedMessageBuffer		Inställningar för diskstödd meddelandebuffert.
generateResourceLimits	GenerateResourceLimits		Den här inställningen styr om Kubernetes CPU-resursgränser begärs. Om du ökar antalet repliker eller arbetare proportionellt ökar mängden begärda CPU-resurser. Om den här inställningen är aktiverad och det inte finns tillräckligt med CPU-resurser genereras ett fel.
memoryProfile	BrokerMemoryProfile	Medium	Minnesprofil för Broker.
provisioningState	ProvisioningState		Status för den senaste åtgärden.

BrokerResource

Objekt

Instans broker-resurs

Name	Typ	Description
extendedLocation	ExtendedLocation	Resursens gränsplats.
id	string (arm-id)	Fullständigt kvalificerat resurs-ID för resursen. Till exempel "/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}"
name	string	Namnet på resursen
properties	BrokerProperties	Resursspecifika egenskaper för den här resursen.
systemData	systemData	Azure Resource Manager-metadata som innehåller createdBy och modifiedBy information.
type	string	Resurstypen. Till exempel "Microsoft.Compute/virtualMachines" eller "Microsoft.Storage/storageAccounts"

Cardinality

Objekt

Kardinalitetsegenskaper

Name	Typ	Description
backendChain	BackendChain	Önskade egenskaper för serverdelshanteraren
frontend	Frontend	Önskade egenskaper för klientdelen

CertManagerCertOptions

Objekt

Cert Manager-certifikategenskaper

Name	Typ	Description
duration	string	Certifikatets livslängd. Måste anges med en Go-tid. Varaktighetsformat (h|m|s). T.ex. 240h i 240 timmar och 45m i 45 minuter.
privateKey	CertManagerPrivateKey	Konfiguration av certifikatets privata nyckel.
renewBefore	string	När du ska börja förnya certifikatet. Måste anges med en Go-tid. Varaktighetsformat (h|m|s). T.ex. 240h i 240 timmar och 45m i 45 minuter.

CertManagerPrivateKey

Objekt

Egenskaper för privat nyckel i Cert Manager

Name	Typ	Description
algorithm	PrivateKeyAlgorithm	algoritm för privat nyckel.
rotationPolicy	PrivateKeyRotationPolicy	cert-manager private key rotationPolicy.

ClientConfig

Objekt

Inställningarna för Klientkonfiguration.

Name	Typ	Description
maxKeepAliveSeconds	integer (int32) minimum: 0 maximum: 65535	Övre gräns för en klients Keep Alive på några sekunder.
maxMessageExpirySeconds	integer (int32) minimum: 1 maximum: 4294967295	Övre gräns för meddelande förfallointervall i sekunder.
maxPacketSizeBytes	integer (int32) minimum: 1 maximum: 268435456	Maximal meddelandestorlek för ett paket i Bytes.
maxReceiveMaximum	integer (int32) minimum: 1 maximum: 65535	Övre gräns för Ta emot maximalt som en klient kan begära i CONNECT-paketet.
maxSessionExpirySeconds	integer (int32) minimum: 1 maximum: 4294967295	Övre gräns för sessionens förfallointervall i sekunder.
subscriberQueueLimit	SubscriberQueueLimit	Gränsen för antalet köade meddelanden för en prenumerant.

createdByType

Uppräkning

Den typ av identitet som skapade resursen.

Värde	Description
Application
Key
ManagedIdentity
User

DiagnosticsLogs

Objekt

Egenskaper för diagnostiklogg

Name	Typ	Standardvärde	Description
level	string	info	Loggnivån. Exempel – "felsökning", "info", "warn", "error", "trace".

DiskBackedMessageBuffer

Objekt

DiskBackedMessageBuffer-egenskaper

Name	Typ	Description
ephemeralVolumeClaimSpec	VolumeClaimSpec	Använd den angivna mallen för beständiga volymanspråk för att montera en "allmän tillfällig volym" för meddelandebufferten. Mer information finns i https://kubernetes.io/docs/concepts/storage/ephemeral-volumes/#generic-ephemeral-volumes.
maxSize	string pattern: ^[0-9]+[KMGTPE]$	Den maximala storleken på meddelandebufferten på disken. Om en PVC-mall anges med hjälp av en av tillfälligaVolumeClaimSpec eller persistentVolumeClaimSpec, används den här storleken som begärande- och gränsstorlekar för mallen. Om varken efemeralVolumeClaimSpec eller persistentVolumeClaimSpec anges monteras en emptyDir-volym med den här storleken som gräns. Mer information finns i https://kubernetes.io/docs/concepts/storage/volumes/#emptydir.
persistentVolumeClaimSpec	VolumeClaimSpec	Använd den angivna mallen för beständiga volymanspråk för att montera en beständig volym för meddelandebufferten.

ErrorAdditionalInfo

Objekt

Ytterligare information om resurshanteringsfelet.

Name	Typ	Description
info	object	Ytterligare information.
type	string	Ytterligare informationstyp.

ErrorDetail

Objekt

Felinformationen.

Name	Typ	Description
additionalInfo	ErrorAdditionalInfo[]	Ytterligare information om felet.
code	string	Felkoden.
details	ErrorDetail[]	Felinformationen.
message	string	Felmeddelandet.
target	string	Felmålet.

ErrorResponse

Objekt

Felsvar

Name	Typ	Description
error	ErrorDetail	Felobjektet.

ExtendedLocation

Objekt

Utökad plats är ett tillägg av Azure-platser. De tillhandahåller ett sätt att använda sina Azure ARC-aktiverade Kubernetes-kluster som målplatser för distribution av Azure-tjänstinstanser.

Name	Typ	Description
name	string	Namnet på den utökade platsen.
type	ExtendedLocationType	Typ av ExtendedLocation.

ExtendedLocationType

Uppräkning

Den uppräkningsdefinieringstyp för ExtendedLocation som accepteras.

Värde	Description
CustomLocation	CustomLocation-typ

Frontend

Objekt

De önskade egenskaperna för klientdelsinstanserna i Broker

Name	Typ	Standardvärde	Description
replicas	integer (int32) minimum: 1 maximum: 16		Önskat antal klientdelsinstanser (poddar).
workers	integer (int32) minimum: 1 maximum: 16	2	Antal logiska klientdelsarbetare per instans (podd).

GenerateResourceLimits

Objekt

Egenskaper för GenerateResourceLimits

Name	Typ	Standardvärde	Description
cpu	OperationalMode	Enabled	Växlingsknappen för att aktivera/inaktivera cpu-resursgränser.

KubernetesReference

Objekt

Kubernetes-referens

Name	Typ	Description
apiGroup	string	APIGroup är gruppen för den resurs som refereras till. Om APIGroup inte har angetts måste den angivna typen finnas i kärn-API-gruppen. För andra typer av tredje part krävs APIGroup.
kind	string	Typ är den typ av resurs som refereras till
name	string	Namn är namnet på resursen som refereras
namespace	string	Namnområdet är namnområdet för resursen som refereras till. Det här fältet krävs när resursen har ett namnområde.

LocalKubernetesReference

Objekt

Kubernetes-referens

Name	Typ	Description
apiGroup	string	APIGroup är gruppen för den resurs som refereras till. Om APIGroup inte har angetts måste den angivna typen finnas i kärn-API-gruppen. För andra typer av tredje part krävs APIGroup.
kind	string	Typ är den typ av resurs som refereras till
name	string	Namn är namnet på resursen som refereras

Metrics

Objekt

Egenskaper för diagnostikmått

Name	Typ	Standardvärde	Description
prometheusPort	integer (int32) minimum: 0 maximum: 65535	9600	Prometheus-porten för att exponera måtten.

OperationalMode

Uppräkning

Lägesegenskaper

Värde	Description
Disabled	Inaktiverad motsvarar False.
Enabled	Aktiverad motsvarar True

OperatorValues

Uppräkning

Giltiga operatorer är In, NotIn, Exists och DoesNotExist.

Värde	Description
DoesNotExist	DoesNotExist-operator.
Exists	Finns operator.
In	I operator.
NotIn	NotIn-operator.

PrivateKeyAlgorithm

Uppräkning

Algoritmtyper för privata nycklar.

Värde	Description
Ec256	Algoritm – ec256.
Ec384	Algoritm – ec384.
Ec521	Algoritm – ec521.
Ed25519	Algoritm – ed25519.
Rsa2048	Algoritm – rsa2048.
Rsa4096	Algoritm – rsa4096.
Rsa8192	Algoritm – rsa8192.

PrivateKeyRotationPolicy

Uppräkning

Roteringsprincip för privat nyckel.

Värde	Description
Always	Rotationsprincip – Alltid.
Never	Rotationsprincip – Aldrig.

ProvisioningState

Uppräkning

Uppräkningen som definierar status för resursen.

Värde	Description
Accepted	Resursen har accepterats.
Canceled	Resursskapandet avbröts.
Deleting	Resursen tas bort.
Failed	Det gick inte att skapa resurser.
Provisioning	Resursen etableras.
Succeeded	Resursen har skapats.
Updating	Resursen uppdateras.

SelfCheck

Objekt

Egenskaper för broker Diagnostic Self check

Name	Typ	Standardvärde	Description
intervalSeconds	integer (int32) minimum: 30 maximum: 300	30	Självkontrollintervallet.
mode	OperationalMode	Enabled	Växlingsknappen för att aktivera/inaktivera självkontroll.
timeoutSeconds	integer (int32) minimum: 5 maximum: 120	15	Tidsgränsen för självkontroll.

SelfTracing

Objekt

Egenskaper för självspårning av diagnostik

Name	Typ	Standardvärde	Description
intervalSeconds	integer (int32) minimum: 1 maximum: 300	30	Självspårningsintervallet.
mode	OperationalMode	Enabled	Växlingsknappen för att aktivera/inaktivera självspårning.

SubscriberMessageDropStrategy

Uppräkning

Uppräkningen definierar strategier för att ta bort meddelanden från prenumerantkön.

Värde	Description
DropOldest	Det äldsta meddelandet tas bort.
None	Meddelanden tas aldrig bort.

SubscriberQueueLimit

Objekt

Inställningarna för kögräns för prenumeranter.

Name	Typ	Standardvärde	Description
length	integer (int64) minimum: 1		Den maximala längden på kön innan meddelanden börjar tas bort.
strategy	SubscriberMessageDropStrategy	None	Den strategi som ska användas för att ta bort meddelanden från kön.

systemData

Objekt

Metadata som rör skapande och senaste ändring av resursen.

Name	Typ	Description
createdAt	string (date-time)	Tidsstämpeln för resursskapande (UTC).
createdBy	string	Identiteten som skapade resursen.
createdByType	createdByType	Den typ av identitet som skapade resursen.
lastModifiedAt	string (date-time)	Tidsstämpeln för resursens senaste ändring (UTC)
lastModifiedBy	string	Identiteten som senast ändrade resursen.
lastModifiedByType	createdByType	Den typ av identitet som senast ändrade resursen.

Traces

Objekt

Egenskaper för asynkron diagnostikspårning

Name	Typ	Standardvärde	Description
cacheSizeMegabytes	integer (int32) minimum: 1 maximum: 128	16	Cachestorleken i megabyte.
mode	OperationalMode	Enabled	Växlingsknappen för att aktivera/inaktivera spårningar.
selfTracing	SelfTracing		Egenskaperna för självspårning.
spanChannelCapacity	integer (int32) minimum: 1000 maximum: 100000	1000	Span-kanalkapaciteten.

VolumeClaimResourceRequirements

Objekt

VolumeClaimResourceRequirements-egenskaper

Name	Typ	Description
limits	object	Gränser beskriver den maximala mängden beräkningsresurser som tillåts. Mer information: https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/
requests	object	Begäranden beskriver den minsta mängd beräkningsresurser som krävs. Om begäranden utelämnas för en container är det standardvärdet Gränser om det uttryckligen anges, i annat fall till ett implementeringsdefinierat värde. Mer information: https://kubernetes.io/docs/concepts/configuration/manage-resources-containers/

VolumeClaimSpec

Objekt

VolumeClaimSpec-egenskaper

Name	Typ	Description
accessModes	string[]	AccessModes innehåller önskade åtkomstlägen som volymen ska ha. Mer information: https://kubernetes.io/docs/concepts/storage/persistent-volumes#access-modes-1
dataSource	LocalKubernetesReference	Det här fältet kan användas för att ange antingen: * Ett befintligt VolumeSnapshot-objekt (snapshot.storage.k8s.io/VolumeSnapshot) * En befintlig PVC (PersistentVolumeClaim) Om etableraren eller en extern kontrollant kan stödja den angivna datakällan skapas en ny volym baserat på innehållet i den angivna datakällan. Om funktionsporten AnyVolumeDataSource är aktiverad har det här fältet alltid samma innehåll som fältet DataSourceRef.
dataSourceRef	KubernetesReference	Anger det objekt som volymen ska fyllas från med data, om en volym som inte är tom önskas. Detta kan vara ett lokalt objekt från en icke-tom API-grupp (icke-kärnobjekt) eller ett PersistentVolumeClaim-objekt. När det här fältet har angetts lyckas volymbindningen endast om typen av det angivna objektet matchar någon installerad volymfyllare eller dynamisk provisioner. Det här fältet ersätter funktionerna i fältet DataSource och om båda fälten inte är tomma måste de ha samma värde. För bakåtkompatibilitet ställs båda fälten (DataSource och DataSourceRef) in på samma värde automatiskt om en av dem är tom och den andra inte är tom. Det finns två viktiga skillnader mellan DataSource och DataSourceRef: * DataSource tillåter endast två specifika typer av objekt, men DataSourceRef tillåter alla objekt som inte är kärnobjekt, samt PersistentVolumeClaim-objekt. * DataSource ignorerar otillåtna värden (släpper dem), men DataSourceRef bevarar alla värden och genererar ett fel om ett otillåtet värde har angetts. (Beta) Om du använder det här fältet måste funktionsporten AnyVolumeDataSource vara aktiverad.
resources	VolumeClaimResourceRequirements	Resurser representerar de minsta resurser som volymen ska ha. Om funktionen RecoverVolumeExpansionFailure är aktiverad kan användarna ange resurskrav som är lägre än tidigare värde men som fortfarande måste vara högre än kapaciteten som registrerats i statusfältet för anspråket. Mer information: https://kubernetes.io/docs/concepts/storage/persistent-volumes#resources
selector	VolumeClaimSpecSelector	En etikettfråga över volymer att överväga för bindning.
storageClassName	string	Namnet på lagringsklassen som krävs av anspråket. Mer information: https://kubernetes.io/docs/concepts/storage/persistent-volumes#class-1
volumeMode	string	volumeMode definierar vilken typ av volym som krävs av anspråket. Filsystemets värde är underförstått när det inte ingår i anspråksspecifikationen. Det här är en betafunktion.
volumeName	string	VolumeName är bindningsreferensen till PersistentVolume som stöder det här anspråket.

VolumeClaimSpecSelector

Objekt

Egenskaper för VolumeClaimSpecSelector

Name	Typ	Description
matchExpressions	VolumeClaimSpecSelectorMatchExpressions[]	MatchExpressions är en lista över krav för etikettväljare. Kraven är ANDed.
matchLabels	object	MatchLabels är en karta över {key,value}-par. En enda {nyckel,värde} i matchLabels-kartan motsvarar ett element av matchExpressions, vars nyckelfält är "key", operatorn är "In" och värdematrisen innehåller endast "värde". Kraven är ANDed.

VolumeClaimSpecSelectorMatchExpressions

Objekt

VolumeClaimSpecSelectorMatchExpressions-egenskaper

Name	Typ	Description
key	string	nyckel är den etikettnyckel som väljaren gäller för.
operator	OperatorValues	operatorn representerar en nyckels relation till en uppsättning värden. Giltiga operatorer är In, NotIn, Exists och DoesNotExist.
values	string[]	värden är en matris med strängvärden. Om operatorn är I eller NotIn måste värdematrisen vara tom. Om operatorn är Finns eller DoesNotExist måste värdematrisen vara tom. Den här matrisen ersätts under en strategisk sammanslagningskorrigering.