Správa připojení ve službě Azure Functions

Tady je příklad kódu funkce jazyka C#, který vytvoří statickou instanci HttpClient :

// Create a single, static HttpClient
private static HttpClient httpClient = new HttpClient();

public static async Task Run(string input)
{
    var response = await httpClient.GetAsync("https://example.com");
    // Rest of function
}

Běžnou otázkou týkající se HttpClient v .NET je "Mám odstranit klienta?" Obecně platí, že odstraníte objekty, které implementují IDisposable , když je použijete. Statického klienta ale nelikvidujete, protože ho nepoužíváte, když funkce skončí. Chcete, aby statický klient žil po dobu trvání vaší aplikace.

Vzhledem k tomu, že poskytuje lepší možnosti správy připojení, měli byste místo ne nativních metod, jako node-fetch je modul, použít nativní http.agent třídu. Parametry připojení se konfigurují prostřednictvím možností ve http.agent třídě. Podrobné možnosti dostupné pro agenta HTTP najdete v tématu nový agent([možnosti]).

Globální http.globalAgent třída, kterou http.request() používá, má všechny tyto hodnoty nastavené na jejich odpovídající výchozí hodnoty. Doporučeným způsobem konfigurace limitů připojení ve službě Functions je nastavení maximálního počtu globálně. Následující příklad nastaví maximální počet soketů pro aplikaci funkcí:

http.globalAgent.maxSockets = 200;

Následující příklad vytvoří nový požadavek HTTP s vlastním agentem HTTP pouze pro tento požadavek:

var http = require('http');
var httpAgent = new http.Agent();
httpAgent.maxSockets = 200;
const options = { agent: httpAgent };
http.request(options, onResponseCallback);

CosmosClient se připojuje k instanci služby Azure Cosmos DB. Dokumentace ke službě Azure Cosmos DB doporučuje používat jednoúčelového klienta Azure Cosmos DB po celou dobu životnosti vaší aplikace. Následující příklad ukazuje jeden vzor pro to ve funkci:

#r "Microsoft.Azure.Cosmos"
using Microsoft.Azure.Cosmos;

private static Lazy<CosmosClient> lazyClient = new Lazy<CosmosClient>(InitializeCosmosClient);
private static CosmosClient cosmosClient => lazyClient.Value;

private static CosmosClient InitializeCosmosClient()
{
    // Perform any initialization here
    var uri = "https://youraccount.documents.azure.com:443";
    var authKey = "authKey";
   
    return new CosmosClient(uri, authKey);
}

public static async Task Run(string input)
{
    Container container = cosmosClient.GetContainer("database", "collection");
    MyItem item = new MyItem{ id = "myId", partitionKey = "myPartitionKey", data = "example" };
    await container.UpsertItemAsync(document);
   
    // Rest of function
}

Vytvořte také soubor s názvem function.proj pro trigger a přidejte následující obsah:

<Project Sdk="Microsoft.NET.Sdk">
    <PropertyGroup>
        <TargetFramework>netcoreapp3.1</TargetFramework>
    </PropertyGroup>
    <ItemGroup>
        <PackageReference Include="Microsoft.Azure.Cosmos" Version="3.23.0" />
    </ItemGroup>
</Project>

CosmosClient se připojuje k instanci služby Azure Cosmos DB. Dokumentace ke službě Azure Cosmos DB doporučuje používat jednoúčelového klienta Azure Cosmos DB po celou dobu životnosti vaší aplikace. Následující příklad ukazuje jeden vzor pro to ve funkci:

const cosmos = require('@azure/cosmos');
const endpoint = process.env.COSMOS_API_URL;
const key = process.env.COSMOS_API_KEY;
const { CosmosClient } = cosmos;

const client = new CosmosClient({ endpoint, key });
// All function invocations also reference the same database and container.
const container = client.database("MyDatabaseName").container("MyContainerName");

module.exports = async function (context) {
    const { resources: itemArray } = await container.items.readAll().fetchAll();
    context.log(itemArray);
}