Azure İşlevleri için Azure Blob depolama tetikleyicisi

Python v2 programlama modeli, doğrudan Python işlev kodunuzda dekoratörleri kullanarak bağlamaları tanımlamanıza olanak tanır. Daha fazla bilgi için bkz . Python geliştirici kılavuzu.

Python v1 programlama modeli, işlev klasöründeki ayrı bir function.json dosyasında bağlamaları tanımlamanızı gerektirir. Daha fazla bilgi için bkz . Python geliştirici kılavuzu.

Aşağıdaki örnek, yalıtılmış bir çalışan işleminde çalışan ve hem blob girişi hem de blob çıkış blob bağlamaları ile blob tetikleyicisi kullanan bir C# işlevidir . İşlev, test-samples-trigger kapsayıcısında bir blob oluşturularak tetikleniyor. Test-samples-input kapsayıcısından bir metin dosyası okur ve tetiklenen dosyanın adına göre çıkış kapsayıcısında yeni bir metin dosyası oluşturur.

public static class BlobFunction
{
    [Function(nameof(BlobFunction))]
    [BlobOutput("test-samples-output/{name}-output.txt")]
    public static string Run(
        [BlobTrigger("test-samples-trigger/{name}")] string myTriggerItem,
        [BlobInput("test-samples-input/sample1.txt")] string myBlob,
        FunctionContext context)
    {
        var logger = context.GetLogger("BlobFunction");
        logger.LogInformation("Triggered Item = {myTriggerItem}", myTriggerItem);
        logger.LogInformation("Input Item = {myBlob}", myBlob);

        // Blob Output
        return "blob-output content";
    }
}

Aşağıdaki örnekte, kapsayıcıya blob eklendiğinde veya güncelleştirildiğinde samples-workitems günlük yazan bir C# işlevi gösterilmektedir.

[FunctionName("BlobTriggerCSharp")]        
public static void Run([BlobTrigger("samples-workitems/{name}")] Stream myBlob, string name, ILogger log)
{
    log.LogInformation($"C# Blob trigger function Processed blob\n Name:{name} \n Size: {myBlob.Length} Bytes");
}

Blob tetikleyici yolundaki samples-workitems/{name} dize{name}, tetikleyici blobun dosya adına erişmek için işlev kodunda kullanabileceğiniz bir bağlama ifadesi oluşturur. Daha fazla bilgi için bu makalenin devamında yer alan Blob adı desenleri bölümüne bakın.

Öznitelik hakkında BlobTrigger daha fazla bilgi için bkz . Öznitelikler.

Aşağıdaki örnekte bir blob tetikleyici TypeScript kodu gösterilmektedir. İşlev, kapsayıcıya bir blob eklendiğinde veya güncelleştirildiğinde samples-workitems bir günlük yazar.

Blob tetikleyici yolundaki samples-workitems/{name} dize{name}, tetikleyici blobun dosya adına erişmek için işlev kodunda kullanabileceğiniz bir bağlama ifadesi oluşturur. Daha fazla bilgi için bu makalenin devamında yer alan Blob adı desenleri bölümüne bakın.

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

export async function storageBlobTrigger1(blob: Buffer, context: InvocationContext): Promise<void> {
    context.log(
        `Storage blob function processed blob "${context.triggerMetadata.name}" with size ${blob.length} bytes`
    );
}

app.storageBlob('storageBlobTrigger1', {
    path: 'samples-workitems/{name}',
    connection: 'MyStorageAccountAppSetting',
    handler: storageBlobTrigger1,
});

Model v3 için TypeScript örnekleri belgelenmez.

Aşağıdaki örnekte bir blob tetikleyicisi JavaScript kodu gösterilmektedir. İşlev, kapsayıcıya bir blob eklendiğinde veya güncelleştirildiğinde samples-workitems bir günlük yazar.

Blob tetikleyici yolundaki samples-workitems/{name} dize{name}, tetikleyici blobun dosya adına erişmek için işlev kodunda kullanabileceğiniz bir bağlama ifadesi oluşturur. Daha fazla bilgi için bu makalenin devamında yer alan Blob adı desenleri bölümüne bakın.

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

app.storageBlob('storageBlobTrigger1', {
    path: 'samples-workitems/{name}',
    connection: 'MyStorageAccountAppSetting',
    handler: (blob, context) => {
        context.log(
            `Storage blob function processed blob "${context.triggerMetadata.name}" with size ${blob.length} bytes`
        );
    },
});

Aşağıdaki örnekte, function.json dosyasında blob tetikleyici bağlaması ve bağlamayı kullanan JavaScript kodu gösterilmektedir. İşlev, kapsayıcıya bir blob eklendiğinde veya güncelleştirildiğinde samples-workitems bir günlük yazar.

İşte function.json dosyası:

{
    "disabled": false,
    "bindings": [
        {
            "name": "myBlob",
            "type": "blobTrigger",
            "direction": "in",
            "path": "samples-workitems/{name}",
            "connection":"MyStorageAccountAppSetting"
        }
    ]
}

Blob tetikleyici yolundaki samples-workitems/{name} dize{name}, tetikleyici blobun dosya adına erişmek için işlev kodunda kullanabileceğiniz bir bağlama ifadesi oluşturur. Daha fazla bilgi için bu makalenin devamında yer alan Blob adı desenleri bölümüne bakın.

