Hedef tabanlı ölçeklendirme

host.json aşağıdaki örnekte olduğu gibi ayarını maxConcurrentCallsdeğiştirin:

{
    "version": "2.0",
    "extensions": {
        "serviceBus": {
            "maxConcurrentCalls": 16
        }
    }
}

host.json aşağıdaki örnekte olduğu gibi içindeki ayarını maxConcurrentCalls messageHandlerOptionsdeğiştirin:

{
    "version": "2.0",
    "extensions": {
        "serviceBus": {
            "messageHandlerOptions": {
                "maxConcurrentCalls": 16
            }
        }
    }
}

Aşağıdaki örnekte olduğu host.json gibi, örnek başına hedef yürütmeleri ayarlamak için ayarı maxConcurrentSessions değiştirin:

{
    "version": "2.0",
    "extensions": {
        "serviceBus": {
            "maxConcurrentSessions": 8
        }
    }
}

host.json aşağıdaki örnekte olduğu gibi, içindeki ayarını maxConcurrentSessions sessionHandlerOptions örnek başına hedef yürütmeleri ayarlamak için değiştirin:

{
    "version": "2.0",
    "extensions": {
        "serviceBus": {
            "sessionHandlerOptions": {
                "maxConcurrentSessions": 2000
            }
        }
    }
}

Aşağıdaki örnekte olduğu host.json gibi, örnek başına hedef yürütmeleri ayarlamak için ayarı maxMessageBatchSize değiştirin:

{
    "version": "2.0",
    "extensions": {
        "serviceBus": {
            "maxMessageBatchSize": 1000
        }
    }
}

host.json aşağıdaki örnekte olduğu gibi, içindeki ayarını maxMessageCount batchOptions örnek başına hedef yürütmeleri ayarlamak için değiştirin:

{
    "version": "2.0",
    "extensions": {
        "serviceBus": {
            "batchOptions": {
                "maxMessageCount": 1000
            }
        }
    }
}

Aşağıdaki örnekte olduğu host.json gibi, örnek başına hedef yürütmeleri ayarlamak için ayarı maxEventBatchSize değiştirin:

{
    "version": "2.0",
    "extensions": {
        "eventHubs": {
            "maxEventBatchSize" : 100
        }
    }
}

içinde host.jsontargetUnprocessedEventThreshold tanımlandığında, aşağıdaki örnekte olduğu gibi örneği yerine her örnek için maxEventBatchSizehedef yürütme olarak kullanılır:

{
    "version": "2.0",
    "extensions": {
        "eventHubs": {
            "targetUnprocessedEventThreshold": 153
        }
    }
}

Event Hubs uzantısının v3.x+ için altındaki host.json ayarı maxBatchSize eventProcessorOptions değiştirerek örnek başına hedef yürütmeleri ayarlayın:

{
    "version": "2.0",
    "extensions": {
        "eventHubs": {
            "eventProcessorOptions": {
                "maxBatchSize": 10
            }
        }
    }
}

içinde host.jsontargetUnprocessedEventThreshold tanımlandığında, aşağıdaki örnekte olduğu gibi örneği yerine her örnek için maxBatchSizehedef yürütme olarak kullanılır:

{
    "version": "2.0",
    "extensions": {
        "eventHubs": {
            "targetUnprocessedEventThreshold": 23
        }
    }
}

Derlenmiş bir C# işlevi için, işlem içi C# işlevi için aşağıdaki örneklerde gösterildiği gibi tetikleyici tanımınızda ayarlayın MaxItemsPerInvocation :

namespace CosmosDBSamplesV2
{
    public static class CosmosTrigger
    {
        [FunctionName("CosmosTrigger")]
        public static void Run([CosmosDBTrigger(
            databaseName: "ToDoItems",
            collectionName: "Items",
            MaxItemsPerInvocation: 100,
            ConnectionStringSetting = "CosmosDBConnection",
            LeaseCollectionName = "leases",
            CreateLeaseCollectionIfNotExists = true)]IReadOnlyList<Document> documents,
            ILogger log)
        {
            if (documents != null && documents.Count > 0)
            {
                log.LogInformation($"Documents modified: {documents.Count}");
                log.LogInformation($"First document Id: {documents[0].Id}");
            }
        }
    }
}

Java örneği bekliyor.

kullanan function.jsonMaxItemsPerInvocation İşlev dilleri için parametresi, bu Azure Cosmos DB tetikleyici örneğinde olduğu gibi belirli bağlamada tanımlanır:

