Триггер хранилища очередей Azure для Функций Azure

Триггер хранилища очередей запускает функцию при добавлении сообщений в хранилище очередей Azure.

Решения по масштабированию хранилища очередей Azure для планов потребления и уровня "Премиум" выполняются с помощью масштабирования на основе целевого объекта. Дополнительные сведения см. в статье о масштабировании на основе целевого объекта.

Внимание

В этой статье используются вкладки для поддержки нескольких версий модели программирования Node.js. Модель версии 4 общедоступна и предназначена для более гибкого и интуитивно понятного интерфейса для разработчиков JavaScript и TypeScript. Дополнительные сведения о том, как работает модель версии 4, см. в руководстве разработчика по Функции Azure Node.js. Дополнительные сведения о различиях между версиями 3 и 4 см. в руководстве по миграции.

Функции Azure поддерживает две модели программирования для Python. Способ определения привязок зависит от выбранной модели программирования.

версия 2

Модель программирования Python версии 2 позволяет определять привязки с помощью декораторов непосредственно в коде функции Python. Дополнительные сведения см. в руководстве разработчика Python.

версия 1

Модель программирования Python версии 1 требует определения привязок в отдельном файле function.json в папке функции. Дополнительные сведения см. в руководстве разработчика Python.

Эта статья поддерживает обе модели программирования.

Пример

Поддержка Go для этого привязки сейчас недоступна.

Используйте триггер очереди для запуска функции при получении нового элемента очереди. Сообщение очереди предоставляется в качестве входных данных функции.

Функцию C# можно создать с помощью одного из следующих режимов C#:

• Изолированная рабочая модель: скомпилированная функция C#, которая выполняется в рабочем процессе, изолированном от среды выполнения. Изолированный рабочий процесс необходим для поддержки функций C#, работающих в LTS и не LTS-версиях .NET и платформа .NET Framework. Расширения для изолированных рабочих процессов используют Microsoft.Azure.Functions.Worker.Extensions.* пространства имен.
• Модель внутрипроцессного процесса: скомпилированная функция C#, которая выполняется в том же процессе, что и среда выполнения Функций. В варианте этой модели функции можно запускать с помощью скриптов C#, которая поддерживается главным образом для редактирования портала C#. Расширения для функций в процессе используют Microsoft.Azure.WebJobs.Extensions.* пространства имен.

Внимание

Поддержка будет завершена для модели в процессе 10 ноября 2026 г. Настоятельно рекомендуется перенести приложения в изолированную рабочую модель для полной поддержки.

Изолированная рабочая модель

В следующем примере показана функция C#, которая выполняет опрос очереди input-queue, а затем записывает несколько сообщений в очередь вывода при каждой обработке элемента очереди.

[Function(nameof(QueueInputOutputFunction))]
[QueueOutput("output-queue")]
public string[] QueueInputOutputFunction([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}"};

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

    // Queue Output messages
    return messages;
}

Модель внутрипроцессного процесса

В следующем примере показана функция C#, которая выполняет опрос очереди myqueue-items, а затем делает запись в журнал при каждой обработке элемента очереди.

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

В следующем примере Java показаны триггерные функцию очереди хранилища, которая регистрирует активированное сообщение, помещенное в очередь myqueuename.

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

Модель версии 4

В следующем примере показана функция триггера TypeScript очереди. Эта функция выполняет опрос очереди myqueue-items, а затем делает запись в журнал при каждой обработке элемента очереди.

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,
});

Tip

Чтобы избежать типа по умолчанию unknown для входных данных очереди, используйте параметр универсального типа (например, app.storageQueue<string>(...)). Для этого требуется @azure/functions версия 4.11.0 или более поздняя. Дополнительные сведения см. в разделе "Использование".

В разделе Метаданные сообщений показаны все остальные переменные.

Модель версии 3

Примеры TypeScript не документируются для модели версии 3.

Модель версии 4

В следующем примере показана функция триггера JavaScript очереди. Эта функция выполняет опрос очереди myqueue-items, а затем делает запись в журнал при каждой обработке элемента очереди.

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);
    },
});

В разделе об использовании объясняется queueItem. В разделе Метаданные сообщений показаны все остальные переменные.

Модель версии 3

В следующем примере показана привязка триггера очереди в файле function.json и функция JavaScript, которая использует привязку. Эта функция выполняет опрос очереди myqueue-items, а затем делает запись в журнал при каждой обработке элемента очереди.

Ниже показан файл function.json.

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

В разделе Конфигурация описываются эти свойства.

Примечание.