function.json dosya özellikleri hakkında daha fazla bilgi için bu özelliklerin açıklandığı Yapılandırma bölümüne bakın.

JavaScript kodu şu şekildedir:

module.exports = async function(context) {
    context.log('Node.js Blob trigger function processed', context.bindings.myBlob);
};

Bu örnek, Blob depolama tetikleyicisi tarafından sağlanan temel alınan BlobClient nesneye doğrudan erişmek için SDK türlerini kullanır:

import logging

import azure.functions as func
import azurefunctions.extensions.bindings.blob as blob

app = func.FunctionApp(http_auth_level=func.AuthLevel.ANONYMOUS)
@app.blob_trigger(
    arg_name="client", path="PATH/TO/BLOB", connection="AzureWebJobsStorage"
)
def blob_trigger(client: blob.BlobClient):
    logging.info(
        f"Python blob trigger function processed blob \n"
        f"Properties: {client.get_blob_properties()}\n"
        f"Blob content head: {client.download_blob().read(size=1)}"
    )

Diğer SDK türlerini kullanma örnekleri için ve StorageStreamDownloader örneklerine ContainerClient bakın.

Projenizde SDK türü bağlamalarını etkinleştirme de dahil olmak üzere daha fazla bilgi edinmek için bkz . SDK türü bağlamaları.

Bu örnek, gelen blob meta verilerindeki bilgileri günlüğe kaydeder.

import logging
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="BlobTrigger1")
@app.blob_trigger(arg_name="myblob", 
                  path="PATH/TO/BLOB",
                  connection="CONNECTION_SETTING")
def test_function(myblob: func.InputStream):
   logging.info(f"Python blob trigger function processed blob \n"
                f"Name: {myblob.name}\n"
                f"Blob Size: {myblob.length} bytes")

İşlev, kapsayıcıya bir blob eklendiğinde veya güncelleştirildiğinde samples-workitems bir günlük yazar. İşte function.json dosyası:

{
    "scriptFile": "__init__.py",
    "disabled": false,
    "bindings": [
        {
            "name": "myblob",
            "type": "blobTrigger",
            "direction": "in",
            "path": "samples-workitems/{name}",
            "connection":"MyStorageAccountAppSetting"
        }
    ]
}

Blob tetikleyici yolundaki samples-workitems/{name} dize{name}, tetikleyici blobun dosya adına erişmek için işlev kodunda kullanabileceğiniz bir bağlama ifadesi oluşturur. Daha fazla bilgi için bu makalenin devamında yer alan Blob adı desenleri bölümüne bakın.

function.json dosya özellikleri hakkında daha fazla bilgi için bu özelliklerin açıklandığı Yapılandırma bölümüne bakın.

Python kodu şu şekildedir:

import logging
import azure.functions as func


def main(myblob: func.InputStream):
    logging.info('Python Blob trigger function processed %s', myblob.name)

Yöntem BlobTrigger imzasında bir öznitelik aşağıdadır:

[Function(nameof(BlobFunction))]
[BlobOutput("test-samples-output/{name}-output.txt")]
public static string Run(
    [BlobTrigger("test-samples-trigger/{name}")] string myTriggerItem,
    [BlobInput("test-samples-input/sample1.txt")] string myBlob,
    FunctionContext context)

C# sınıf kitaplıklarında özniteliğin oluşturucu, izlenmek üzere kapsayıcıyı ve isteğe bağlı olarak bir blob adı desenini gösteren bir yol dizesi alır. Bir örnek aşağıda verilmiştir:

[FunctionName("ResizeImage")]
public static void Run(
  [BlobTrigger("sample-images/{name}")] Stream image,
  [Blob("sample-images-md/{name}", FileAccess.Write)] Stream imageSmall)
{
  ....
}

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

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

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

Meta veriler, aşağıdaki örnekte gösterildiği gibi sağlanan context nesnenin özelliğinden triggerMetadata alınabilir ve kapsayıcı da dahil olmak üzere tetikleyici blobun (blobTrigger yolunu günlüğe kaydeder:

context.log(`Full blob path: ${context.triggerMetadata.blobTrigger}`);

Meta veriler, aşağıdaki örnekte gösterildiği gibi sağlanan context nesnenin özelliğinden bindingData alınabilir ve kapsayıcı da dahil olmak üzere tetikleyici blobun (blobTrigger yolunu günlüğe kaydeder:

module.exports = async function (context, myBlob) {
    context.log("Full blob path:", context.bindingData.blobTrigger);
};

Blob tetikleyicisi aşağıdaki türlere bağlanabilir:

¹ Bu türleri kullanmak için Microsoft.Azure.Functions.Worker.Extensions.Storage.Blobs 6.0.0 veya sonraki sürümlerine ve SDK türü bağlamaları için ortak bağımlılıklara başvurmanız gerekir.

Desteklenen türlerin listesi için bkz. Bağlama türleri.

İşlevinizin ilk bağımsız değişkeni olarak blob verilerine erişin.

blob verilerine context.bindings.<NAME> erişmek için function.json'de <NAME> tanımlanan değerle eşleşir.