Enlaces de salida de Azure Tables para Azure Functions

La clase MyTableData siguiente representa una fila de datos en la tabla:

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

La función siguiente, que se inicia mediante un desencadenador de Queue Storage, escribe una nueva entidad MyDataTable en una tabla denominada 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}"
    };
}

En el ejemplo siguiente se muestra una función de C# que usa un desencadenador HTTP para escribir una única fila de la tabla.

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

Los ejemplos de TypeScript no están documentados para el 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 };
    },
});

Este es el archivo function.json:

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

En la sección de configuración se explican estas propiedades.

Este es el código de 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
        });
    }
};

En las bibliotecas de clases de C#, la clase TableInputAttribute admite las siguientes propiedades:

En las bibliotecas de clases de C#, la clase TableAttribute admite las siguientes propiedades:

El constructor del atributo toma el nombre de la tabla. Use el atributo en un parámetro out o en el valor devuelto de la función, como se muestra en el ejemplo siguiente:

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

Puede establecer la propiedad Connection para especificar una conexión al servicio de tablas, tal como se muestra en el ejemplo siguiente:

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

Aunque el atributo toma una propiedad Connection, también puede usar el atributo Connection para especificar una conexión de cuenta de almacenamiento. Puede hacerlo cuando necesite usar una cuenta de almacenamiento diferente a otras funciones de la biblioteca. El constructor toma el nombre de una configuración de aplicación que contiene una cadena de conexión de almacenamiento. El atributo se puede aplicar en el nivel de clase, método o parámetro. En el ejemplo siguiente se muestran el nivel de clase y de método:

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

La cuenta de almacenamiento que se debe usar se determina en el orden siguiente:

• La propiedad Connection del atributo de enlace o desencadenador.
• El atributo StorageAccount aplicado al mismo parámetro que el atributo de enlace o desencadenador.
• El atributo StorageAccount aplicado a la función.
• El atributo StorageAccount aplicado a la clase.
• La cuenta de almacenamiento predeterminada de la aplicación de funciones, que se define en la configuración de la aplicación AzureWebJobsStorage.

En la tabla siguiente se explican las propiedades que puede establecer en el objeto options que se pasa al métodooutput.table().

En la siguiente tabla se explican las propiedades de configuración de enlace que se establecen en el archivo function.json.

Una función de C# compilada de la biblioteca de clases de procesos de trabajo aislados se ejecuta en un proceso aislado del entorno de ejecución.

Un biblioteca de clases en proceso es una función de C# compilada que se ejecuta en el mismo proceso que Functions Runtime.

Los tipos que se incluyen a continuación son compatibles con los parámetros out y los tipos de valores devueltos:

• Un objeto CRL estándar (POCO) que incluye las propiedades PartitionKey y RowKey. Puede acompañar a estas propiedades mediante la implementación de ITableEntity.
• ICollector<T> o IAsyncCollector<T>, donde T incluye las propiedades PartitionKey y RowKey. Puede acompañar a estas propiedades mediante la implementación de ITableEntity.

También puede enlazar desde TableClient el SDK de Azure. A continuación, puede usar ese objeto para escribir en la tabla.

Los tipos que se incluyen a continuación son compatibles con los parámetros out y los tipos de valores devueltos:

• Un objeto CRL estándar (POCO) que incluye las propiedades PartitionKey y RowKey. Puede acompañar a estas propiedades mediante la implementación de ITableEntity o la herencia de TableEntity.
• ICollector<T> o IAsyncCollector<T>, donde T incluye las propiedades PartitionKey y RowKey. Puede acompañar a estas propiedades mediante la implementación de ITableEntity o la herencia de TableEntity.

También puede enlazar desde CloudTable el SDK de Storage como parámetro de método. A continuación, puede usar ese objeto para escribir en la tabla.

Los tipos que se incluyen a continuación son compatibles con los parámetros out y los tipos de valores devueltos:

• Un objeto CRL estándar (POCO) que incluye las propiedades PartitionKey y RowKey. Puede acompañar a estas propiedades mediante la implementación de ITableEntity o la herencia de TableEntity.
• ICollector<T> o IAsyncCollector<T>, donde T incluye las propiedades PartitionKey y RowKey. Puede acompañar a estas propiedades mediante la implementación de ITableEntity o la herencia de TableEntity.

También puede enlazar desde CloudTable el SDK de Storage como parámetro de método. A continuación, puede usar ese objeto para escribir en la tabla.

Cuando quiera que la función escriba en una sola entidad, el enlace de salida de Azure Tables puede enlazarse a los siguientes tipos:

Cuando quiera que la función escriba en múltiples entidades, el enlace de salida de Azure Tables puede enlazarse a los siguientes tipos:

Para otros escenarios de salida, cree y use tableClient con otros tipos de Azure.Data.Tables directamente. Consulte Registro de clientes de Azure para obtener un ejemplo de uso de la inserción de dependencias para crear un tipo de cliente a partir del SDK de Azure.

Se devuelve un objeto CRL estándar (POCO) con propiedades que se pueden asignar a la entidad de tabla.

La versión 1.x de Functions no admite el proceso de trabajo aislado.

Acceda a los datos de la fila de salida devolviendo el valor o utilizando context.extraOutputs.set().

Acceda al evento de salida mediante context.bindings.<name>, donde <name> es el valor especificado en la propiedad name de function.json.