Azure İşlevleri için Azure Tabloları giriş bağlamaları

Tablo veya Azure Tablo Depolama için Azure Cosmos DB'de bir tabloyu okumak için Azure Tabloları giriş bağlamasını kullanın.

Kurulum ve yapılandırma ayrıntıları hakkında bilgi için genel bakışa bakın.

Ö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.

Örnek

Go desteği şu anda bu bağlama için mevcut değil.

Bağlamanın kullanımı uzantı paketi sürümüne ve işlev uygulamanızda kullanılan C# modalitesine bağlıdır ve bu da aşağıdakilerden biri olabilir:

Yalıtılmış çalışan modeli

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.

İşlem içi model

Ö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.

İşlem içi sınıf kitaplığı , İşlevler çalışma zamanıyla aynı işlemde çalıştırılan derlenmiş bir C# işlevidir.

Mod ve sürüm örneklerini görmek için bir sürüm seçin.

Azure Tabloları uzantısı

Aşağıdaki örnekte tek bir tablo satırını okuyan bir C# işlevi gösterilmektedir. Kuyruğa gönderilen her ileti için işlev tetiklenir.

Satır anahtarı değeri {queueTrigger} , satır anahtarını ileti meta verilerine (ileti dizesi) bağlar.

public class TableStorage
{
    public class MyPoco : 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; }
    }


    [FunctionName("TableInput")]
    public static void TableInput(
        [QueueTrigger("table-items")] string input, 
        [Table("MyTable", "MyPartition", "{queueTrigger}")] MyPoco poco, 
        ILogger log)
    {
        log.LogInformation($"PK={poco.PartitionKey}, RK={poco.RowKey}, Text={poco.Text}");
    }
}

Azure SDK'sını kullanarak tabloyu okumak için bir TableClient yöntem parametresi kullanın. Azure İşlevleri günlük tablosunu sorgulayan bir işlev örneği aşağıda verilmişti:

using Microsoft.Azure.WebJobs;
using Microsoft.Extensions.Logging;
using Azure.Data.Tables;
using System;
using System.Threading.Tasks;
using Azure;
namespace FunctionAppCloudTable2
{
    public class LogEntity : ITableEntity
    {
        public string OriginalName { get; set; }

        public string PartitionKey { get; set; }
        public string RowKey { get; set; }
        public DateTimeOffset? Timestamp { get; set; }
        public ETag ETag { get; set; }
    }
    public static class CloudTableDemo
    {
        [FunctionName("CloudTableDemo")]
        public static async Task Run(
            [TimerTrigger("0 */1 * * * *")] TimerInfo myTimer,
            [Table("AzureWebJobsHostLogscommon")] TableClient tableClient,
            ILogger log)
        {
            log.LogInformation($"C# Timer trigger function executed at: {DateTime.Now}");
            AsyncPageable<LogEntity> queryResults = tableClient.QueryAsync<LogEntity>(filter: $"PartitionKey eq 'FD2' and RowKey gt 't'");
            await foreach (LogEntity entity in queryResults)
            {
                log.LogInformation($"{entity.PartitionKey}\t{entity.RowKey}\t{entity.Timestamp}\t{entity.OriginalName}");
            }
        }
    }
}

kullanma hakkında daha fazla bilgi için TableClientbkz . Azure.Data.Tables API Başvurusu.

Birleşik Azure Depolama uzantısı

Aşağıdaki örnekte tek bir tablo satırını okuyan bir C# işlevi gösterilmektedir. Kuyruğa gönderilen her ileti için işlev tetiklenir.

Satır anahtarı değeri {queueTrigger} , satır anahtarını ileti meta verilerine (ileti dizesi) bağlar.

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

    [FunctionName("TableInput")]
    public static void TableInput(
        [QueueTrigger("table-items")] string input, 
        [Table("MyTable", "MyPartition", "{queueTrigger}")] MyPoco poco, 
        ILogger log)
    {
        log.LogInformation($"PK={poco.PartitionKey}, RK={poco.RowKey}, Text={poco.Text}");
    }
}

Azure Depolama SDK'sını kullanarak tabloyu okumak için bir CloudTable yöntem parametresi kullanın. Azure İşlevleri günlük tablosunu sorgulayan bir işlev örneği aşağıda verilmişti:

