Scenariusze usługi Azure Functions

  • Artykuł

Często tworzymy systemy reagujące na serię zdarzeń krytycznych. Niezależnie od tego, czy tworzysz internetowy interfejs API, odpowiadasz na zmiany bazy danych, przetwarzasz strumienie zdarzeń lub komunikaty, usługa Azure Functions może służyć do ich implementowania.

W wielu przypadkach funkcja integruje się z szeregiem usług w chmurze w celu zapewnienia zaawansowanych funkcji implementacji. Poniżej przedstawiono typowy (ale w żaden sposób wyczerpujący) zestaw scenariuszy dla usługi Azure Functions.

Wybierz język programowania w górnej części artykułu.

Przetwarzanie przekazywania plików

Istnieje kilka sposobów użycia funkcji do przetwarzania plików w kontenerze magazynu obiektów blob lub poza nim. Aby dowiedzieć się więcej na temat opcji wyzwalania w kontenerze obiektów blob, zobacz Praca z obiektami blob w dokumentacji najlepszych rozwiązań.

Na przykład w rozwiązaniu handlu detalicznego system partnerski może przesyłać informacje o katalogu produktów jako pliki do magazynu obiektów blob. Za pomocą funkcji wyzwalanej przez obiekt blob można weryfikować, przekształcać i przetwarzać pliki w głównym systemie podczas ich przekazywania.

Diagram of a file upload process using Azure Functions.

Poniższe samouczki używają wyzwalacza usługi Event Grid do przetwarzania plików w kontenerze obiektów blob:

Na przykład użycie wyzwalacza obiektu blob z subskrypcją zdarzeń w kontenerach obiektów blob:

[FunctionName("ProcessCatalogData")]
public static async Task Run([BlobTrigger("catalog-uploads/{name}", Source = BlobTriggerSource.EventGrid, Connection = "<NAMED_STORAGE_CONNECTION>")]Stream myCatalogData, string name, ILogger log)
{
    log.LogInformation($"C# Blob trigger function Processed blob\n Name:{name} \n Size: {myCatalogData.Length} Bytes");

    using (var reader = new StreamReader(myCatalogData))
    {
        var catalogEntry = await reader.ReadLineAsync();
        while(catalogEntry !=null)
        {
            // Process the catalog entry
            // ...

            catalogEntry = await reader.ReadLineAsync();
        }
    }
}

Przesyłanie strumieniowe i przetwarzanie zdarzeń w czasie rzeczywistym

Tak wiele danych telemetrycznych jest generowanych i zbieranych z aplikacji w chmurze, urządzeń IoT i urządzeń sieciowych. Usługa Azure Functions może przetwarzać te dane niemal w czasie rzeczywistym jako ścieżkę gorącą, a następnie przechowywać je w usłudze Azure Cosmos DB do użycia na pulpicie nawigacyjnym analizy.

Funkcje mogą również używać wyzwalaczy zdarzeń o małych opóźnieniach, takich jak Event Grid, i danych wyjściowych czasu rzeczywistego, takich jak SignalR, do przetwarzania danych niemal w czasie rzeczywistym.

Diagram of a real-time stream process using Azure Functions.

Na przykład użycie wyzwalacza usługi Event Hubs do odczytu z centrum zdarzeń i powiązania wyjściowego w celu zapisu w centrum zdarzeń po debatowaniu i przekształcaniu zdarzeń:

[FunctionName("ProcessorFunction")]
public static async Task Run(
    [EventHubTrigger(
        "%Input_EH_Name%",
        Connection = "InputEventHubConnectionString",
        ConsumerGroup = "%Input_EH_ConsumerGroup%")] EventData[] inputMessages,
    [EventHub(
        "%Output_EH_Name%",
        Connection = "OutputEventHubConnectionString")] IAsyncCollector<SensorDataRecord> outputMessages,
    PartitionContext partitionContext,
    ILogger log)
{
    var debatcher = new Debatcher(log);
    var debatchedMessages = await debatcher.Debatch(inputMessages, partitionContext.PartitionId);

    var xformer = new Transformer(log);
    await xformer.Transform(debatchedMessages, partitionContext.PartitionId, outputMessages);
}

Uczenie maszynowe i AI

Oprócz przetwarzania danych usługa Azure Functions może służyć do wnioskowania na temat modeli.

Na przykład funkcja, która wywołuje model TensorFlow lub przesyła ją do usług Azure AI, może przetwarzać i klasyfikować strumień obrazów.