Параметр name отображается как context.bindings.<name> в коде JavaScript, который содержит полезные данные элемента очереди. Эти полезные данные также передаются в качестве второго параметра в функцию.

Ниже показан код JavaScript.

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);
};

В этом разделе показано свойство myQueueItem, имя которому назначает свойство name в function.json. В разделе Метаданные сообщений показаны все остальные переменные.

В следующем примере показано, как прочитать сообщение очереди, переданное в функцию через триггер.

Триггер очереди хранилища определяется в файле function.json, в котором type настроен на queueTrigger.

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

Код в файле Run.ps1 объявляет параметр как $QueueItem, который позволяет считывать сообщение очереди в функции.

# 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)"

В следующем примере показано, как прочитать сообщение очереди, переданное в функцию через триггер. Пример зависит от того, используется ли модель программирования Python версии 1 или версии 2.

версия 2

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')

версия 1

Триггер очереди хранилища определяется в файле function.js, в котором type настроен на queueTrigger.

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

Код в файле _init_.py объявляет параметр как func.QueueMessage, который позволяет считывать сообщение очереди в функции.

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)

Атрибуты

Библиотеки C# в процессе и изолированном рабочем процессе используют QueueTriggerAttribute для определения функции. Вместо этого скрипт C# использует файл конфигурации function.json, как описано в руководстве по скриптам C#.

Изолированная рабочая модель

В библиотеках классов C# конструктор атрибута принимает имя очереди для отслеживания, как показано в следующем примере:

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

В этом примере также показано задание параметра строки подключения в самом атрибуте.

Модель внутрипроцессного процесса

В библиотеках классов C# конструктор атрибута принимает имя очереди для отслеживания, как показано в следующем примере:

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

Вы можете установить свойство Connection, чтобы указать настройки приложений, содержащие используемую строку подключения учетной записи хранения, как показано в следующем примере:

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

Заметки

Заметка QueueTrigger предоставляет доступ к очереди, которая запускает функцию. В следующем примере сообщение очереди становится доступным для функции через параметр message.

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);
    }
}

Свойство	Description
name	Объявляет имя параметра в сигнатуре функции. При активации функции значение этого параметра будет иметь содержимое сообщения очереди.
queueName	Объявляет имя очереди в учетной записи хранения.
connection	Задает строку подключения к учетной записи хранения.

Декораторы

Применяется только к модели программирования Python версии 2.

Для функций Python версии 2, определенных с помощью декораторов, следующие свойства в декораторе queue_trigger определяют триггер хранилища очередей:

Свойство	Description
arg_name	Объявляет имя параметра в сигнатуре функции. При активации функции значение этого параметра будет иметь содержимое сообщения очереди.
queue_name	Объявляет имя очереди в учетной записи хранения.
connection	Задает строку подключения к учетной записи хранения.

Сведения о функциях Python, определенных с помощью function.json, см. в разделе "Конфигурация".

Настройка

Применяется только к модели программирования Python версии 1.

Модель версии 4

В следующей таблице описываются свойства, которые можно задать для options объекта, переданного методу app.storageQueue() .

Свойство	Description
queueName	Имя очереди для опроса.
Подключение	Имя параметра или коллекции параметров приложения, указывающих, как подключиться к очередям Azure. См. раздел Подключения.

Модель версии 3

В следующей таблице описываются свойства конфигурации привязки, которые задаются в файле function.json.

Свойство	Description
type	Должен иметь значениеqueueTrigger. Это свойство задается автоматически при создании триггера на портале Azure.
direction	Только в файле function.json. Должен иметь значениеin. Это свойство задается автоматически при создании триггера на портале Azure.
name	Имя переменной, содержащей полезные данные элемента очереди в коде функции.
queueName	Имя очереди для опроса.
Подключение	Имя параметра или коллекции параметров приложения, указывающих, как подключиться к очередям Azure. См. раздел Подключения.

В следующей таблице описываются свойства конфигурации привязки, которые задаются в файле function.json и атрибуте QueueTrigger.

Свойство в function.json	Description
type	Должен иметь значениеqueueTrigger. Это свойство задается автоматически при создании триггера на портале Azure.
direction	Только в файле function.json. Должен иметь значениеin. Это свойство задается автоматически при создании триггера на портале Azure.
name	Имя переменной, содержащей полезные данные элемента очереди в коде функции.
queueName	Имя очереди для опроса.
Подключение	Имя параметра или коллекции параметров приложения, указывающих, как подключиться к очередям Azure. См. раздел Подключения.

Подробные примеры см. в разделе Примеры.

Если разработка ведется на локальном компьютере, добавьте параметры приложения в файл local.settings.json в коллекции Values.

