Dayanıklı İşlevler'de fan-out/fan-in senaryosu - Bulut yedekleme örneği

2023-05-23

Fan-out/fan-in , birden çok işlevi eşzamanlı olarak yürütme ve ardından sonuçlar üzerinde toplama gerçekleştirme desenini ifade eder. Bu makalede, bir fan-in/fan-out senaryosu uygulamak için Dayanıklı İşlevler kullanan bir örnek açıklanmaktadır. Örnek, bir uygulamanın site içeriğinin tamamını veya bir kısmını Azure Depolama'ya yedekleyen dayanıklı bir işlevdir.

Not

Azure İşlevleri için Node.js programlama modelinin 4. sürümü genel olarak kullanılabilir. Yeni v4 modeli, JavaScript ve TypeScript geliştiricileri için daha esnek ve sezgisel bir deneyime sahip olacak şekilde tasarlanmıştır. Geçiş kılavuzunda v3 ve v4 arasındaki farklar hakkında daha fazla bilgi edinin.

Aşağıdaki kod parçacıklarında JavaScript (PM4), yeni deneyim olan programlama modeli V4'i belirtir.

Önkoşullar

Senaryoya genel bakış

Bu örnekte, işlevler belirtilen dizin altındaki tüm dosyaları yinelenen olarak blob depolama alanına yükler. Ayrıca karşıya yüklenen toplam bayt sayısını da sayar.

Her şeyi halleden tek bir işlev yazmak mümkündür. Karşılaşacağınız temel sorun ölçeklenebilirliktir. Tek bir işlev yürütmesi yalnızca tek bir sanal makinede çalıştırılabilir, bu nedenle aktarım hızı bu tek VM'nin aktarım hızıyla sınırlandırılır. Bir diğer sorun da güvenilirliktir. Tam ortasında bir hata varsa veya işlemin tamamı 5 dakikadan uzun sürüyorsa yedekleme kısmen tamamlanmış durumda başarısız olabilir. Daha sonra yeniden başlatılması gerekir.

İki normal işlev yazmak daha sağlam bir yaklaşım olacaktır: biri dosyaları numaralandırır, dosya adlarını bir kuyruğa ekler ve diğeri kuyruktan okuyup dosyaları blob depolamaya yükler. Bu yaklaşım aktarım hızı ve güvenilirlik açısından daha iyidir, ancak bir kuyruk sağlamanızı ve yönetmenizi gerektirir. Daha da önemlisi, karşıya yüklenen toplam bayt sayısını raporlama gibi daha fazlasını yapmak istiyorsanız durum yönetimi ve koordinasyon açısından önemli bir karmaşıklık ortaya konur.

Dayanıklı İşlevler bir yaklaşım, çok düşük ek yük ile bahsedilen avantajların tümünü sunar.

İşlevler

Bu makalede, örnek uygulamada aşağıdaki işlevler açıklanmaktadır:

E2_BackupSiteContent: Yedeklene dosyaların listesini almak için çağıran E2_GetFileList ve ardından her dosyayı yedeklemeye çağıran E2_CopyFileToBlob bir orchestrator işlevi.
E2_GetFileList: Dizindeki dosyaların listesini döndüren etkinlik işlevi .
E2_CopyFileToBlob: Tek bir dosyayı Azure Blob Depolama yedekleyen etkinlik işlevi.

E2_BackupSiteContent orchestrator işlevi

Bu orchestrator işlevi temelde aşağıdakileri yapar:

Giriş parametresi olarak bir rootDirectory değer alır.
altında rootDirectoryözyinelemeli bir dosya listesi almak için bir işlevi çağırır.
Her dosyayı Azure Blob Depolama yüklemek için birden çok paralel işlev çağrısı yapar.
Tüm karşıya yüklemelerin tamamlanmasını bekler.
Azure Blob Depolama yüklenen toplam bayt toplamını döndürür.

Orchestrator işlevini uygulayan kod aşağıdadır:

[FunctionName("E2_BackupSiteContent")]
public static async Task<long> Run(
    [OrchestrationTrigger] IDurableOrchestrationContext backupContext)
{
    string rootDirectory = backupContext.GetInput<string>()?.Trim();
    if (string.IsNullOrEmpty(rootDirectory))
    {
        rootDirectory = Directory.GetParent(typeof(BackupSiteContent).Assembly.Location).FullName;
    }

    string[] files = await backupContext.CallActivityAsync<string[]>(
        "E2_GetFileList",
        rootDirectory);

    var tasks = new Task<long>[files.Length];
    for (int i = 0; i < files.Length; i++)
    {
        tasks[i] = backupContext.CallActivityAsync<long>(
            "E2_CopyFileToBlob",
            files[i]);
    }

    await Task.WhenAll(tasks);

    long totalBytes = tasks.Sum(t => t.Result);
    return totalBytes;
}

