Выходные привязки таблиц Azure для службы "Функции Azure"

Следующий класс MyTableData представляет строку данных в таблице:

public class MyTableData : Azure.Data.Tables.ITableEntity
{
    public string Text { get; set; }

    public string PartitionKey { get; set; }
    public string RowKey { get; set; }
    public DateTimeOffset? Timestamp { get; set; }
    public ETag ETag { get; set; }
}

Следующая функция, которая запускается триггером Хранилища очередей, записывает новую сущность MyDataTable в таблицу с именем OutputTable.

[Function("TableFunction")]
[TableOutput("OutputTable", Connection = "AzureWebJobsStorage")]
public static MyTableData Run(
    [QueueTrigger("table-items")] string input,
    [TableInput("MyTable", "<PartitionKey>", "{queueTrigger}")] MyTableData tableInput,
    FunctionContext context)
{
    var logger = context.GetLogger("TableFunction");

    logger.LogInformation($"PK={tableInput.PartitionKey}, RK={tableInput.RowKey}, Text={tableInput.Text}");

    return new MyTableData()
    {
        PartitionKey = "queue",
        RowKey = Guid.NewGuid().ToString(),
        Text = $"Output record with rowkey {input} created at {DateTime.Now}"
    };
}

В следующем примере показана функция C#, которая использует триггер HTTP для записи одной строки таблицы.

public class TableStorage
{
    public class MyPoco
    {
        public string PartitionKey { get; set; }
        public string RowKey { get; set; }
        public string Text { get; set; }
    }

    [FunctionName("TableOutput")]
    [return: Table("MyTable")]
    public static MyPoco TableOutput([HttpTrigger] dynamic input, ILogger log)
    {
        log.LogInformation($"C# http trigger function processed: {input.Text}");
        return new MyPoco { PartitionKey = "Http", RowKey = Guid.NewGuid().ToString(), Text = input.Text };
    }
}

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

const tableOutput = output.table({
    tableName: 'Person',
    connection: 'MyStorageConnectionAppSetting',
});

interface PersonEntity {
    PartitionKey: string;
    RowKey: string;
    Name: string;
}

export async function httpTrigger1(request: HttpRequest, context: InvocationContext): Promise<HttpResponseInit> {
    const rows: PersonEntity[] = [];
    for (let i = 1; i < 10; i++) {
        rows.push({
            PartitionKey: 'Test',
            RowKey: i.toString(),
            Name: `Name ${i}`,
        });
    }
    context.extraOutputs.set(tableOutput, rows);
    return { status: 201 };
}

app.http('httpTrigger1', {
    methods: ['POST'],
    authLevel: 'anonymous',
    extraOutputs: [tableOutput],
    handler: httpTrigger1,
});

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

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

const tableOutput = output.table({
    tableName: 'Person',
    connection: 'MyStorageConnectionAppSetting',
});

app.http('httpTrigger1', {
    methods: ['POST'],
    authLevel: 'anonymous',
    extraOutputs: [tableOutput],
    handler: async (request, context) => {
        const rows = [];
        for (let i = 1; i < 10; i++) {
            rows.push({
                PartitionKey: 'Test',
                RowKey: i.toString(),
                Name: `Name ${i}`,
            });
        }
        context.extraOutputs.set(tableOutput, rows);
        return { status: 201 };
    },
});

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

{
  "bindings": [
    {
      "name": "input",
      "type": "manualTrigger",
      "direction": "in"
    },
    {
      "tableName": "Person",
      "connection": "MyStorageConnectionAppSetting",
      "name": "tableBinding",
      "type": "table",
      "direction": "out"
    }
  ],
  "disabled": false
}

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

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

module.exports = async function (context) {

    context.bindings.tableBinding = [];

    for (var i = 1; i < 10; i++) {
        context.bindings.tableBinding.push({
            PartitionKey: "Test",
            RowKey: i.toString(),
            Name: "Name " + i
        });
    }
};

В библиотеках классов C# TableInputAttribute поддерживает следующие свойства:

В библиотеках классов C# TableAttribute поддерживает следующие свойства:

Конструктор атрибута использует имя таблицы. Используйте атрибут с параметром out или с возвращаемым значением функции, как показано в следующем примере:

[FunctionName("TableOutput")]
[return: Table("MyTable")]
public static MyPoco TableOutput(
    [HttpTrigger] dynamic input, 
    ILogger log)
{
    ...
}

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

[FunctionName("TableOutput")]
[return: Table("MyTable", Connection = "StorageConnectionAppSetting")]
public static MyPoco TableOutput(
    [HttpTrigger] dynamic input, 
    ILogger log)
{
    ...
}

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

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

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

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

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

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

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

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

Для параметров out и типов возвращаемых значений поддерживаются следующие типы:

• Объект POCO, включающий свойства PartitionKey и RowKey. Чтобы добавить эти свойства, можно реализовать ITableEntity.
• ICollector<T> или IAsyncCollector<T>, где T включает свойства PartitionKey и RowKey. Чтобы добавить эти свойства, можно реализовать ITableEntity.

Вы также можете привязаться к TableClient пакету SDK Для Azure. Затем этот объект можно использовать для записи в таблицу.

Для параметров out и типов возвращаемых значений поддерживаются следующие типы:

• Объект POCO, включающий свойства PartitionKey и RowKey. Чтобы добавить эти свойства, можно реализовать ITableEntity или наследовать TableEntity.
• ICollector<T> или IAsyncCollector<T>, где T включает свойства PartitionKey и RowKey. Чтобы добавить эти свойства, можно реализовать ITableEntity или наследовать TableEntity.

Вы также можете привязаться к CloudTable пакету SDK хранилища в качестве параметра метода. Затем этот объект можно использовать для записи в таблицу.

Для параметров out и типов возвращаемых значений поддерживаются следующие типы:

• Объект POCO, включающий свойства PartitionKey и RowKey. Чтобы добавить эти свойства, можно реализовать ITableEntity или наследовать TableEntity.
• ICollector<T> или IAsyncCollector<T>, где T включает свойства PartitionKey и RowKey. Чтобы добавить эти свойства, можно реализовать ITableEntity или наследовать TableEntity.

Вы также можете привязаться к CloudTable пакету SDK хранилища в качестве параметра метода. Затем этот объект можно использовать для записи в таблицу.

Если требуется, чтобы функция записывала в одну сущность, выходная привязка таблиц Azure может привязаться к следующим типам:

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

Для других сценариев вывода создайте и используйте TableClient с другими типами из Azure.Data.Tables напрямую. Пример использования внедрения зависимостей для создания типа клиента из пакета SDK Azure см. в статье "Регистрация клиентов Azure".

Возвращает объект POCO со свойствами, которые можно сопоставить с сущностью таблицы.

Функции версии 1.x не поддерживают изолированный рабочий процесс.

Задайте выходные данные строки, возвращая значение или используя context.extraOutputs.set()его.

Задайте выходные данные строки с помощью context.bindings.<name> <name> значения, указанного в свойстве name function.json.