Использование

Примечание.

Функции ожидают строку в кодировке base64. Любая корректировка типа кодирования (для подготовки данных в виде строки в кодировке base64) должна быть реализована в вызывающей службе.

Использование триггера очереди зависит от версии пакета расширения и модальности C#, используемой в приложении-функции, которая может быть одним из следующих режимов:

Изолированная рабочая модель

Изолированная библиотека классов рабочих процессов, скомпилированная функция C# выполняется в процессе, изолированном от среды выполнения.

Библиотека внутрипроцессных классов

Библиотека внутрипроцессных классов — это скомпилированная функция C#, которая выполняется в том же процессе, что и среда выполнения Функций.

Выберите версию, чтобы просмотреть сведения об использовании для режима и версии.

Расширение 5.x+

Для доступа к данным сообщения используйте параметр метода, например string paramName. paramName — это значение, указанное в атрибуте QueueTriggerAttribute. Вы можете выполнить привязку к одному из следующих типов:

• Обычный объект .NET CLR (POCO)
• string
• byte[]
• QueueMessage

Во время привязки к объекту среда выполнения службы "Функции" пытается десериализовать полезные данные JSON в экземпляр произвольного класса, определенного в коде. Примеры использования QueueMessage см. в разделе репозитория GitHub для расширения.

Хотя атрибут принимает Connection свойство, можно также использовать StorageAccountAttribute для указания подключения к учетной записи хранения. Это можно сделать, если необходимо использовать учетную запись хранения, отличную от той, что используется другими функциями в библиотеке. Конструктор принимает имя параметра приложения, содержащего строку подключения к службе хранилища. Атрибут может применяться на уровне класса, метода или параметра. Ниже показан пример уровня класса и метода.

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

Используемая учетная запись хранения определяется в следующем порядке:

• Свойство триггера или привязки атрибута Connection.
• Атрибут StorageAccount, примененный к тому же параметру, что и триггер или атрибут привязки.
• Атрибут StorageAccount, примененный к функции.
• Атрибут StorageAccount, примененный к классу.
• Учетная запись хранения по умолчанию для приложения-функции, определенная в параметре приложения AzureWebJobsStorage.

Расширение 2.x+

Для доступа к данным сообщения используйте параметр метода, например string paramName. paramName — это значение, указанное в атрибуте QueueTriggerAttribute. Вы можете выполнить привязку к одному из следующих типов:

• Объект POCO
• string
• byte[]
• CloudQueueMessage

Во время привязки к объекту среда выполнения службы "Функции" пытается десериализовать полезные данные JSON в экземпляр произвольного класса, определенного в коде. Если при попытке привязки к CloudQueueMessage отображается сообщение об ошибке, убедитесь, что указана ссылка на правильную версию пакета SDK для службы хранилища.

Хотя атрибут принимает Connection свойство, можно также использовать StorageAccountAttribute для указания подключения к учетной записи хранения. Это можно сделать, если необходимо использовать учетную запись хранения, отличную от той, что используется другими функциями в библиотеке. Конструктор принимает имя параметра приложения, содержащего строку подключения к службе хранилища. Атрибут может применяться на уровне класса, метода или параметра. Ниже показан пример уровня класса и метода.

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

Используемая учетная запись хранения определяется в следующем порядке:

• Свойство триггера или привязки атрибута Connection.
• Атрибут StorageAccount, примененный к тому же параметру, что и триггер или атрибут привязки.
• Атрибут StorageAccount, примененный к функции.
• Атрибут StorageAccount, примененный к классу.
• Учетная запись хранения по умолчанию для приложения-функции, определенная в параметре приложения AzureWebJobsStorage.

Расширение 5.x+

Триггер очереди может привязаться к следующим типам:

Тип	Description
string	Содержимое сообщения в виде строки. Используется, когда сообщение является простым текстом..
byte[]	Байт сообщения.
Сериализуемые в JSON типы	Если сообщение очереди содержит данные JSON, функции пытаются десериализировать данные JSON в обычный тип объекта CLR (POCO).
QueueMessage1	Сообщение.
BinaryData1	Байт сообщения.

¹ Для использования этих типов необходимо ссылаться на Microsoft.Azure.Functions.Worker.Extensions.Storage.Queues 5.2.0 или более поздней версии , а также общие зависимости для привязок типов ПАКЕТА SDK.

Расширение 2.x+

Более ранние версии этого расширения в изолированном рабочем процессе поддерживают привязку только к строкам. Дополнительные параметры доступны для расширения 5.x+.