Satıra await Task.WhenAll(tasks); dikkat edin. İşleve E2_CopyFileToBlob yapılan tek tek tüm çağrılar beklenmedi ve bu da paralel olarak çalışmalarına olanak tanır. Bu görev dizisini öğesine Task.WhenAllgeçirdiğimizde, tüm kopyalama işlemleri tamamlanana kadar tamamlanmayacak bir görevi geri alacağız. .NET'teki Görev Paralel Kitaplığı 'nı (TPL) biliyorsanız, bu sizin için yeni değildir. Aradaki fark, bu görevlerin aynı anda birden çok sanal makinede çalışıyor olması ve Dayanıklı İşlevler uzantısının uçtan uca yürütmenin geri dönüşümü işlemeye dayanıklı olmasını sağlamasıdır.

'den Task.WhenAllbekledikten sonra, tüm işlev çağrılarının tamamlandığını ve değerleri bize geri döndürdüğünü biliyoruz. her çağrısı E2_CopyFileToBlob karşıya yüklenen bayt sayısını döndürür, bu nedenle toplam bayt sayısını hesaplamak, tüm bu dönüş değerlerinin bir araya eklenmesiyle ilgili bir konudur.

işlevi, düzenleyici işlevleri için standart function.json kullanır.

{
  "bindings": [
    {
      "name": "context",
      "type": "orchestrationTrigger",
      "direction": "in"
    }
  ],
  "disabled": false
}

Orchestrator işlevini uygulayan kod aşağıdadır:

const df = require("durable-functions");

module.exports = df.orchestrator(function* (context) {
    const rootDirectory = context.df.getInput();
    if (!rootDirectory) {
        throw new Error("A directory path is required as an input.");
    }

    const files = yield context.df.callActivity("E2_GetFileList", rootDirectory);

    // Backup Files and save Promises into array
    const tasks = [];
    for (const file of files) {
        tasks.push(context.df.callActivity("E2_CopyFileToBlob", file));
    }

    // wait for all the Backup Files Activities to complete, sum total bytes
    const results = yield context.df.Task.all(tasks);
    const totalBytes = results.reduce((prev, curr) => prev + curr, 0);

    // return results;
    return totalBytes;
});

Satıra yield context.df.Task.all(tasks); dikkat edin. İşleve E2_CopyFileToBlob yapılan tek tek tüm çağrılar , paralel olarak çalıştırılmasını sağlayan verim alınmadı. Bu görev dizisini öğesine context.df.Task.allgeçirdiğimizde, tüm kopyalama işlemleri tamamlanana kadar tamamlanmayacak bir görevi geri alacağız. JavaScript hakkında Promise.all bilgi sahibiyseniz, bu sizin için yeni değildir. Aradaki fark, bu görevlerin aynı anda birden çok sanal makinede çalışıyor olması ve Dayanıklı İşlevler uzantısının uçtan uca yürütmenin geri dönüşümü işlemeye dayanıklı olmasını sağlamasıdır.

Not

Görevler kavramsal olarak JavaScript vaatlerine benzer olsa da, orchestrator işlevleri görev paralelleştirmesini yönetmek için ve yerine ve Promise.race kullanmalıdır context.df.Task.all context.df.Task.any.Promise.all

'den context.df.Task.allçıktıktan sonra, tüm işlev çağrılarının tamamlandığını ve değerleri bize geri döndürdüğünü biliyoruz. her çağrısı E2_CopyFileToBlob karşıya yüklenen bayt sayısını döndürür, bu nedenle toplam bayt sayısını hesaplamak, tüm bu dönüş değerlerinin bir araya eklenmesiyle ilgili bir konudur.

Orchestrator işlevini uygulayan kod aşağıdadır:

const df = require("durable-functions");
const path = require("path");
const getFileListActivityName = "getFileList";
const copyFileToBlobActivityName = "copyFileToBlob";

