Azure İşlevleri için Azure Kuyruk depolama tetikleyicisi

Makale
03/10/2024

Kuyruk depolama tetikleyicisi, iletiler Azure Kuyruk depolama alanına eklendikçe bir işlev çalıştırır.

Tüketim ve Premium planları için Azure Kuyruk depolama ölçeklendirme kararları hedef tabanlı ölçeklendirme yoluyla yapılır. Daha fazla bilgi için bkz . Hedef tabanlı ölçeklendirme.

Önemli

Bu makalede, Node.js programlama modelinin birden çok sürümünü desteklemek için sekmeler kullanılır. Genel kullanıma sunulan v4 modeli, JavaScript ve TypeScript geliştiricileri için daha esnek ve sezgisel bir deneyime sahip olacak şekilde tasarlanmıştır. v4 modelinin nasıl çalıştığı hakkında daha fazla bilgi için Azure İşlevleri Node.js geliştirici kılavuzuna bakın. v3 ile v4 arasındaki farklar hakkında daha fazla bilgi edinmek için geçiş kılavuzuna bakın.

Azure İşlevleri, Python için iki programlama modelini destekler. Bağlamalarınızı tanımlama şekliniz seçtiğiniz programlama modeline bağlıdır.

Python v2 programlama modeli, doğrudan Python işlev kodunuzda dekoratörleri kullanarak bağlamaları tanımlamanıza olanak tanır. Daha fazla bilgi için bkz . Python geliştirici kılavuzu.

Bu makale her iki programlama modelini de destekler.

Örnek

Kuyrukta yeni bir öğe alındığında işlev başlatmak için kuyruk tetikleyicisini kullanın. Kuyruk iletisi işleve giriş olarak sağlanır.

C# işlevi aşağıdaki C# modlarından biri kullanılarak oluşturulabilir:

Yalıtılmış çalışan modeli: Çalışma zamanından yalıtılmış bir çalışan işleminde çalışan derlenmiş C# işlevi. LTS ve .NET ve .NET Framework dışındaki sürümlerde çalışan C# işlevlerini desteklemek için yalıtılmış çalışan işlemi gereklidir. Yalıtılmış çalışan işlemi işlevleri için uzantılar ad alanlarını kullanır Microsoft.Azure.Functions.Worker.Extensions.* .
İşlem içi model: İşlevler çalışma zamanıyla aynı işlemde çalışan derlenmiş C# işlevi. Bu modelin bir varyasyonunda, İşlevler öncelikle C# portalı düzenleme için desteklenen C# betiği kullanılarak çalıştırılabilir. İşlem içi işlevlerin uzantıları ad alanlarını kullanır Microsoft.Azure.WebJobs.Extensions.* .

Önemli

İşlem içi model desteği 10 Kasım 2026'da sona erecektir. Tam destek için uygulamalarınızı yalıtılmış çalışan modeline geçirmenizi kesinlikle öneririz.

Yalıtılmış çalışan modeli
İşlem içi model

Aşağıdaki örnekte kuyruğu yoklayan input-queue ve bir kuyruk öğesi her işlendiğinde çıkış kuyruğuna birkaç ileti yazan bir C# işlevi gösterilmektedir.

[Function(nameof(QueueFunction))]
[QueueOutput("output-queue")]
public string[] Run([QueueTrigger("input-queue")] Album myQueueItem, FunctionContext context)
{
    // Use a string array to return more than one message.
    string[] messages = {
        $"Album name = {myQueueItem.Name}",
        $"Album songs = {myQueueItem.Songs.ToString()}"};

    _logger.LogInformation("{msg1},{msg2}", messages[0], messages[1]);

    // Queue Output messages
    return messages;
}

Aşağıdaki örnekte kuyruğu yoklayan myqueue-items ve bir kuyruk öğesi her işlendiğinde günlük yazan bir C# işlevi gösterilmektedir.

public static class QueueFunctions
{
    [FunctionName("QueueTrigger")]
    public static void QueueTrigger(
        [QueueTrigger("myqueue-items")] string myQueueItem, 
        ILogger log)
    {
        log.LogInformation($"C# function processed: {myQueueItem}");
    }
}

Aşağıdaki Java örneği, kuyruğa yerleştirilen tetiklenen iletiyi günlüğe kaydeden bir depolama kuyruğu myqueuenametetikleyici işlevini gösterir.

@FunctionName("queueprocessor")
public void run(
    @QueueTrigger(name = "msg",
                queueName = "myqueuename",
                connection = "myconnvarname") String message,
    final ExecutionContext context
) {
    context.getLogger().info(message);
}

Model v4
Model v3