Заметка QueueTrigger предоставляет доступ к сообщению очереди, вызвавшему функцию.

Модель версии 4

Доступ к элементу очереди в качестве первого аргумента функции. Если полезные данные представлены в виде JSON, значение десериализируется в объект.

Используйте параметр универсального типа для app.storageQueue<string>(...) ввода входных данных триггера очереди. Без универсального входного параметра по умолчанию используется unknownзначение, для которого требуется явное сужение типа, прежде чем использовать значение. Для поддержки универсального типа требуется @azure/functions версия 4.11.0 или более поздняя.

Модель версии 3

Доступ к элементу очереди с использованием context.bindings.<NAME><NAME> соответствия значению, определенному в function.json. Если полезные данные представлены в виде JSON, значение десериализируется в объект.

Модель версии 4

Доступ к элементу очереди в качестве первого аргумента функции. Если полезные данные представлены в виде JSON, значение десериализируется в объект.

Модель версии 3

Доступ к элементу очереди с использованием context.bindings.<NAME><NAME> соответствия значению, определенному в function.json. Если полезные данные представлены в виде JSON, значение десериализируется в объект.

Получение доступа к сообщению очереди через параметр string, который соответствует имени, назначенному name параметром привязки в файле function.js.

Получение доступа к сообщению очереди с помощью параметра, типизированного как QueueMessage.

Метаданные

Триггер очереди предоставляет несколько свойств метаданных. Эти свойства можно использовать как часть выражений привязки в других привязках или в качестве параметров в коде для языковых работников, которые предоставляют этот доступ к метаданным сообщения.

Свойства метаданных сообщения являются членами класса CloudQueueMessage .

К свойствам метаданных сообщения можно получить доступ.context.triggerMetadata

К свойствам метаданных сообщения можно получить доступ из переданного $TriggerMetadata параметра.

Свойство	Тип	Description
QueueTrigger	string	Полезные данные очереди (если это допустимая строка). Если полезные данные очереди сообщений представлены в виде строки, значение QueueTrigger совпадает со значением переменной, имя которой назначено свойством name в файле function.json.
DequeueCount	long	Количество раз, когда сообщение было выведено из очереди.
ExpirationTime	DateTimeOffset	Время истечения срока действия сообщения.
Id	string	Идентификатор сообщения в очереди.
InsertionTime	DateTimeOffset	Время, когда сообщение было добавлено в очередь.
NextVisibleTime	DateTimeOffset	Время, когда сообщение станет видимым в следующий раз.
PopReceipt	string	Уведомление о получении сообщения.

Следующие свойства метаданных сообщения можно получить из переданного параметра привязки (msg в предыдущих примерах).

Свойство	Description
body	Полезные данные очереди в виде строки.
dequeue_count	Количество раз, когда сообщение было выведено из очереди.
expiration_time	Время истечения срока действия сообщения.
id	Идентификатор сообщения в очереди.
insertion_time	Время, когда сообщение было добавлено в очередь.
time_next_visible	Время, когда сообщение станет видимым в следующий раз.
pop_receipt	Уведомление о получении сообщения.

Связи

Свойство устанавливается на ключ в настройках приложения, который возвращает значение, используемое connection runtime Functions для подключения к аккаунту хранилища, используемому расширением. Значение настройки свойств соединения зависит от типа соединения:

• Управляемое соединение идентичности: свойство connection является <CONNECTION_NAME_PREFIX> общим для группы настроек, которые вместе определяют соединение на основе идентичности с аккаунтом хранения. Для получения дополнительной информации см. раздел «Определить идентичные связи».
• Key Vault reference: connection Настройка свойств возвращает ссылку на Azure Key Vault на место, где централизованно поддерживается строка подключения. Для получения дополнительной информации смотрите раздел Define Key Vault connections.
• App Configuration reference: connection Настройка свойства возвращает ссылку на Конфигурация приложений Azure, которая возвращает строка подключения или ссылку на Key Vault. Для получения дополнительной информации см. Конфигурация приложений Azure в статье о соединениях.
• Connection string: Настройка connection свойств возвращает фактическую строка подключения для учетной записи хранилища. Поскольку строка строка подключения содержит общие секретные ключи, следует рассмотреть возможность использования управляемого идентификатора соединения, если это возможно. Для получения дополнительной информации см. раздел «Определить соединения».

Чтобы узнать больше о соединениях связей, см. раздел «Управление соединением в Функции Azure». Чтобы получить строку подключения, выполните действия, описанные в разделе Управление ключами доступа к учетной записи хранения.