df.app.orchestration("backupSiteContent", function* (context) {
    const rootDir = context.df.getInput();
    if (!rootDir) {
        throw new Error("A directory path is required as an input.");
    }

    const rootDirAbs = path.resolve(rootDir);
    const files = yield context.df.callActivity(getFileListActivityName, rootDirAbs);

    // Backup Files and save Tasks into array
    const tasks = [];
    for (const file of files) {
        const input = {
            backupPath: path.relative(rootDirAbs, file).replace("\\", "/"),
            filePath: file,
        };
        tasks.push(context.df.callActivity(copyFileToBlobActivityName, input));
    }

    // wait for all the Backup Files Activities to complete, sum total bytes
    const results = yield context.df.Task.all(tasks);
    const totalBytes = results ? results.reduce((prev, curr) => prev + curr, 0) : 0;

    // return results;
    return totalBytes;
});

Satıra yield context.df.Task.all(tasks); dikkat edin. İşleve copyFileToBlob yapılan tek tek tüm çağrılar , paralel olarak çalıştırılmasını sağlayan verim alınmadı. Bu görev dizisini öğesine context.df.Task.allgeçirdiğimizde, tüm kopyalama işlemleri tamamlanana kadar tamamlanmayacak bir görevi geri alacağız. JavaScript hakkında Promise.all bilgi sahibiyseniz, bu sizin için yeni değildir. Aradaki fark, bu görevlerin aynı anda birden çok sanal makinede çalışıyor olması ve Dayanıklı İşlevler uzantısının uçtan uca yürütmenin geri dönüşümü işlemeye dayanıklı olmasını sağlamasıdır.

Not

'den context.df.Task.allçıktıktan sonra, tüm işlev çağrılarının tamamlandığını ve değerleri bize geri döndürdüğünü biliyoruz. her çağrısı copyFileToBlob karşıya yüklenen bayt sayısını döndürür, bu nedenle toplam bayt sayısını hesaplamak, tüm bu dönüş değerlerinin bir araya eklenmesiyle ilgili bir konudur.

işlevi, düzenleyici işlevleri için standart function.json kullanır.

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "context",
      "type": "orchestrationTrigger",
      "direction": "in"
    }
  ]
}

Orchestrator işlevini uygulayan kod aşağıdadır:

import azure.functions as func
import azure.durable_functions as df


def orchestrator_function(context: df.DurableOrchestrationContext):

    root_directory: str = context.get_input()

    if not root_directory:
        raise Exception("A directory path is required as input")

    files = yield context.call_activity("E2_GetFileList", root_directory)
    tasks = []
    for file in files:
        tasks.append(context.call_activity("E2_CopyFileToBlob", file))
    
    results = yield context.task_all(tasks)
    total_bytes = sum(results)
    return total_bytes

main = df.Orchestrator.create(orchestrator_function)

Satıra yield context.task_all(tasks); dikkat edin. İşleve E2_CopyFileToBlob yapılan tek tek tüm çağrılar , paralel olarak çalıştırılmasını sağlayan verim alınmadı. Bu görev dizisini öğesine context.task_allgeçirdiğimizde, tüm kopyalama işlemleri tamamlanana kadar tamamlanmayacak bir görevi geri alacağız. Python hakkında asyncio.gather bilgi sahibiyseniz, bu sizin için yeni değildir. Aradaki fark, bu görevlerin aynı anda birden çok sanal makinede çalışıyor olması ve Dayanıklı İşlevler uzantısının uçtan uca yürütmenin geri dönüşümü işlemeye dayanıklı olmasını sağlamasıdır.

Not

Görevler kavramsal olarak Python beklenebilir özelliklerine benzer olsa da, orchestrator işlevlerinin görev paralelleştirmesini context.task_all yönetmek için ve context.task_any API'lerini kullanması yield gerekir.

'den context.task_allçıktıktan sonra, tüm işlev çağrılarının tamamlandığını ve değerleri bize geri döndürdüğünü biliyoruz. her çağrısı E2_CopyFileToBlob karşıya yüklenen bayt sayısını döndürür, böylece tüm dönüş değerlerini bir araya ekleyerek toplam bayt sayısını hesaplayabiliriz.

Yardımcı etkinlik işlevleri

Diğer örneklerde olduğu gibi yardımcı etkinlik işlevleri yalnızca tetikleyici bağlamasını activityTrigger kullanan normal işlevlerdir.

etkinlik işlevini E2_GetFileList

[FunctionName("E2_GetFileList")]
public static string[] GetFileList(
    [ActivityTrigger] string rootDirectory, 
    ILogger log)
{
    log.LogInformation($"Searching for files under '{rootDirectory}'...");
    string[] files = Directory.GetFiles(rootDirectory, "*", SearchOption.AllDirectories);
    log.LogInformation($"Found {files.Length} file(s) under {rootDirectory}.");

    return files;
}