Aşağıdaki örnekte bir kuyruk tetikleyicisi TypeScript işlevi gösterilmektedir. İşlev kuyruğu yoklar myqueue-items ve bir kuyruk öğesi her işlendiğinde bir günlük yazar.

import { app, InvocationContext } from '@azure/functions';

export async function storageQueueTrigger1(queueItem: unknown, context: InvocationContext): Promise<void> {
    context.log('Storage queue function processed work item:', queueItem);
    context.log('expirationTime =', context.triggerMetadata.expirationTime);
    context.log('insertionTime =', context.triggerMetadata.insertionTime);
    context.log('nextVisibleTime =', context.triggerMetadata.nextVisibleTime);
    context.log('id =', context.triggerMetadata.id);
    context.log('popReceipt =', context.triggerMetadata.popReceipt);
    context.log('dequeueCount =', context.triggerMetadata.dequeueCount);
}

app.storageQueue('storageQueueTrigger1', {
    queueName: 'myqueue-items',
    connection: 'MyStorageConnectionAppSetting',
    handler: storageQueueTrigger1,
});

Kullanım bölümünde açıklanmaktadırqueueItem. İleti meta verileri bölümü , gösterilen diğer tüm değişkenleri açıklar.

Model v4
Model v3

Aşağıdaki örnekte kuyruk tetikleyicisi JavaScript işlevi gösterilmektedir. İşlev kuyruğu yoklar myqueue-items ve bir kuyruk öğesi her işlendiğinde bir günlük yazar.

const { app } = require('@azure/functions');

app.storageQueue('storageQueueTrigger1', {
    queueName: 'myqueue-items',
    connection: 'MyStorageConnectionAppSetting',
    handler: (queueItem, context) => {
        context.log('Storage queue function processed work item:', queueItem);
        context.log('expirationTime =', context.triggerMetadata.expirationTime);
        context.log('insertionTime =', context.triggerMetadata.insertionTime);
        context.log('nextVisibleTime =', context.triggerMetadata.nextVisibleTime);
        context.log('id =', context.triggerMetadata.id);
        context.log('popReceipt =', context.triggerMetadata.popReceipt);
        context.log('dequeueCount =', context.triggerMetadata.dequeueCount);
    },
});

Kullanım bölümünde açıklanmaktadırqueueItem. İleti meta verileri bölümü , gösterilen diğer tüm değişkenleri açıklar.

Aşağıdaki örnekte, function.json dosyasındaki bir kuyruk tetikleyicisi bağlaması ve bağlamayı kullanan bir JavaScript işlevi gösterilmektedir. İşlev kuyruğu yoklar myqueue-items ve bir kuyruk öğesi her işlendiğinde bir günlük yazar.

İşte function.json dosyası:

{
    "disabled": false,
    "bindings": [
        {
            "type": "queueTrigger",
            "direction": "in",
            "name": "myQueueItem",
            "queueName": "myqueue-items",
            "connection":"MyStorageConnectionAppSetting"
        }
    ]
}

Yapılandırma bölümünde bu özellikler açıklanır.

Not

ad parametresi, kuyruk öğesi yükünü içeren JavaScript kodunda olduğu gibi context.bindings.<name> yansıtılmıştır. Bu yük işlevine ikinci parametre olarak da geçirilir.

JavaScript kodu şu şekildedir:

module.exports = async function (context, message) {
    context.log('Node.js queue trigger function processed work item', message);
    // OR access using context.bindings.<name>
    // context.log('Node.js queue trigger function processed work item', context.bindings.myQueueItem);
    context.log('expirationTime =', context.bindingData.expirationTime);
    context.log('insertionTime =', context.bindingData.insertionTime);
    context.log('nextVisibleTime =', context.bindingData.nextVisibleTime);
    context.log('id =', context.bindingData.id);
    context.log('popReceipt =', context.bindingData.popReceipt);
    context.log('dequeueCount =', context.bindingData.dequeueCount);
};

Kullanım bölümünde, function.json özelliği tarafından name adlandırılan açıklanmaktadırmyQueueItem. İleti meta verileri bölümü , gösterilen diğer tüm değişkenleri açıklar.

Aşağıdaki örnekte, bir işleve tetikleyici aracılığıyla iletilen bir kuyruk iletisinin nasıl okunduğu gösterilmektedir.

Depolama kuyruğu tetikleyicisi, olarak ayarlandığı type queueTriggerfunction.json dosyasında tanımlanır.

{
  "bindings": [
    {
      "name": "QueueItem",
      "type": "queueTrigger",
      "direction": "in",
      "queueName": "messages",
      "connection": "MyStorageConnectionAppSetting"
    }
  ]
}