Funkcje mogą również łączyć się z innymi usługami, aby ułatwić przetwarzanie danych i wykonywanie innych zadań związanych ze sztuczną inteligencją, takich jak podsumowywanie tekstu.

Diagram of a machine learning and AI process using Azure Functions.

Uruchamianie zaplanowanych zadań

Funkcje umożliwiają uruchamianie kodu na podstawie zdefiniowanego harmonogramu cron.

Dowiedz się, jak utworzyć funkcję w witrynie Azure Portal, która jest uruchamiana zgodnie z harmonogramem.

Na przykład baza danych klienta usług finansowych może być analizowana pod kątem zduplikowanych wpisów co 15 minut, aby uniknąć komunikacji wychodzącej do tego samego klienta.

Diagram of a scheduled task where a function cleans a database every 15 minutes deduplicating entries based on business logic.

[FunctionName("TimerTriggerCSharp")]
public static void Run([TimerTrigger("0 */15 * * * *")]TimerInfo myTimer, ILogger log)
{
    if (myTimer.IsPastDue)
    {
        log.LogInformation("Timer is running late!");
    }
    log.LogInformation($"C# Timer trigger function executed at: {DateTime.Now}");

    // Perform the database deduplication
}

Tworzenie skalowalnego internetowego interfejsu API

Funkcja wyzwalana przez protokół HTTP definiuje punkt końcowy HTTP. Te punkty końcowe uruchamiają kod funkcji, który może łączyć się z innymi usługami bezpośrednio lub przy użyciu rozszerzeń powiązań. Punkty końcowe można tworzyć w internetowym interfejsie API.

Możesz również użyć punktu końcowego funkcji wyzwalanej przez protokół HTTP jako integracji elementu webhook, takiego jak elementy webhook usługi GitHub. W ten sposób można tworzyć funkcje przetwarzające dane ze zdarzeń usługi GitHub. Aby dowiedzieć się więcej, zobacz Monitorowanie zdarzeń usługi GitHub przy użyciu elementu webhook w usłudze Azure Functions.

Diagram of processing an HTTP request using Azure Functions.

Przykłady można znaleźć w następujących tematach:

[FunctionName("InsertName")]
public static async Task<IActionResult> Run(
    [HttpTrigger(AuthorizationLevel.Function, "post")] HttpRequest req,
    [CosmosDB(
        databaseName: "my-database",
        collectionName: "my-container",
        ConnectionStringSetting = "CosmosDbConnectionString")]IAsyncCollector<dynamic> documentsOut,
    ILogger log)
{
    string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
    dynamic data = JsonConvert.DeserializeObject(requestBody);
    string name = data?.name;

    if (name == null)
    {
        return new BadRequestObjectResult("Please pass a name in the request body json");
    }

    // Add a JSON document to the output container.
    await documentsOut.AddAsync(new
    {
        // create a random ID
        id = System.Guid.NewGuid().ToString(), 
        name = name
    });

    return new OkResult();
}

Tworzenie bezserwerowego przepływu pracy

Funkcje są często składnikiem obliczeniowym w topologii przepływu pracy bezserwerowego, takiego jak przepływ pracy usługi Logic Apps. Można również tworzyć długotrwałe aranżacje przy użyciu rozszerzenia Durable Functions. Aby uzyskać więcej informacji, zobacz Durable Functions overview (Omówienie rozszerzenia Durable Functions).

A combination diagram of a series of specific serverless workflows using Azure Functions.

Reagowanie na zmiany bazy danych

Istnieją procesy, w których może być konieczne rejestrowanie, inspekcja lub wykonywanie innych operacji podczas przechowywania zmian danych. Wyzwalacze funkcji zapewniają dobry sposób otrzymywania powiadomień o zmianach danych w celu zainicjowania takiej operacji.

Diagram of a function being used to respond to database changes.

Rozważ następujące przykłady:

Tworzenie niezawodnych systemów komunikatów

Usługi Functions z usługami obsługi komunikatów platformy Azure umożliwiają tworzenie zaawansowanych rozwiązań do obsługi komunikatów opartych na zdarzeniach.

Można na przykład użyć wyzwalaczy w kolejkach usługi Azure Storage jako sposobu łączenia szeregu wykonań funkcji. Możesz też użyć kolejek i wyzwalaczy usługi Service Bus dla systemu zamawiania online.

Diagram of Azure Functions in a reliable message system.

W poniższym artykule pokazano, jak zapisywać dane wyjściowe w kolejce magazynu.

W tych artykułach pokazano, jak wyzwalać z kolejki lub tematu usługi Azure Service Bus.

Następne kroki

Wprowadzenie do usługi Azure Functions