using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Host;
using Microsoft.Extensions.Logging;
using Microsoft.Azure.Cosmos.Table;
using System;
using System.Threading.Tasks;

namespace FunctionAppCloudTable2
{
    public class LogEntity : TableEntity
    {
        public string OriginalName { get; set; }
    }
    public static class CloudTableDemo
    {
        [FunctionName("CloudTableDemo")]
        public static async Task Run(
            [TimerTrigger("0 */1 * * * *")] TimerInfo myTimer, 
            [Table("AzureWebJobsHostLogscommon")] CloudTable cloudTable,
            ILogger log)
        {
            log.LogInformation($"C# Timer trigger function executed at: {DateTime.Now}");

            TableQuery<LogEntity> rangeQuery = new TableQuery<LogEntity>().Where(
                TableQuery.CombineFilters(
                    TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, 
                        "FD2"),
                    TableOperators.And,
                    TableQuery.GenerateFilterCondition("RowKey", QueryComparisons.GreaterThan, 
                        "t")));

            // Execute the query and loop through the results
            foreach (LogEntity entity in 
                await cloudTable.ExecuteQuerySegmentedAsync(rangeQuery, null))
            {
                log.LogInformation(
                    $"{entity.PartitionKey}\t{entity.RowKey}\t{entity.Timestamp}\t{entity.OriginalName}");
            }
        }
    }
}

CloudTable'ı kullanma hakkında daha fazla bilgi için bkz . Azure Tablo depolamayı kullanmaya başlama.

bağlamaya CloudTable ve hata iletisi almaya çalışırsanız, doğru Depolama SDK'sı sürümüne bir başvurunuz olduğundan emin olun.

İşlevler 1.x

Aşağıdaki örnekte tek bir tablo satırını okuyan bir C# işlevi gösterilmektedir. Kuyruğa gönderilen her ileti için işlev tetiklenir.

Satır anahtarı değeri {queueTrigger} , satır anahtarını ileti meta verilerine (ileti dizesi) bağlar.

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

    [FunctionName("TableInput")]
    public static void TableInput(
        [QueueTrigger("table-items")] string input, 
        [Table("MyTable", "MyPartition", "{queueTrigger}")] MyPoco poco, 
        ILogger log)
    {
        log.LogInformation($"PK={poco.PartitionKey}, RK={poco.RowKey}, Text={poco.Text}");
    }
}

Aşağıdaki örnekte, sınıfının öğesinden türetildiği MyPoco birden çok tablo satırını okuyan bir TableEntity gösterilmektedir.

public class TableStorage
{
    public class MyPoco : TableEntity
    {
        public string Text { get; set; }
    }

    [FunctionName("TableInput")]
    public static void TableInput(
        [QueueTrigger("table-items")] string input, 
        [Table("MyTable", "MyPartition")] IQueryable<MyPoco> pocos, 
        ILogger log)
    {
        foreach (MyPoco poco in pocos)
        {
            log.LogInformation($"PK={poco.PartitionKey}, RK={poco.RowKey}, Text={poco.Text}");
        }
    }
}

Azure Tabloları uzantısı

Aşağıdaki MyTableData sınıf, tablodaki bir veri satırını temsil eder:

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

Kuyruk Depolama tetikleyicisi tarafından başlatılan aşağıdaki işlev, giriş tablosundan satırı almak için kullanılan kuyruktan bir satır anahtarı okur. İfade {queueTrigger} , satır anahtarını ileti meta verilerine bağlar ve bu da ileti dizesidir.

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

Aşağıdaki Kuyruk ile tetiklenen işlev, ilk 5 varlığı olarak IEnumerable<T>döndürür ve bölüm anahtarı değeri kuyruk iletisi olarak ayarlanır.

[Function("TestFunction")]
public static void Run([QueueTrigger("myqueue", Connection = "AzureWebJobsStorage")] string partition,
    [TableInput("inTable", "{queueTrigger}", Take = 5, Filter = "Text eq 'test'", 
    Connection = "AzureWebJobsStorage")] IEnumerable<MyTableData> tableInputs,
    FunctionContext context)
{
    var logger = context.GetLogger("TestFunction");
    logger.LogInformation(partition);
    foreach (MyTableData tableInput in tableInputs)
    {
        logger.LogInformation($"PK={tableInput.PartitionKey}, RK={tableInput.RowKey}, Text={tableInput.Text}");
    }
}