Run.ps1 dosyasındaki kod, işlevinizdeki kuyruk iletisini okumanızı sağlayan parametresini olarak $QueueItembildirir.

# Input bindings are passed in via param block.
param([string] $QueueItem, $TriggerMetadata)

# Write out the queue message and metadata to the information log.
Write-Host "PowerShell queue trigger function processed work item: $QueueItem"
Write-Host "Queue item expiration time: $($TriggerMetadata.ExpirationTime)"
Write-Host "Queue item insertion time: $($TriggerMetadata.InsertionTime)"
Write-Host "Queue item next visible time: $($TriggerMetadata.NextVisibleTime)"
Write-Host "ID: $($TriggerMetadata.Id)"
Write-Host "Pop receipt: $($TriggerMetadata.PopReceipt)"
Write-Host "Dequeue count: $($TriggerMetadata.DequeueCount)"

Aşağıdaki örnekte, bir işleve tetikleyici aracılığıyla iletilen bir kuyruk iletisinin nasıl okunduğu gösterilmektedir. Örnek, v1 veya v2 Python programlama modelini kullanıp kullanmadığınıza bağlıdır.

import logging
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="QueueFunc")
@app.queue_trigger(arg_name="msg", queue_name="inputqueue",
                   connection="storageAccountConnectionString")  # Queue trigger
@app.queue_output(arg_name="outputQueueItem", queue_name="outqueue",
                 connection="storageAccountConnectionString")  # Queue output binding
def test_function(msg: func.QueueMessage,
                  outputQueueItem: func.Out[str]) -> None:
    logging.info('Python queue trigger function processed a queue item: %s',
                 msg.get_body().decode('utf-8'))
    outputQueueItem.set('hello')

Depolama kuyruğu tetikleyicisi, türün olarak ayarlandığı queueTriggerfunction.json tanımlanır.

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "msg",
      "type": "queueTrigger",
      "direction": "in",
      "queueName": "messages",
      "connection": "AzureStorageQueuesConnectionString"
    }
  ]
}

kod _init_.py işlevinizdeki kuyruk iletisini okumanızı sağlayan parametresini olarak func.QueueMessagebildirir.

import logging
import json

import azure.functions as func

def main(msg: func.QueueMessage):
    logging.info('Python queue trigger function processed a queue item.')

    result = json.dumps({
        'id': msg.id,
        'body': msg.get_body().decode('utf-8'),
        'expiration_time': (msg.expiration_time.isoformat()
                            if msg.expiration_time else None),
        'insertion_time': (msg.insertion_time.isoformat()
                           if msg.insertion_time else None),
        'time_next_visible': (msg.time_next_visible.isoformat()
                              if msg.time_next_visible else None),
        'pop_receipt': msg.pop_receipt,
        'dequeue_count': msg.dequeue_count
    })

    logging.info(result)

Özellikler

hem işlem içi hem de yalıtılmış çalışan işlemi C# kitaplıkları, işlevi tanımlamak için QueueTriggerAttribute kullanır. Bunun yerine C# betiği, C# betik kılavuzunda açıklandığı gibi bir function.json yapılandırma dosyası kullanır.

Yalıtılmış çalışan modeli
İşlem içi model

Aşağıdaki örnekte gösterildiği gibi, C# sınıf kitaplıklarında özniteliğin oluşturucusunun izlemesi gereken kuyruğun adını alır:

[Function(nameof(QueueFunction))]
[QueueOutput("output-queue")]
public string[] Run([QueueTrigger("input-queue")] Album myQueueItem, FunctionContext context)

Bu örnekte, özniteliğin kendisinde bağlantı dizesi ayarının ayarlanması da gösterilmektedir.

Aşağıdaki örnekte gösterildiği gibi, C# sınıf kitaplıklarında özniteliğin oluşturucusunun izlemesi gereken kuyruğun adını alır:

[FunctionName("QueueTrigger")]
public static void Run(
    [QueueTrigger("myqueue-items")] string myQueueItem, 
    ILogger log)
{
    ...
}

Özelliğini, aşağıdaki örnekte gösterildiği gibi kullanılacak depolama hesabı bağlantı dizesi içeren uygulama ayarını belirtecek şekilde ayarlayabilirsinizConnection:

[FunctionName("QueueTrigger")]
public static void Run(
    [QueueTrigger("myqueue-items", Connection = "StorageConnectionAppSetting")] string myQueueItem, 
    ILogger log)
{
    ....
}

Ek Açıklamalar