için E2_GetFileList function.json dosyası aşağıdaki gibi görünür:

{
  "bindings": [
    {
      "name": "rootDirectory",
      "type": "activityTrigger",
      "direction": "in"
    }
  ],
  "disabled": false
}

Uygulama şu şekildedir:

const readdirp = require("readdirp");

module.exports = function (context, rootDirectory) {
    context.log(`Searching for files under '${rootDirectory}'...`);
    const allFilePaths = [];

    readdirp(
        { root: rootDirectory, entryType: "all" },
        function (fileInfo) {
            if (!fileInfo.stat.isDirectory()) {
                allFilePaths.push(fileInfo.fullPath);
            }
        },
        function (err, res) {
            if (err) {
                throw err;
            }

            context.log(`Found ${allFilePaths.length} under ${rootDirectory}.`);
            context.done(null, allFilePaths);
        }
    );
};

işlevi, dizin yapısını özyinelemeli olarak okumak için modülünü (sürüm 2.x) kullanır readdirp .

Etkinlik işlevinin uygulaması aşağıdadır getFileList :

const df = require("durable-functions");
const readdirp = require("readdirp");
const getFileListActivityName = "getFileList";

df.app.activity(getFileListActivityName, {
    handler: async function (rootDirectory, context) {
        context.log(`Searching for files under '${rootDirectory}'...`);

        const allFilePaths = [];
        for await (const entry of readdirp(rootDirectory, { type: "files" })) {
            allFilePaths.push(entry.fullPath);
        }
        context.log(`Found ${allFilePaths.length} under ${rootDirectory}.`);
        return allFilePaths;
    },
});

işlevi, dizin yapısını özyinelemeli olarak okumak için modülünü (sürüm3.x) kullanırreaddirp.

için E2_GetFileList function.json dosyası aşağıdaki gibi görünür:

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "rootDirectory",
      "type": "activityTrigger",
      "direction": "in"
    }
  ]
}

Uygulama şu şekildedir:

import os
from os.path import dirname
from typing import List

def main(rootDirectory: str) -> List[str]:

    all_file_paths = []
    # We walk the file system
    for path, _, files in os.walk(rootDirectory):
        # We copy the code for activities and orchestrators
        if "E2_" in path:
            # For each file, we add their full-path to the list
            for name in files:
                if name == "__init__.py" or name == "function.json":
                    file_path = os.path.join(path, name)
                    all_file_paths.append(file_path)
    
    return all_file_paths

Not

Bu kodu neden doğrudan orchestrator işlevine koyamadığınızı merak ediyor olabilirsiniz. Bunu yapabilirsiniz, ancak bu, düzenleyici işlevlerinin temel kurallarından birini bozar. Bu, yerel dosya sistemi erişimi de dahil olmak üzere hiçbir zaman G/Ç yapmaması gerektiğidir. Daha fazla bilgi için bkz . Orchestrator işlev kodu kısıtlamaları.

E2_CopyFileToBlob etkinlik işlevi

[FunctionName("E2_CopyFileToBlob")]
public static async Task<long> CopyFileToBlob(
    [ActivityTrigger] string filePath,
    Binder binder,
    ILogger log)
{
    long byteCount = new FileInfo(filePath).Length;

    // strip the drive letter prefix and convert to forward slashes
    string blobPath = filePath
        .Substring(Path.GetPathRoot(filePath).Length)
        .Replace('\\', '/');
    string outputLocation = $"backups/{blobPath}";

    log.LogInformation($"Copying '{filePath}' to '{outputLocation}'. Total bytes = {byteCount}.");

    // copy the file contents into a blob
    using (Stream source = File.Open(filePath, FileMode.Open, FileAccess.Read, FileShare.Read))
    using (Stream destination = await binder.BindAsync<CloudBlobStream>(
        new BlobAttribute(outputLocation, FileAccess.Write)))
    {
        await source.CopyToAsync(destination);
    }

    return byteCount;
}

Not

Örnek kodu çalıştırmak için NuGet paketini yüklemeniz Microsoft.Azure.WebJobs.Extensions.Storage gerekir.

İşlev, Azure İşlevleri bağlamalarının bazı gelişmiş özelliklerini (parametrenin Binderkullanımı) kullanır, ancak bu kılavuzun amacı için bu ayrıntılar hakkında endişelenmeniz gerekmez.

için E2_CopyFileToBlob function.json dosyası benzer şekilde basittir:

{
  "bindings": [
    {
      "name": "filePath",
      "type": "activityTrigger",
      "direction": "in"
    },
    {
      "name": "out",
      "type": "blob",
      "path": "",
      "connection": "AzureWebJobsStorage",
      "direction": "out"
    }
  ],
  "disabled": false
}

JavaScript uygulaması, dosyaları Azure Blob Depolama yüklemek için Node için Azure Depolama SDK'sını kullanır.

const fs = require("fs");
const path = require("path");
const storage = require("azure-storage");

module.exports = function (context, filePath) {
    const container = "backups";
    const root = path.parse(filePath).root;
    const blobPath = filePath.substring(root.length).replace("\\", "/");
    const outputLocation = `backups/${blobPath}`;
    const blobService = storage.createBlobService();

    blobService.createContainerIfNotExists(container, (error) => {
        if (error) {
            throw error;
        }

        fs.stat(filePath, function (error, stats) {
            if (error) {
                throw error;
            }
            context.log(
                `Copying '${filePath}' to '${outputLocation}'. Total bytes = ${stats.size}.`
            );

            const readStream = fs.createReadStream(filePath);

            blobService.createBlockBlobFromStream(
                container,
                blobPath,
                readStream,
                stats.size,
                function (error) {
                    if (error) {
                        throw error;
                    }

                    context.done(null, stats.size);
                }
            );
        });
    });
};

JavaScript copyFileToBlob uygulaması, dosyaları Azure Blob depolamaya yüklemek için bir Azure Depolama çıkış bağlaması kullanır.

const df = require("durable-functions");
const fs = require("fs/promises");
const { output } = require("@azure/functions");

const copyFileToBlobActivityName = "copyFileToBlob";

const blobOutput = output.storageBlob({
    path: "backups/{backupPath}",
    connection: "StorageConnString",
});

df.app.activity(copyFileToBlobActivityName, {
    extraOutputs: [blobOutput],
    handler: async function ({ backupPath, filePath }, context) {
        const outputLocation = `backups/${backupPath}`;
        const stats = await fs.stat(filePath);
        context.log(`Copying '${filePath}' to '${outputLocation}'. Total bytes = ${stats.size}.`);

        const fileContents = await fs.readFile(filePath);

        context.extraOutputs.set(blobOutput, fileContents);

        return stats.size;
    },
});

için E2_CopyFileToBlob function.json dosyası benzer şekilde basittir:

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "filePath",
      "type": "activityTrigger",
      "direction": "in"
    }
  ]
}

Python uygulaması, dosyaları Azure Blob Depolama yüklemek için Python için Azure Depolama SDK'sını kullanır.

import os
import pathlib
from azure.storage.blob import BlobServiceClient
from azure.core.exceptions import ResourceExistsError

connect_str = os.getenv('AzureWebJobsStorage')

def main(filePath: str) -> str:
    # Create the BlobServiceClient object which will be used to create a container client
    blob_service_client = BlobServiceClient.from_connection_string(connect_str)
    
    # Create a unique name for the container
    container_name = "backups"
    
    # Create the container if it does not exist
    try:
        blob_service_client.create_container(container_name)
    except ResourceExistsError:
        pass

    # Create a blob client using the local file name as the name for the blob
    parent_dir, fname = pathlib.Path(filePath).parts[-2:] # Get last two path components
    blob_name = parent_dir + "_" + fname
    blob_client = blob_service_client.get_blob_client(container=container_name, blob=blob_name)

    # Count bytes in file
    byte_count = os.path.getsize(filePath)

    # Upload the created file
    with open(filePath, "rb") as data:
        blob_client.upload_blob(data)

    return byte_count

Uygulama, dosyayı diskten yükler ve içeriği zaman uyumsuz olarak "yedeklemeler" kapsayıcısında aynı ada sahip bir bloba akışla aktarır. Dönüş değeri, depolama alanına kopyalanan bayt sayısıdır ve daha sonra orchestrator işlevi tarafından toplam toplamı hesaplamak için kullanılır.

Not

Bu, G/Ç işlemlerini bir işleve taşımanın mükemmel bir activityTrigger örneğidir. İş yalnızca birçok farklı makineye dağıtılamaz, aynı zamanda ilerleme durumunu denetlemenin avantajlarını da elde edersiniz. Konak işlemi herhangi bir nedenle sonlandırılırsa, hangi karşıya yüklemelerin zaten tamamlandığını biliyorsunuz.

Örneği çalıştırma