{
    "scriptFile": "main.py",
    "bindings": [
        {
          "type": "cosmosDBTrigger",
          "maxItemsPerInvocation": 100,
          "connection": "MyCosmosDb",
          "leaseContainerName": "leases",
          "containerName": "collectionName",
          "databaseName": "databaseName",
          "leaseDatabaseName": "databaseName",
          "createLeaseContainerIfNotExists": false,
          "startFromBeginning": false,
          "name": "input"
        }
    ]
}

Python v2 programlama modeline yönelik örnekler henüz kullanılamıyor.

kullanan function.jsonMaxItemsPerInvocation İşlev dilleri için parametresi, bu Azure Cosmos DB tetikleyici örneğinde olduğu gibi belirli bağlamada tanımlanır:

{
  "bindings": [
    {
      "type": "cosmosDBTrigger",
      "maxItemsPerInvocation": 100,
      "connection": "MyCosmosDb",
      "leaseContainerName": "leases",
      "containerName": "collectionName",
      "databaseName": "databaseName",
      "leaseDatabaseName": "databaseName",
      "createLeaseContainerIfNotExists": false,
      "startFromBeginning": false,
      "name": "input"
    }
  ]
}

Node.js v4 programlama modeline yönelik örnekler henüz sağlanmamıştır.

Kafka Event Hubs tetikleyicisi için işlem içi C# işlevine yönelik aşağıdaki örneklerde gösterildiği gibi, derlenmiş bir C# işlevi için tetikleyici tanımınızda ayarlayın LagThreshold :

[FunctionName("KafkaTrigger")]
public static void Run(
    [KafkaTrigger("BrokerList",
                  "topic",
                  Username = "$ConnectionString",
                  Password = "%EventHubConnectionString%",
                  Protocol = BrokerProtocol.SaslSsl,
                  AuthenticationMode = BrokerAuthenticationMode.Plain,
                  ConsumerGroup = "$Default",
                  LagThreshold = 100)] KafkaEventData<string> kevent, ILogger log)
{            
    log.LogInformation($"C# Kafka trigger function processed a message: {kevent.Value}");
}

public class KafkaTriggerMany {
    @FunctionName("KafkaTriggerMany")
    public void runMany(
            @KafkaTrigger(
                name = "kafkaTriggerMany",
                topic = "topic",  
                brokerList="%BrokerList%",
                consumerGroup="$Default", 
                username = "$ConnectionString", 
                password = "EventHubConnectionString",
                authenticationMode = BrokerAuthenticationMode.PLAIN,
                protocol = BrokerProtocol.SASLSSL,
                LagThreshold = 100,
                // sslCaLocation = "confluent_cloud_cacert.pem", // Enable this line for windows.
                cardinality = Cardinality.MANY,
                dataType = "string"
             ) String[] kafkaEvents,
            final ExecutionContext context) {
            for (String kevent: kafkaEvents) {
                context.getLogger().info(kevent);
            }

kullanan function.jsonLagThreshold İşlev dilleri için parametresi, bu Kafka Event Hubs tetikleyici örneğinde olduğu gibi belirli bağlamada tanımlanır:

{
      "scriptFile": "main.py",
      "bindings": [
        {
          "type": "kafkaTrigger",
          "name": "kevent",
          "topic": "topic",
          "brokerList": "%BrokerList%",
          "username": "$ConnectionString",
          "password": "EventHubConnectionString",
          "consumerGroup" : "functions",
          "protocol": "saslSsl",
          "authenticationMode": "plain",
          "lagThreshold": "100"
        }
    ]
}

Python v2 programlama modeli şu anda Kafka uzantısı tarafından desteklenmiyor.

kullanan function.jsonLagThreshold İşlev dilleri için parametresi, bu Kafka Event Hubs tetikleyici örneğinde olduğu gibi belirli bağlamada tanımlanır:

{
    "bindings": [
      {
            "type": "kafkaTrigger",
            "name": "kafkaEvent",
            "direction": "in",
            "protocol" : "SASLSSL",
            "password" : "EventHubConnectionString",
            "dataType" : "string",
            "topic" : "topic",
            "authenticationMode" : "PLAIN",
            "consumerGroup" : "$Default",
            "username" : "$ConnectionString",
            "brokerList" : "%BrokerList%",
            "sslCaLocation": "confluent_cloud_cacert.pem",
            "lagThreshold": "100"
        }
    ]
}

Node.js v4 programlama modeli şu anda Kafka uzantısı tarafından desteklenmiyor.