Ek QueueTrigger açıklama işlevi tetikleyen kuyruğa erişmenizi sağlar. Aşağıdaki örnek, kuyruk iletisini parametresi aracılığıyla message işlev için kullanılabilir hale getirir.

package com.function;
import com.microsoft.azure.functions.annotation.*;
import java.util.Queue;
import com.microsoft.azure.functions.*;

public class QueueTriggerDemo {
    @FunctionName("QueueTriggerDemo")
    public void run(
        @QueueTrigger(name = "message", queueName = "messages", connection = "MyStorageConnectionAppSetting") String message,
        final ExecutionContext context
    ) {
        context.getLogger().info("Queue message: " + message);
    }
}

Özellik	Açıklama
`name`	İşlev imzasında parametre adını bildirir. İşlev tetiklendiğinde, bu parametrenin değeri kuyruk iletisinin içeriğine sahiptir.
`queueName`	Depolama hesabında kuyruk adını bildirir.
`connection`	Depolama hesabı bağlantı dizesi gösterir.

Dekoratörler

Yalnızca Python v2 programlama modeli için geçerlidir.

Dekoratörler kullanılarak tanımlanan Python v2 işlevleri için, dekoratördeki queue_trigger aşağıdaki özellikler Kuyruk Depolama tetikleyicisini tanımlar:

Özellik	Açıklama
`arg_name`	İşlev imzasında parametre adını bildirir. İşlev tetiklendiğinde, bu parametrenin değeri kuyruk iletisinin içeriğine sahiptir.
`queue_name`	Depolama hesabında kuyruk adını bildirir.
`connection`	Depolama hesabı bağlantı dizesi gösterir.

function.json kullanılarak tanımlanan Python işlevleri için Yapılandırma bölümüne bakın.

Yapılandırma

Yalnızca Python v1 programlama modeli için geçerlidir.

Model v4
Model v3

Aşağıdaki tabloda, yöntemine geçirilen app.storageQueue() nesnede options ayarlayabileceğiniz özellikler açıklanmaktadır.

Özellik	Açıklama
queueName	Yoklama kuyruğunun adı.
bağlantı	Azure Kuyruklarına nasıl bağlanıldığını belirten bir uygulama ayarının veya ayar koleksiyonunun adı. Bkz. Bağlantılar.

Aşağıdaki tabloda, function.json dosyasında ayarladığınız bağlama yapılandırma özellikleri açıklanmaktadır.

Özellik	Açıklama
type	olarak ayarlanmalıdır `queueTrigger`. Bu özellik, Tetikleyiciyi Azure portalında oluşturduğunuzda otomatik olarak ayarlanır.
direction	Yalnızca function.json dosyasında. olarak ayarlanmalıdır `in`. Bu özellik, Tetikleyiciyi Azure portalında oluşturduğunuzda otomatik olarak ayarlanır.
ad	İşlev kodundaki kuyruk öğesi yükünü içeren değişkenin adı.
queueName	Yoklama kuyruğunun adı.
bağlantı	Azure Kuyruklarına nasıl bağlanıldığını belirten bir uygulama ayarının veya ayar koleksiyonunun adı. Bkz. Bağlantılar.

Aşağıdaki tabloda, function.json dosyasında ve QueueTrigger özniteliğinde ayarladığınız bağlama yapılandırma özellikleri açıklanmaktadır.

function.json özelliği	Açıklama
type	olarak ayarlanmalıdır `queueTrigger`. Bu özellik, Tetikleyiciyi Azure portalında oluşturduğunuzda otomatik olarak ayarlanır.
direction	Yalnızca function.json dosyasında. olarak ayarlanmalıdır `in`. Bu özellik, Tetikleyiciyi Azure portalında oluşturduğunuzda otomatik olarak ayarlanır.
ad	İşlev kodundaki kuyruk öğesi yükünü içeren değişkenin adı.
queueName	Yoklama kuyruğunun adı.
bağlantı	Azure Kuyruklarına nasıl bağlanıldığını belirten bir uygulama ayarının veya ayar koleksiyonunun adı. Bkz. Bağlantılar.

Tam örnekler için Örnek bölümüne bakın.

Yerel olarak geliştirme yaparken uygulama ayarlarınızı koleksiyondaki local.settings.json dosyasına Values ekleyin.

Kullanım

Not

İşlevler base64 kodlanmış bir dize bekler. Kodlama türündeki tüm ayarlamaların (verileri base64 kodlanmış dize olarak hazırlamak için) çağrı hizmetinde uygulanması gerekir.

Kuyruk tetikleyicisinin kullanımı uzantı paketi sürümüne ve işlev uygulamanızda kullanılan C# modalitesine bağlıdır ve bu modlardan biri olabilir:

Yalıtılmış çalışan modeli
İşlem içi sınıf kitaplığı

Yalıtılmış çalışan işlem sınıfı kitaplığı derlenmiş C# işlevi çalışma zamanından yalıtılmış bir işlemde çalışır.

Modun ve sürümün kullanım ayrıntılarını görmek için bir sürüm seçin.

gibi string paramNamebir yöntem parametresi kullanarak ileti verilerine erişin. paramName, QueueTriggerAttribute içinde belirtilen değerdir. Aşağıdaki türlerden herhangi birine bağlanabilirsiniz:

Düz eski .NET CLR nesnesi (POCO)
string
byte[]
QueueMessage

Bir nesneye bağlanırken, İşlevler çalışma zamanı JSON yükünü kodunuzda tanımlanan rastgele bir sınıfın örneğine seri durumdan çıkarmaya çalışır. QueueMessage kullanan örnekler için uzantının GitHub deposuna bakın.

Özniteliği bir Connection özellik alırken depolama hesabı bağlantısı belirtmek için StorageAccountAttribute'u da kullanabilirsiniz. Kitaplıktaki diğer işlevlerden farklı bir depolama hesabı kullanmanız gerektiğinde bunu yapabilirsiniz. Oluşturucu, depolama bağlantı dizesi içeren bir uygulama ayarının adını alır. Özniteliği parametre, yöntem veya sınıf düzeyinde uygulanabilir. Aşağıdaki örnekte sınıf düzeyi ve yöntem düzeyi gösterilmektedir:

[StorageAccount("ClassLevelStorageAppSetting")]
public static class AzureFunctions
{
    [FunctionName("StorageTrigger")]
    [StorageAccount("FunctionLevelStorageAppSetting")]
    public static void Run( //...
{
    ...
}

Kullanılacak depolama hesabı aşağıdaki sırayla belirlenir:

Tetikleyici veya bağlama özniteliğinin Connection özelliği.
Tetikleyici StorageAccount veya bağlama özniteliğiyle aynı parametreye uygulanan öznitelik.
StorageAccount İşleve uygulanan öznitelik.
StorageAccount sınıfına uygulanan öznitelik.
uygulama ayarında AzureWebJobsStorage tanımlanan işlev uygulaması için varsayılan depolama hesabı.

Düz eski CLR nesnesi (POCO)
string
byte[]
CloudQueueMessage

Bir nesneye bağlanırken, İşlevler çalışma zamanı JSON yükünü kodunuzda tanımlanan rastgele bir sınıfın örneğine seri durumdan çıkarmaya çalışır. CloudQueueMessage'a bağlanmaya çalışır ve bir hata iletisi alırsanız, doğru Depolama SDK'sı sürümüne başvuru aldığınızdan emin olun.

[StorageAccount("ClassLevelStorageAppSetting")]
public static class AzureFunctions
{
    [FunctionName("StorageTrigger")]
    [StorageAccount("FunctionLevelStorageAppSetting")]
    public static void Run( //...
{
    ...
}

Kullanılacak depolama hesabı aşağıdaki sırayla belirlenir:

Tetikleyici veya bağlama özniteliğinin Connection özelliği.
Tetikleyici StorageAccount veya bağlama özniteliğiyle aynı parametreye uygulanan öznitelik.
StorageAccount İşleve uygulanan öznitelik.
StorageAccount sınıfına uygulanan öznitelik.
uygulama ayarında AzureWebJobsStorage tanımlanan işlev uygulaması için varsayılan depolama hesabı.

Kuyruk tetikleyicisi aşağıdaki türlere bağlanabilir:

Type	Açıklama
`string`	dize olarak ileti içeriği. İleti basit bir metin olduğunda kullan...
`byte[]`	İletinin baytları.
JSON serileştirilebilir türler	Bir kuyruk iletisi JSON verileri içerdiğinde İşlevler, JSON verilerinin seri durumdan çıkarılarak düz eski bir CLR nesnesi (POCO) türüne dönüştürülmeye çalışılır.
QueueMessage¹	İleti.
BinaryData¹	İletinin baytları.

¹ Bu türleri kullanmak için Microsoft.Azure.Functions.Worker.Extensions.Storage.Queues 5.2.0 veya sonraki sürümlerine ve SDK türü bağlamaları için ortak bağımlılıklara başvurmanız gerekir.

QueueTrigger ek açıklaması, işlevi tetikleyen kuyruk iletisine erişmenizi sağlar.

Model v4
Model v3

İşlevinizin ilk bağımsız değişkeni olarak kuyruk öğesine erişin. Yük JSON ise, değer bir nesnede seri durumdan çıkarılır.

function.json dosyasında bağlamanın name parametresi tarafından belirlenen adla eşleşen dize parametresi aracılığıyla kuyruk iletisine erişin.

QueueMessage olarak yazılan parametre aracılığıyla kuyruk iletisine erişin.

Meta veri

Kuyruk tetikleyicisi çeşitli meta veri özellikleri sağlar. Bu özellikler, diğer bağlamalardaki bağlama ifadelerinin bir parçası olarak veya ileti meta verilerine bu erişimi sağlayan dil çalışanları için kodunuzda parametreler olarak kullanılabilir.

İleti meta veri özellikleri CloudQueueMessage sınıfının üyeleridir.

İleti meta veri özelliklerine uygulamasından context.triggerMetadataerişilebilir.

İleti meta veri özelliklerine geçirilen $TriggerMetadata parametreden erişilebilir.

Özellik	Türü	Açıklama
`QueueTrigger`	`string`	Kuyruk yükü (geçerli bir dizeyse). Kuyruk iletisi yükü bir dizeyse, `QueueTrigger` function.json özelliği tarafından adlandırılan değişkenle `name` aynı değere sahiptir.
`DequeueCount`	`long`	Bu iletinin kaç kez sıralandığı.
`ExpirationTime`	`DateTimeOffset`	İletinin süresinin dolma zamanı.
`Id`	`string`	Kuyruk iletisi kimliği.
`InsertionTime`	`DateTimeOffset`	İletinin kuyruğa eklendiği saat.
`NextVisibleTime`	`DateTimeOffset`	İletinin bir sonraki görünür olacağı saat.
`PopReceipt`	`string`	İletinin açılır makbuzu.

Aşağıdaki ileti meta veri özelliklerine geçirilen bağlama parametresinden (msg önceki örneklerde) erişilebilir.

Özellik	Açıklama
`body`	Dize olarak kuyruk yükü.
`dequeue_count`	Bu iletinin kaç kez sıralandığı.
`expiration_time`	İletinin süresinin dolma zamanı.
`id`	Kuyruk iletisi kimliği.
`insertion_time`	İletinin kuyruğa eklendiği saat.
`time_next_visible`	İletinin bir sonraki görünür olacağı saat.
`pop_receipt`	İletinin açılır makbuzu.

Bağlantılar

connection özelliği, uygulamanın Azure Kuyruklarına nasıl bağlanması gerektiğini belirten bir ortam yapılandırması başvurusudur. Şunları belirtebilir:

bağlantı dizesi içeren bir uygulama ayarının adı
Birden çok uygulama ayarı için paylaşılan ön ekin adı ve birlikte kimlik tabanlı bağlantı tanımlama.

Yapılandırılan değer hem tek bir ayar için tam eşleşme hem de diğer ayarlar için bir ön ek eşleşmesiyse, tam eşleşme kullanılır.

Connection string

bağlantı dizesi almak için Depolama hesabı erişim anahtarlarını yönetme bölümünde gösterilen adımları izleyin.

Bu bağlantı dizesi, bağlama yapılandırmasının özelliği tarafından connection belirtilen değerle eşleşen bir adla bir uygulama ayarında depolanmalıdır.

Uygulama ayarı adı "AzureWebJobs" ile başlıyorsa, adın yalnızca kalanını burada belirtebilirsiniz. Örneğin, "MyStorage" olarak ayarlarsanızconnection, İşlevler çalışma zamanı "AzureWebJobsMyStorage" adlı bir uygulama ayarı arar. Boş bırakırsanızconnection, İşlevler çalışma zamanı adlı AzureWebJobsStorageuygulama ayarında varsayılan Depolama bağlantı dizesi kullanır.

Kimlik tabanlı bağlantılar

Uzantının 5.x veya üzeri bir sürümünü (non-.NET dil yığınları için paket 3.x veya üzeri) kullanıyorsanız, gizli dizi içeren bir bağlantı dizesi kullanmak yerine uygulamanın bir Microsoft Entra kimliği kullanmasını sağlayabilirsiniz. Kimlik kullanmak için, tetikleyici ve bağlama yapılandırmasındaki özelliğiyle connection eşleyen ortak bir ön ek altında ayarları tanımlarsınız.

"AzureWebJobsStorage" olarak ayarlanıyorsanız connection bkz . Kimlikle konak depolamaya bağlanma. Diğer tüm bağlantılar için uzantı aşağıdaki özellikleri gerektirir:

Özellik	Ortam değişkeni şablonu	Açıklama	Örnek değer
Kuyruk Hizmeti URI'si	`<CONNECTION_NAME_PREFIX>__queueServiceUri`¹	HTTPS şemasını kullanarak bağlandığınız kuyruk hizmetinin veri düzlemi URI'si.	<https:// storage_account_name.queue.core.windows.net>

¹ <CONNECTION_NAME_PREFIX>__serviceUri diğer ad olarak kullanılabilir. Her iki form da sağlanırsa, queueServiceUri form kullanılır. Genel serviceUri bağlantı yapılandırması bloblar, kuyruklar ve/veya tablolar arasında kullanılacaksa form kullanılamaz.

Bağlantıyı özelleştirmek için diğer özellikler ayarlanabilir. Bkz. Kimlik tabanlı bağlantılar için ortak özellikler.

Azure İşlevleri hizmetinde barındırıldığında, kimlik tabanlı bağlantılar yönetilen kimlik kullanır. Ve özellikleriyle credential clientID kullanıcı tarafından atanan bir kimlik belirtilse de, sistem tarafından atanan kimlik varsayılan olarak kullanılır. Kullanıcı tarafından atanan kimliği kaynak kimliğiyle yapılandırmanın desteklenmediğini unutmayın. Yerel geliştirme gibi diğer bağlamlarda çalıştırıldığında, bunun yerine geliştirici kimliğiniz kullanılır, ancak bu özelleştirilebilir. Bkz. Kimlik tabanlı bağlantılarla yerel geliştirme.

Kimliğe izin verme

Hangi kimlik kullanılıyorsa, hedeflenen eylemleri gerçekleştirmek için izinlere sahip olmalıdır. Çoğu Azure hizmeti için bu, bu izinleri sağlayan yerleşik veya özel rolleri kullanarak Azure RBAC'de bir rol atamanız gerektiği anlamına gelir.

Önemli

Bazı izinler, tüm bağlamlar için gerekli olmayan hedef hizmet tarafından gösterilebilir. Mümkün olduğunda, kimliğe yalnızca gerekli ayrıcalıkları sağlayarak en az ayrıcalık ilkesine uyun. Örneğin, uygulamanın yalnızca bir veri kaynağından okuyabilmesi gerekiyorsa, yalnızca okuma izni olan bir rol kullanın. Okuma işlemi için aşırı izin olduğundan, bu hizmete yazmaya da izin veren bir rol atamak uygun olmaz. Benzer şekilde, rol atamasının kapsamının yalnızca okunması gereken kaynaklara göre ayarlandığından emin olmak istersiniz.

Çalışma zamanında kuyruğunuza erişim sağlayan bir rol ataması oluşturmanız gerekir. Sahip gibi yönetim rolleri yeterli değildir. Aşağıdaki tabloda, Normal işlemde Kuyruk Depolama uzantısı kullanılırken önerilen yerleşik roller gösterilmektedir. Uygulamanız, yazdığınız koda göre ek izinler gerektirebilir.

Bağlama türü	Örnek yerleşik roller
Tetikleyici	Depolama Kuyruğu Veri Okuyucusu, Depolama Kuyruğu Veri İleti İşlemcisi
Çıkış bağlaması	Depolama Kuyruğu Veri Katkıda Bulunanı, Depolama Kuyruğu Veri İletisi Göndereni

Zehirli iletiler

Kuyruk tetikleyicisi işlevi başarısız olduğunda, Azure İşlevleri ilk deneme dahil olmak üzere belirli bir kuyruk iletisi için işlevi en fazla beş kez yeniden dener. Beş denemenin tümü başarısız olursa, işlev çalışma zamanı originalqueuename-poison> adlı <kuyruğa bir ileti ekler. Zehirli kuyruktan gelen iletileri günlüğe kaydederek veya el ile dikkat gerektiğini belirten bir bildirim göndererek işlemek için bir işlev yazabilirsiniz.

Zehirli iletileri el ile işlemek için kuyruk iletisinin dequeueCount sayısını denetleyin.

Göz atma kilidi

Peek-lock düzeni, depolama hizmeti tarafından sağlanan görünürlük mekaniği kullanılarak kuyruk tetikleyicileri için otomatik olarak gerçekleşir. İletiler tetiklenen işlev tarafından sıralandığında görünmez olarak işaretlenir. Kuyrukla tetiklenen bir işlevin yürütülmesi, kuyruktaki iletide şu sonuçlardan birine sahip olabilir:

İşlev yürütmesi başarıyla tamamlanır ve ileti kuyruktan silinir.
İşlev yürütme başarısız olur ve İşlevler ana bilgisayarı, host.json dosyasındaki ayara visibilityTimeout göre iletinin görünürlüğünü güncelleştirir. Varsayılan görünürlük zaman aşımı sıfırdır; bu da iletinin yeniden işlem için kuyrukta hemen yeniden görüntülendiği anlamına gelir. visibilityTimeout İşlemesi başarısız olan iletilerin yeniden işlenmesini geciktirmek için ayarını kullanın. Bu zaman aşımı ayarı, işlev uygulamasındaki kuyruk tarafından tetiklenen tüm işlevler için geçerlidir.
İşlevler ana bilgisayarı işlev yürütme sırasında kilitleniyor. Bu yaygın olmayan olay gerçekleştiğinde, konak işlenen iletiye öğesini visibilityTimeout uygulayamaz. Bunun yerine, ileti depolama hizmeti tarafından ayarlanan varsayılan 10 dakikalık zaman aşımı ile bırakılır. 10 dakika sonra ileti yeniden işlenmesi için kuyrukta yeniden görünür. Bu hizmet tanımlı varsayılan zaman aşımı değiştirilemez.

Yoklama algoritması

Kuyruk tetikleyicisi, boşta kuyruk yoklamasının depolama işlemi maliyetleri üzerindeki etkisini azaltmak için rastgele bir üstel geri alma algoritması uygular.

Algoritma aşağıdaki mantığı kullanır:

bir ileti bulunduğunda, çalışma zamanı 100 milisaniye bekler ve sonra başka bir iletiyi denetler.
İleti bulunamadığında, yeniden denemeden önce yaklaşık 200 milisaniye bekler.
Sonraki başarısız kuyruk iletisi alma girişimlerinin ardından bekleme süresi, varsayılan olarak bir dakika olan en uzun bekleme süresine ulaşana kadar artmaya devam eder.
En uzun bekleme süresi, host.json dosyasındaki özelliği aracılığıyla maxPollingInterval yapılandırılabilir.

Yerel geliştirme sırasında maksimum yoklama aralığı varsayılan olarak iki saniyedir.

Not

Tüketim planında işlev uygulamalarını barındırırken faturalamayla ilgili olarak, çalışma zamanı tarafından yoklama için harcanan süre için ücret alınmaz.

Eşzamanlılık

Bekleyen birden çok kuyruk iletisi olduğunda, kuyruk tetikleyicisi bir toplu ileti alır ve bunları işlemek için işlev örneklerini eşzamanlı olarak çağırır. Varsayılan olarak, toplu iş boyutu 16'dır. İşlenen sayı 8'e indiğinde çalışma zamanı başka bir toplu iş alır ve bu iletileri işlemeye başlar. Bu nedenle, bir sanal makinede (VM) işlev başına işlenen en fazla eşzamanlı ileti sayısı 24'tür. Bu sınır, her VM'de kuyrukla tetiklenen her işlev için ayrı ayrı uygulanır. İşlev uygulamanızın ölçeği birden çok VM'ye genişletilirse, her VM tetikleyicileri bekler ve işlevleri çalıştırmayı dener. Örneğin, bir işlev uygulamasının ölçeği 3 VM'ye genişletilirse, kuyrukla tetiklenen bir işlevin varsayılan eşzamanlı örnek sayısı üst sınırı 72'dir.

Toplu iş boyutu ve yeni bir toplu iş alma eşiği host.json dosyasında yapılandırılabilir. Bir işlev uygulamasında kuyrukla tetiklenen işlevler için paralel yürütmeyi en aza indirmek istiyorsanız, toplu iş boyutunu 1 olarak ayarlayabilirsiniz. Bu ayar, işlev uygulamanız tek bir sanal makinede (VM) çalıştığı sürece eşzamanlılığı ortadan kaldırır.

Kuyruk tetikleyicisi, bir işlevin bir kuyruk iletisini aynı anda birden çok kez işlemesini otomatik olarak engeller.

host.json özellikleri

host.json dosyası, kuyruk tetikleyici davranışını denetleen ayarlar içerir. Kullanılabilir ayarlarla ilgili ayrıntılar için host.json ayarları bölümüne bakın.

Sonraki adımlar

Kuyruk depolama iletileri yazma (Çıkış bağlaması)

Aracılığıyla paylaş

Azure İşlevleri için Azure Kuyruk depolama tetikleyicisi

Örnek

Özellikler

Ek Açıklamalar

Dekoratörler

Yapılandırma

Kullanım

Meta veri

Bağlantılar

Connection string

Kimlik tabanlı bağlantılar

Kimliğe izin verme

Zehirli iletiler

Göz atma kilidi

Yoklama algoritması

Eşzamanlılık

host.json özellikleri

Sonraki adımlar

Geri Bildirim

Ek kaynaklar