Associações de saída de Tabelas do Azure para o Azure Functions

A classe a seguir MyTableData representa uma linha de dados na tabela:

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

A função a seguir, que é iniciada por um gatilho de armazenamento de fila, grava uma nova MyDataTable entidade em uma tabela chamada 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}"
    };
}

O exemplo a seguir mostra uma função C# que usa um gatilho HTTP para gravar uma única linha de tabela.

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

Os exemplos de TypeScript não estão documentados para o modelo v3.

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

Aqui está o arquivo function.json :

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

A seção de configuração explica essas propriedades.

Aqui está o código 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
        });
    }
};

Em bibliotecas de classe C#, o TableInputAttribute suporta as seguintes propriedades:

Em bibliotecas de classe C#, o TableAttribute suporta as seguintes propriedades:

O construtor do atributo usa o nome da tabela. Use o atributo em um out parâmetro ou no valor de retorno da função, conforme mostrado no exemplo a seguir:

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

Você pode definir a Connection propriedade para especificar uma conexão com o serviço de tabela, conforme mostrado no exemplo a seguir:

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

Embora o atributo tenha uma Connection propriedade, você também pode usar StorageAccountAttribute para especificar uma conexão de conta de armazenamento. Você pode fazer isso quando precisar usar uma conta de armazenamento diferente de outras funções na biblioteca. O construtor leva o nome de uma configuração de aplicativo que contém uma cadeia de conexão de armazenamento. O atributo pode ser aplicado no nível de parâmetro, método ou classe. O exemplo a seguir mostra o nível da classe e o nível do método:

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

A conta de armazenamento a ser usada é determinada na seguinte ordem:

• A propriedade do atributo trigger ou de ligação Connection .
• O StorageAccount atributo aplicado ao mesmo parâmetro que o atributo trigger ou de ligação.
• O StorageAccount atributo aplicado à função.
• O StorageAccount atributo aplicado à classe.
• A conta de armazenamento padrão para o aplicativo de função, que é definida na configuração do AzureWebJobsStorage aplicativo.

A tabela a seguir explica as propriedades que você pode definir no options objeto passado para o output.table() método.

A tabela a seguir explica as propriedades de configuração de associação definidas no arquivo function.json .

Uma biblioteca de classes de processo de trabalho isolada compilada função C# é executada em um processo isolado do tempo de execução.

Uma biblioteca de classes em processo é uma função C# compilada executada no mesmo processo que o tempo de execução do Functions.

Os seguintes tipos são suportados para out parâmetros e tipos de retorno:

• Um objeto CLR simples (POCO) que inclui as PartitionKey propriedades e RowKey . Você pode acompanhar essas propriedades implementando ITableEntityo .
• ICollector<T> ou IAsyncCollector<T> onde T inclui o PartitionKey e RowKey propriedades. Você pode acompanhar essas propriedades implementando ITableEntityo .

Você também pode vincular a TableClient partir do SDK do Azure. Em seguida, você pode usar esse objeto para gravar na tabela.

Os seguintes tipos são suportados para out parâmetros e tipos de retorno:

• Um objeto CLR simples (POCO) que inclui as PartitionKey propriedades e RowKey . Você pode acompanhar essas propriedades implementando ITableEntity ou herdando TableEntity.
• ICollector<T> ou IAsyncCollector<T> onde T inclui o PartitionKey e RowKey propriedades. Você pode acompanhar essas propriedades implementando ITableEntity ou herdando TableEntity.

Você também pode vincular a CloudTable partir do SDK de armazenamento como um parâmetro de método. Em seguida, você pode usar esse objeto para gravar na tabela.

Os seguintes tipos são suportados para out parâmetros e tipos de retorno:

• Um objeto CLR simples (POCO) que inclui as PartitionKey propriedades e RowKey . Você pode acompanhar essas propriedades implementando ITableEntity ou herdando TableEntity.
• ICollector<T> ou IAsyncCollector<T> onde T inclui o PartitionKey e RowKey propriedades. Você pode acompanhar essas propriedades implementando ITableEntity ou herdando TableEntity.

Você também pode vincular a CloudTable partir do SDK de armazenamento como um parâmetro de método. Em seguida, você pode usar esse objeto para gravar na tabela.

Quando você deseja que a função grave em uma única entidade, a associação de saída Tabelas do Azure pode se vincular aos seguintes tipos:

Quando você deseja que a função grave em várias entidades, a associação de saída Tabelas do Azure pode se vincular aos seguintes tipos:

Para outros cenários de saída, crie e use um TableClient com outros tipos de Azure.Data.Tables diretamente. Consulte Registrar clientes do Azure para obter um exemplo de como usar a injeção de dependência para criar um tipo de cliente a partir do SDK do Azure.

Retorna um objeto CLR (POCO) simples com propriedades que podem ser mapeadas para a entidade da tabela.

O Functions versão 1.x não suporta o processo de trabalho isolado.

Defina os dados da linha de saída retornando o valor ou usando context.extraOutputs.set().

Defina os dados da linha de saída usando context.bindings.<name> onde é o name valor especificado na propriedade de function.json<name>.