Filter ve Take özellikleri, döndürülen varlık sayısını sınırlamak için kullanılır.

Birleşik Azure Depolama uzantısı

Aşağıdaki MyTableData sınıf, tablodaki bir veri satırını temsil eder:

{
    var tableEntities = table.QueryAsync<TableEntity>(filter: $"RowKey eq '{rowKey}'");

    await foreach (TableEntity entity in tableEntities)
    {
        _logger.LogInformation("PK={pk}, RK={rk}, Text={t}", entity.PartitionKey, entity.RowKey, entity["Text"]);
    }

Kuyruk Depolama tetikleyicisi tarafından başlatılan aşağıdaki işlev, giriş tablosundan satırı almak için kullanılan kuyruktan bir satır anahtarı okur. İfade {queueTrigger} , satır anahtarını ileti meta verilerine bağlar ve bu da ileti dizesidir.

namespace SampleApp
{
    public class TableFunction
    {
        private readonly ILogger<TableFunction> _logger;

        public TableFunction(ILogger<TableFunction> logger)
        {
            _logger = logger;
        }

        /// <summary>
        /// This function demonstrates binding to a single <see cref="TableClient"/>
        /// and using the client for output.
        /// </summary>
        [Function(nameof(TableFunction))]
        public async Task Run(
            [QueueTrigger("table-items")] string rowKey,

Aşağıdaki Kuyruk ile tetiklenen işlev, ilk 5 varlığı olarak IEnumerable<T>döndürür ve bölüm anahtarı değeri kuyruk iletisi olarak ayarlanır.

[Function("TestFunction")]
public static void Run([QueueTrigger("myqueue", Connection = "AzureWebJobsStorage")] string partition,
    [TableInput("inTable", "{queueTrigger}", Take = 5, Filter = "Text eq 'test'", 
    Connection = "AzureWebJobsStorage")] IEnumerable<MyTableData> tableInputs,
    FunctionContext context)
{
    var logger = context.GetLogger("TestFunction");
    logger.LogInformation(partition);
    foreach (MyTableData tableInput in tableInputs)
    {
        logger.LogInformation($"PK={tableInput.PartitionKey}, RK={tableInput.RowKey}, Text={tableInput.Text}");
    }
}

Filter ve Take özellikleri, döndürülen varlık sayısını sınırlamak için kullanılır.

İşlevler 1.x

İşlevler sürüm 1.x yalıtılmış çalışan işlemini desteklemez.

Aşağıdaki örnekte, Tablo depolama alanında belirtilen bölümde yer alan kişi nesnelerinin listesini döndüren HTTP ile tetiklenen bir işlev gösterilmektedir. Örnekte, bölüm anahtarı http yolundan ayıklanır ve tableName ve bağlantı işlev ayarlarındandır.

public class Person {
    private String PartitionKey;
    private String RowKey;
    private String Name;

    public String getPartitionKey() { return this.PartitionKey; }
    public void setPartitionKey(String key) { this.PartitionKey = key; }
    public String getRowKey() { return this.RowKey; }
    public void setRowKey(String key) { this.RowKey = key; }
    public String getName() { return this.Name; }
    public void setName(String name) { this.Name = name; }
}

@FunctionName("getPersonsByPartitionKey")
public Person[] get(
        @HttpTrigger(name = "getPersons", methods = {HttpMethod.GET}, authLevel = AuthorizationLevel.FUNCTION, route="persons/{partitionKey}") HttpRequestMessage<Optional<String>> request,
        @BindingName("partitionKey") String partitionKey,
        @TableInput(name="persons", partitionKey="{partitionKey}", tableName="%MyTableName%", connection="MyConnectionString") Person[] persons,
        final ExecutionContext context) {

    context.getLogger().info("Got query for person related to persons with partition key: " + partitionKey);

    return persons;
}

TableInput ek açıklaması, aşağıdaki örnekte gösterildiği gibi isteğin json gövdesinden bağlamaları ayıklayabilir.

@FunctionName("GetPersonsByKeysFromRequest")
public HttpResponseMessage get(
        @HttpTrigger(name = "getPerson", methods = {HttpMethod.GET}, authLevel = AuthorizationLevel.FUNCTION, route="query") HttpRequestMessage<Optional<String>> request,
        @TableInput(name="persons", partitionKey="{partitionKey}", rowKey = "{rowKey}", tableName="%MyTableName%", connection="MyConnectionString") Person person,
        final ExecutionContext context) {

    if (person == null) {
        return request.createResponseBuilder(HttpStatus.NOT_FOUND)
                    .body("Person not found.")
                    .build();
    }

    return request.createResponseBuilder(HttpStatus.OK)
                    .header("Content-Type", "application/json")
                    .body(person)
                    .build();
}

Aşağıdaki örnek, Bir Azure Tablosunda belirli bir ada sahip kişileri sorgulamak için bir filtre kullanır ve olası eşleşme sayısını 10 sonuçla sınırlar.

@FunctionName("getPersonsByName")
public Person[] get(
        @HttpTrigger(name = "getPersons", methods = {HttpMethod.GET}, authLevel = AuthorizationLevel.FUNCTION, route="filter/{name}") HttpRequestMessage<Optional<String>> request,
        @BindingName("name") String name,
        @TableInput(name="persons", filter="Name eq '{name}'", take = "10", tableName="%MyTableName%", connection="MyConnectionString") Person[] persons,
        final ExecutionContext context) {

    context.getLogger().info("Got query for person related to persons with name: " + name);

    return persons;
}

Aşağıdaki örnekte, tek bir tablo satırını okumak için kuyruk tetikleyicisi kullanan bir tablo giriş bağlaması gösterilmektedir. Bağlama, bir partitionKey ve rowKeybelirtir. rowKey"{queueTrigger}" değeri, satır anahtarının kuyruk ileti dizesinden geldiğini gösterir.

Model v4

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

const tableInput = input.table({
    tableName: 'Person',
    partitionKey: 'Test',
    rowKey: '{queueTrigger}',
    connection: 'MyStorageConnectionAppSetting',
});

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

export async function storageQueueTrigger1(queueItem: unknown, context: InvocationContext): Promise<void> {
    context.log('Node.js queue trigger function processed work item', queueItem);
    const person = <PersonEntity>context.extraInputs.get(tableInput);
    context.log('Person entity name: ' + person.Name);
}

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

Model v3

Model v3 için TypeScript örnekleri belgelenmez.

Model v4

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

const tableInput = input.table({
    tableName: 'Person',
    partitionKey: 'Test',
    rowKey: '{queueTrigger}',
    connection: 'MyStorageConnectionAppSetting',
});

app.storageQueue('storageQueueTrigger1', {
    queueName: 'myqueue-items',
    connection: 'MyStorageConnectionAppSetting',
    extraInputs: [tableInput],
    handler: (queueItem, context) => {
        context.log('Node.js queue trigger function processed work item', queueItem);
        const person = context.extraInputs.get(tableInput);
        context.log('Person entity name: ' + person.Name);
    },
});

Model v3

{
  "bindings": [
    {
      "queueName": "myqueue-items",
      "connection": "MyStorageConnectionAppSetting",
      "name": "myQueueItem",
      "type": "queueTrigger",
      "direction": "in"
    },
    {
      "name": "personEntity",
      "type": "table",
      "tableName": "Person",
      "partitionKey": "Test",
      "rowKey": "{queueTrigger}",
      "connection": "MyStorageConnectionAppSetting",
      "direction": "in"
    }
  ],
  "disabled": false
}

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

JavaScript kodu şu şekildedir:

module.exports = async function (context, myQueueItem) {
    context.log('Node.js queue trigger function processed work item', myQueueItem);
    context.log('Person entity name: ' + context.bindings.personEntity.Name);
};

Aşağıdaki işlev, bir işleve giriş olarak tek bir tablo satırını okumak için kuyruk tetikleyicisini kullanır.

Bu örnekte, bağlama yapılandırması tablonun partitionKey için açık bir değer belirtir ve öğesine geçirmek rowKeyiçin bir ifade kullanır. rowKey ifadesi, {queueTrigger}satır anahtarının kuyruk ileti dizesinden geldiğini gösterir.

function.json bağlama yapılandırması:

{
  "bindings": [
    {
      "queueName": "myqueue-items",
      "connection": "MyStorageConnectionAppSetting",
      "name": "MyQueueItem",
      "type": "queueTrigger",
      "direction": "in"
    },
    {
      "name": "PersonEntity",
      "type": "table",
      "tableName": "Person",
      "partitionKey": "Test",
      "rowKey": "{queueTrigger}",
      "connection": "MyStorageConnectionAppSetting",
      "direction": "in"
    }
  ],
  "disabled": false
}

run.ps1'de PowerShell kodu:

param($MyQueueItem, $PersonEntity, $TriggerMetadata)
Write-Host "PowerShell queue trigger function processed work item: $MyQueueItem"
Write-Host "Person entity name: $($PersonEntity.Name)"

Aşağıdaki işlev, bir işleve giriş olarak tek bir tablo satırını okumak için BIR HTTP tetikleyicisi kullanır.

Bu örnekte, bağlama yapılandırması tablonun partitionKey için açık bir değer belirtir ve öğesine geçirmek rowKeyiçin bir ifade kullanır. rowKey ifadesi, {id} satır anahtarının istekteki {id} yolun bölümünden geldiğini gösterir.

v2

import json
import azure.functions as func

app = func.FunctionApp()

@app.route(route="messages/{id}")
@app.table_input(arg_name="messageJSON",
                 connection="AzureWebJobsStorage",
                 table_name="messages",
                 row_key='{id}',
                 partition_key="message")
def table_in_binding(req: func.HttpRequest, messageJSON):
    message = json.loads(messageJSON)
    return func.HttpResponse(f"Table row: {messageJSON}")

Bu basit bağlamayla, satır anahtarı kimliğine sahip satır bulunmayan bir olayı program aracılığıyla işleyemezsiniz. Daha ayrıntılı veri seçimi için depolama SDK'sını kullanın.

v1

function.json dosyasında bağlama yapılandırması:

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "messageJSON",
      "type": "table",
      "tableName": "messages",
      "partitionKey": "message",
      "rowKey": "{id}",
      "connection": "AzureWebJobsStorage",
      "direction": "in"
    },
    {
      "authLevel": "function",
      "type": "httpTrigger",
      "direction": "in",
      "name": "req",
      "methods": [
        "get",
        "post"
      ],
      "route": "messages/{id}"
    },
    {
      "type": "http",
      "direction": "out",
      "name": "$return"
    }
  ],
  "disabled": false
}

__init__.py dosyasındaki Python kodu:

import json

import azure.functions as func

def main(req: func.HttpRequest, messageJSON) -> func.HttpResponse:

    message = json.loads(messageJSON)
    return func.HttpResponse(f"Table row: {messageJSON}")

Bu basit bağlamayla, satır anahtarı kimliğine sahip satır bulunmayan bir olayı program aracılığıyla işleyemezsiniz. Daha ayrıntılı veri seçimi için depolama SDK'sını kullanın.

Özellikler

hem işlem içi hem de yalıtılmış çalışan işlemi C# kitaplıkları işlevi tanımlamak için öznitelikleri 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

C# sınıf kitaplıklarında, TableInputAttribute aşağıdaki özellikleri destekler:

Öznitelik özelliği	Açıklama
Tablo Adı	Tablonun adı.
PartitionKey	isteğe bağlı. Okunacak tablo varlığının bölüm anahtarı.
RowKey	isteğe bağlı. Okunacak tablo varlığının satır anahtarı.
Almak	isteğe bağlı. bir içine okunacak IEnumerable<T>varlık sayısı üst sınırı. ile RowKeykullanılamaz.
Filtre	isteğe bağlı. Varlıkların içine IEnumerable<T>okuması için bir OData filtre ifadesi. ile RowKeykullanılamaz.
Bağlantı	Tablo hizmetine nasıl bağlanıldığını belirten bir uygulama ayarının veya ayar koleksiyonunun adı. Bkz. Bağlantılar.

İşlem içi model

C# sınıf kitaplıklarında, TableAttribute aşağıdaki özellikleri destekler:

Öznitelik özelliği	Açıklama
Tablo Adı	Tablonun adı.
PartitionKey	isteğe bağlı. Okunacak tablo varlığının bölüm anahtarı. Bu özelliğin nasıl kullanılacağına ilişkin yönergeler için kullanım bölümüne bakın.
RowKey	isteğe bağlı. Okunacak tek bir tablo varlığının satır anahtarı. veya Takeile Filter kullanılamaz.
Almak	isteğe bağlı. Döndürülecek varlık sayısı üst sınırı. ile RowKeykullanılamaz.
Filtre	isteğe bağlı. Tablodan döndürülecek varlıklar için bir OData filtre ifadesi. ile RowKeykullanılamaz.
Bağlantı	Tablo hizmetine nasıl bağlanıldığını belirten bir uygulama ayarının veya ayar koleksiyonunun adı. Bkz. Bağlantılar.

Özniteliğin oluşturucusunda aşağıdaki örnekte gösterildiği gibi tablo adı, bölüm anahtarı ve satır anahtarı yer alır:

[FunctionName("TableInput")]
public static void Run(
    [QueueTrigger("table-items")] string input, 
    [Table("MyTable", "Http", "{queueTrigger}")] MyPoco poco, 
    ILogger log)
{
    ...
}

Özelliğini, aşağıdaki örnekte gösterildiği gibi tablo hizmetine bağlantıyı belirtecek şekilde ayarlayabilirsiniz Connection :

[FunctionName("TableInput")]
public static void Run(
    [QueueTrigger("table-items")] string input, 
    [Table("MyTable", "Http", "{queueTrigger}", Connection = "StorageConnectionAppSetting")] MyPoco poco, 
    ILogger log)
{
    ...
}

Ö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ı.

Ek Açıklamalar

Java işlevleri çalışma zamanı kitaplığında, değeri Tablo depolamadan gelecek parametrelerde ek açıklamayı kullanın@TableInput. Bu ek açıklama kullanılarak yerel Java türleri, POJO'lar veya null atanabilir değerlerle Optional<T>kullanılabilir. Bu ek açıklama aşağıdaki öğeleri destekler:

Öğe	Açıklama
ad	İşlev kodundaki tabloyu veya varlığı temsil eden değişkenin adı.
tableName	Tablonun adı.
partitionKey	isteğe bağlı. Okunacak tablo varlığının bölüm anahtarı.
rowKey	isteğe bağlı. Okunacak tablo varlığının satır anahtarı.
almak	isteğe bağlı. Okunacak en fazla varlık sayısı.
filtre	isteğe bağlı. Tablo girişi için bir OData filtre ifadesi.
bağlantı	Tablo hizmetine nasıl bağlanıldığını belirten bir uygulama ayarının veya ayar koleksiyonunun adı. Bkz. Bağlantılar.

Yapılandırma

Model v4

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

Özellik	Açıklama
tableName	Tablonun adı.
partitionKey	isteğe bağlı. Okunacak tablo varlığının bölüm anahtarı.
rowKey	isteğe bağlı. Okunacak tablo varlığının satır anahtarı. veya takeile filter kullanılamaz.
almak	isteğe bağlı. Döndürülecek varlık sayısı üst sınırı. ile rowKeykullanılamaz.
filtre	isteğe bağlı. Tablodan döndürülecek varlıklar için bir OData filtre ifadesi. ile rowKeykullanılamaz.
bağlantı	Tablo hizmetine nasıl bağlanıldığını belirten bir uygulama ayarının veya ayar koleksiyonunun adı. Bkz. Bağlantılar.

Model v3

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

Özellik	Açıklama
türü	olarak ayarlanmalıdır table. Bağlamayı Azure portalında oluşturduğunuzda bu özellik otomatik olarak ayarlanır.
yön	olarak ayarlanmalıdır in. Bağlamayı Azure portalında oluşturduğunuzda bu özellik otomatik olarak ayarlanır.
ad	İşlev kodundaki tabloyu veya varlığı temsil eden değişkenin adı.
tableName	Tablonun adı.
partitionKey	isteğe bağlı. Okunacak tablo varlığının bölüm anahtarı.
rowKey	isteğe bağlı. Okunacak tablo varlığının satır anahtarı. veya takeile filter kullanılamaz.
almak	isteğe bağlı. Döndürülecek varlık sayısı üst sınırı. ile rowKeykullanılamaz.
filtre	isteğe bağlı. Tablodan döndürülecek varlıklar için bir OData filtre ifadesi. ile rowKeykullanılamaz.
bağlantı	Tablo hizmetine nasıl bağlanıldığını belirten bir uygulama ayarının veya ayar koleksiyonunun adı. Bkz. Bağlantılar.

Yapılandırma

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

function.json özelliği	Açıklama
türü	olarak ayarlanmalıdır table. Bağlamayı Azure portalında oluşturduğunuzda bu özellik otomatik olarak ayarlanır.
yön	olarak ayarlanmalıdır in. Bağlamayı Azure portalında oluşturduğunuzda bu özellik otomatik olarak ayarlanır.
ad	İşlev kodundaki tabloyu veya varlığı temsil eden değişkenin adı.
tableName	Tablonun adı.
partitionKey	isteğe bağlı. Okunacak tablo varlığının bölüm anahtarı.
rowKey	isteğe bağlı. Okunacak tablo varlığının satır anahtarı. veya takeile filter kullanılamaz.
almak	isteğe bağlı. Döndürülecek varlık sayısı üst sınırı. ile rowKeykullanılamaz.
filtre	isteğe bağlı. Tablodan döndürülecek varlıklar için bir OData filtre ifadesi. ile rowKeykullanılamaz.
bağlantı	Tablo hizmetine nasıl bağlanıldığını belirten bir uygulama ayarının veya ayar koleksiyonunun adı. Bkz. Bağlantılar.

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

Bağlantılar

Bu özellik, connection uygulama ayarlarında Functions çalışma zamanında uzantının kullandığı depolama hesabına bağlanmak için kullanılan bir değeri döndüren bir anahtara ayarlanmıştır. Bağlantı özellik ayarının değeri, bağlantı türüne bağlıdır:

• Yönetilen kimlik bağlantısı: Özellik, connection<CONNECTION_NAME_PREFIX> depolama hesabına kimlik tabanlı bir bağlantı tanımlayan bir grup ayar tarafından paylaşılan bir özelliktir. Daha fazla bilgi için bkz. Kimlik bağlantılarını tanımlar.
• Key Vault referansı: Özellik connection ayarı, bağlantı dizesi'in merkezi olarak korunduğu konuma Azure Key Vault referansı döner. Daha fazla bilgi için Define Key Vault bağlantılarını tanımla.
• App Configuration referansı: Özellik connection ayarı, bağlantı dizesi veya Key Vault referansı döndüren bir Azure Uygulama Yapılandırması referansı döndürür. Daha fazla bilgi için connections makalesindeki Azure Uygulama Yapılandırması'a bakınız.
• Connection string: Özellik connection ayarı gerçek depolama hesabı bağlantı dizesi'i döndürür. Çünkü bağlantı dizesi paylaşılan gizli anahtarlar içerir, mümkün olduğunda yönetilen bir kimlik bağlantısı kullanmayı düşünmelisiniz. Daha fazla bilgi için bkz. Bağlantıları tanımlar.

Bağlama bağlantıları hakkında daha fazla bilgi edinmek için Azure İşlevleri'te bağlantıyı yönet bölümüne bakınız. bağlantı dizesi almak için Depolama hesabı erişim anahtarlarını yönetme adresinde gösterilen adımları izleyin.

Bir anahtar veya anahtar öneki ya da connection boş bir diziye ayarladığınızdaAzureWebJobsStorage, bağlama uzantısı varsayılan host depolama hesabını kullanır. Daha fazla bilgi için bkz. Depolama performansını optimize et.

Kullanım

Bağlamanın kullanımı uzantı paketi sürümüne ve işlev uygulamanızda kullanılan C# modalitesine bağlıdır ve bu da aşağıdakilerden biri olabilir:

Yalıtılmış çalışan modeli

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.

İşlem içi model

İşlem içi sınıf kitaplığı, İşlevler çalışma zamanıyla aynı işlemde çalışan derlenmiş bir C# işlevidir.

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

Azure Tabloları uzantısı

Anahtara göre belirli bir varlığı döndürmek için TableEntity'den türetilen bağlama parametresini kullanın.

Birden çok varlık döndüren sorguları yürütmek için bir [TableClient] nesnesine bağlayın. Ardından bu nesneyi kullanarak ilişkili tabloya yönelik sorgular oluşturabilir ve yürütebilirsiniz. [TableClient] ve ilgili API'lerin Azure.Data.Tables ad alanına ait olduğunu unutmayın.

Birleşik Azure Depolama uzantısı

Anahtara göre belirli bir varlığı döndürmek için TableEntity'den türetilen bağlama parametresini kullanın.

Birden çok varlık döndüren sorguları yürütmek için bir CloudTable nesnesine bağlayın. Ardından bu nesneyi kullanarak ilişkili tabloya yönelik sorgular oluşturabilir ve yürütebilirsiniz. CloudTable ve ilgili API'lerin Microsoft.Azure.Cosmos.Table ad alanına ait olduğunu unutmayın.

İşlevler 1.x

Anahtara göre belirli bir varlığı döndürmek için TableEntity'den türetilen bağlama parametresini kullanın. Belirli TableName, PartitionKeyve RowKey tablodaki belirli bir varlığı denemek ve almak için kullanılır.

Birden çok varlık döndüren sorguları yürütmek için TableEntity'den IQueryable<T>devralan bir türe bağlayın.

Azure Tabloları uzantısı

Tek bir tablo varlığıyla çalışırken Azure Tabloları giriş bağlaması aşağıdaki türlere bağlanabilir:

Türü	Açıklama
ITableEntity uygulayan bir JSON serileştirilebilir türü	İşlevler, varlığı seri durumdan çıkararak düz eski bir CLR nesnesi (POCO) türüne dönüştürmeye çalışır. Türün ITableEntity uygulaması veya dize RowKey özelliği ve dize PartitionKey özelliği olmalıdır.
TableEntity1	Sözlük benzeri bir tür olarak varlık.

Bir sorgudan birden çok varlıkla çalışırken Azure Tabloları giriş bağlaması aşağıdaki türlere bağlanabilir:

Türü	Açıklama
IEnumerable<T>whereT, ITableEntity'i uygular	Sorgu tarafından döndürülen varlıkların numaralandırması. Her girdi bir varlığı temsil eder. Türün T ITableEntity uygulaması veya dize RowKey özelliği ve dize PartitionKey özelliği olmalıdır.
TableClient1	Tabloya bağlı bir istemci. Bu, tabloyu işlemek için en fazla denetimi sunar ve bağlantı yeterli izne sahipse tabloya yazmak için kullanılabilir.

¹ Bu türleri kullanmak için Microsoft.Azure.Functions.Worker.Extensions.Tables 1.2.0 veya sonraki sürümlerine ve SDK türü bağlamalarına yönelik ortak bağımlılıklara başvurmanız gerekir.

Birleşik Azure Depolama uzantısı

Anahtara göre belirli bir varlığı döndürmek için düz eski bir CLR nesnesi (POCO) kullanın. Belirli TableName, PartitionKeyve RowKey tablodaki belirli bir varlığı denemek ve almak için kullanılır.

Birden çok varlığı olarak IEnumerable<T>döndürürken, sonuç kümesini kısıtlamak için ve Take özelliklerini kullanabilirsinizFilter.

İşlevler 1.x

İşlevler sürüm 1.x yalıtılmış çalışan işlemini desteklemez.

TableInput özniteliği, işlevi tetikleyen tablo satırına erişmenizi sağlar.

Model v4

kullanarak context.extraInputs.get()giriş satırı verilerini alın.

Model v3

function.jsoncontext.bindings.<name>belirtilen değeri kullanarak <name>name giriş satırı verilerini alın.

Veriler, function.json dosyasındaki name anahtar tarafından belirtilen giriş parametresine geçirilir. ve partitionKeyrowKey belirterek belirli kayıtlara filtre uygulamanıza olanak tanır.

Tablo verileri işleve JSON dizesi olarak geçirilir. Giriş json.loads gösterildiği gibi çağırarak iletiyi seri durumdan kaldırın.

Belirli kullanım ayrıntıları için bkz . Örnek.

Sonraki adımlar

• bir işlevden tablo verileri yazma