Когда вы устанавливаете connection префикс ключа или ключа с именем AzureWebJobsStorage или пустую строку, расширение связывания использует стандартную учетную запись хранения хоста. Для получения дополнительной информации см. раздел «Оптимизировать производительность хранения».

Сообщения о сбое

При сбое функции триггера очереди по умолчанию служба "Функции Azure" выполняет ее для заданного сообщения очереди еще пять раз (включая первую попытку). В случае сбоя всех пяти попыток среда выполнения функций добавляет сообщение в очередь с именем <имя_первоначальной_очереди>-poison. Можно написать функции для обработки сообщений из очереди подозрительных сообщений путем внесения их в журнал или отправки уведомления о необходимости ручного вмешательства.

Для обработки сообщений о сбоях вручную проверьте значение dequeueCount сообщения очереди.

Блокировка быстрого редактирования

Шаблон отслеживания блокировки выполняется автоматически для триггеров очереди, используя механизм видимости, предоставляемый службой хранилища. Так как сообщения удаляются триггерной функцией, они помечены как невидимые. Выполнение триггерной функции очереди может иметь один из этих результатов в сообщении в очереди:

• Выполнение функции завершается успешно, и сообщение удаляется из очереди.
• Выполнение функции завершается сбоем, и узел Функций обновляет видимость сообщения на visibilityTimeoutоснове параметра в файле host.json. Время ожидания видимости по умолчанию равно нулю, что означает, что сообщение немедленно появится в очереди для повторной обработки. visibilityTimeout Используйте параметр, чтобы отложить повторную обработку сообщений, которые не удалось обработать. Этот параметр времени ожидания применяется ко всем активированным функциям очереди в приложении-функции.
• Узел функций завершает работу во время выполнения функции. При возникновении этого редкого события узел не может применить visibilityTimeout его к обрабатываемого сообщения. Вместо этого сообщение остается с интервалом времени ожидания по умолчанию 10 минут, заданным службой хранилища. Через 10 минут сообщение снова появится в очереди для повторной обработки. Это время ожидания по умолчанию, определенное службой, не может быть изменено.

Алгоритм опроса

В триггере очереди реализован алгоритм случайной экспоненциальной отсрочки, который позволяет уменьшить влияние опроса очереди ожидающих задач на затраты на транзакции хранилища.

В алгоритме заложена следующая логика:

• При обнаружении сообщения среда выполнения ожидает 100 миллисекунд, а затем проверяет наличие другого сообщения.
• Если новое сообщение не обнаружено, примерно через 200 миллисекунд начинается повторный поиск.
• После последующих неудачных попыток получения сообщения очереди время ожидания продолжает увеличиваться, пока не достигнет максимального времени ожидания, по умолчанию — одна минута.
• Максимальное время ожидания настраивается при помощи свойства maxPollingInterval в файле host.json.

Во время локальной разработки максимальный интервал опроса по умолчанию составляет 2 секунды.

Примечание.

Что касается выставления счетов при размещении приложений-функций в плане потребления, с вас не взимается плата за время, потраченное на опрос средой выполнения.

Параллелизм

При наличии нескольких сообщений, ожидающих в очереди, триггер очереди извлекает пакет сообщений и в параллельном режиме вызывает экземпляры функций для обработки. По умолчанию в пакете содержится 16 сообщений. Когда число обрабатываемых сообщений снижается до 8, среда выполнения получает следующий пакет и начинает обработку содержащихся в нем сообщений. Поэтому максимальное количество сообщений, одновременно обрабатываемых каждой функцией на одной виртуальной машине, равно 24. Это ограничение применяется отдельно к каждой функции, активируемой с помощью очереди, на каждой виртуальной машине. Если приложение-функция масштабируется до нескольких виртуальных машин, каждая виртуальная машина ожидает триггеров и пытается запустить функции. Например, если приложение-функция масштабируется на 3 виртуальные машины, то максимальное количество параллельных экземпляров одной функции, активируемой с помощью очереди, равно 72.

Размер пакета и порог для получения нового пакета настраиваются в файле host.json. Если в приложении-функции требуется свести к минимуму параллельное выполнение функций, активируемых с помощью очереди, вы можете задать для размера пакета значение 1. Этот параметр позволяет исключить параллелизм только при условии, что приложение-функция выполняется на одной виртуальной машине.

Триггер очереди автоматически не дает функции одновременно обрабатывать сообщения очереди несколько раз.

Свойства host.json

В файле host.json содержатся параметры, управляющие поведением очереди триггера. Дополнительные сведения о доступных настройках см. в разделе Настройка host.json.

Следующие шаги

• Сообщения хранилища очереди записи (Выходная привязка)