Windows'da aşağıdaki HTTP POST isteğini göndererek düzenlemeyi başlatabilirsiniz.

POST http://{host}/orchestrators/E2_BackupSiteContent
Content-Type: application/json
Content-Length: 20

"D:\\home\\LogFiles"

Alternatif olarak, bir Linux İşlev Uygulamasında (Python şu anda yalnızca App Service için Linux üzerinde çalıştırılır), düzenlemeyi şu şekilde başlatabilirsiniz:

POST http://{host}/orchestrators/E2_BackupSiteContent
Content-Type: application/json
Content-Length: 20

"/home/site/wwwroot"

Not

HttpStart Çağırdığınız işlev yalnızca JSON biçimli içerikle çalışır. Bu nedenle üst Content-Type: application/json bilgi gereklidir ve dizin yolu bir JSON dizesi olarak kodlanır. Ayrıca, HTTP kod parçacığı, dosyada tüm HTTP tetikleyici işlevleri URL'lerinden host.json varsayılan api/ ön eki kaldıran bir girdi olduğunu varsayar. Bu yapılandırma için işaretlemeyi örneklerdeki host.json dosyada bulabilirsiniz.

Bu HTTP isteği orchestrator'ı E2_BackupSiteContent tetikler ve dizeyi D:\home\LogFiles parametre olarak geçirir. Yanıt, yedekleme işleminin durumunu almak için bir bağlantı sağlar:

HTTP/1.1 202 Accepted
Content-Length: 719
Content-Type: application/json; charset=utf-8
Location: http://{host}/runtime/webhooks/durabletask/instances/b4e9bdcc435d460f8dc008115ff0a8a9?taskHub=DurableFunctionsHub&connection=Storage&code={systemKey}

(...trimmed...)

İşlev uygulamanızda kaç günlük dosyası bulunduğuna bağlı olarak, bu işlemin tamamlanması birkaç dakika sürebilir. Önceki HTTP 202 yanıtının üst bilgisindeki URL'yi Location sorgulayarak en son durumu alabilirsiniz.

GET http://{host}/runtime/webhooks/durabletask/instances/b4e9bdcc435d460f8dc008115ff0a8a9?taskHub=DurableFunctionsHub&connection=Storage&code={systemKey}

HTTP/1.1 202 Accepted
Content-Length: 148
Content-Type: application/json; charset=utf-8
Location: http://{host}/runtime/webhooks/durabletask/instances/b4e9bdcc435d460f8dc008115ff0a8a9?taskHub=DurableFunctionsHub&connection=Storage&code={systemKey}

{"runtimeStatus":"Running","input":"D:\\home\\LogFiles","output":null,"createdTime":"2019-06-29T18:50:55Z","lastUpdatedTime":"2019-06-29T18:51:16Z"}

Bu durumda işlev çalışmaya devam eder. Düzenleyici durumuna kaydedilen girişi ve son güncelleştirme zamanını görebilirsiniz. Tamamlanmak üzere yoklama yapmak için üst bilgi değerlerini kullanmaya Location devam edebilirsiniz. Durum "Tamamlandı" olduğunda, aşağıdakine benzer bir HTTP yanıt değeri görürsünüz:

HTTP/1.1 200 OK
Content-Length: 152
Content-Type: application/json; charset=utf-8

{"runtimeStatus":"Completed","input":"D:\\home\\LogFiles","output":452071,"createdTime":"2019-06-29T18:50:55Z","lastUpdatedTime":"2019-06-29T18:51:26Z"}

Artık düzenlemenin tamamlandığını ve tamamlanmasının yaklaşık ne kadar sürdüğünü görebilirsiniz. Ayrıca alan için output yaklaşık 450 KB günlük karşıya yüklendiğini gösteren bir değer görürsünüz.

Sonraki adımlar

Bu örnek, fan-out/fan-in deseninin nasıl uygulandığını göstermiştir. Sonraki örnek, dayanıklı zamanlayıcıları kullanarak monitör deseninin nasıl uygulanacaklarını gösterir.

İzleyici örneğini çalıştırma

Aracılığıyla paylaş

Dayanıklı İşlevler'de fan-out/fan-in senaryosu - Bulut yedekleme örneği

Önkoşullar

Senaryoya genel bakış

İşlevler

E2_BackupSiteContent orchestrator işlevi

Yardımcı etkinlik işlevleri

etkinlik işlevini E2_GetFileList

E2_CopyFileToBlob etkinlik işlevi

Örneği çalıştırma

Sonraki adımlar

Geri Bildirim

Ek kaynaklar