Azure Functions verbinden met Azure Storage met behulp van opdrachtregelhulpprogramma's

Voordat u begint, moet u het volgende artikel voltooien: Quickstart: een Azure Functions-project maken via de opdrachtregel. Als u de resources na voltooiing van dat artikel al had opgeruimd, doorloopt u de stappen voor het maken van de functie-app en de bijbehorende resources opnieuw in Azure.

Voordat u begint, moet u het volgende artikel voltooien: Quickstart: een Azure Functions-project maken via de opdrachtregel. Als u de resources na voltooiing van dat artikel al had opgeruimd, doorloopt u de stappen voor het maken van de functie-app en de bijbehorende resources opnieuw in Azure.

Voordat u begint, moet u het volgende artikel voltooien: Quickstart: een Azure Functions-project maken via de opdrachtregel. Als u de resources na voltooiing van dat artikel al had opgeruimd, doorloopt u de stappen voor het maken van de functie-app en de bijbehorende resources opnieuw in Azure.

Voordat u begint, moet u het volgende artikel voltooien: Quickstart: een Azure Functions-project maken via de opdrachtregel. Als u de resources na voltooiing van dat artikel al had opgeruimd, doorloopt u de stappen voor het maken van de functie-app en de bijbehorende resources opnieuw in Azure.

Voordat u begint, moet u het volgende artikel voltooien: Quickstart: een Azure Functions-project maken via de opdrachtregel. Als u de resources na voltooiing van dat artikel al had opgeruimd, doorloopt u de stappen voor het maken van de functie-app en de bijbehorende resources opnieuw in Azure.

Voordat u begint, moet u het volgende artikel voltooien: Quickstart: een Azure Functions-project maken via de opdrachtregel. Als u de resources na voltooiing van dat artikel al had opgeruimd, doorloopt u de stappen voor het maken van de functie-app en de bijbehorende resources opnieuw in Azure.

Binding-extensies registreren

Met uitzondering van HTTP- en timertriggers worden bindingen geïmplementeerd als uitbreidingspakketten. Voer de volgende dotnet add package-opdracht in het terminalvenster uit om het Storage-extensiepakket toe te voegen aan uw project.

dotnet add package Microsoft.Azure.WebJobs.Extensions.Storage 

dotnet add package Microsoft.Azure.Functions.Worker.Extensions.Storage.Queues --prerelease

Nu kunt u de Storage-uitvoerbinding toevoegen aan uw project.

Een definitie van een uitvoerbinding toevoegen aan de functie

Hoewel een functie slechts één trigger kan hebben, kan deze meerdere in- en uitvoerbindingen hebben, zodat u verbinding kunt maken met andere Azure-services en -resources zonder dat u aangepaste integratiecode hoeft te schrijven.

U declareert deze bindingen in het bestand function.json in de map function. Door de vorige quickstart bevat uw bestand function.json in de map HttpExample twee bindingen in de verzameling bindings:

"bindings": [
    {
        "authLevel": "function",
        "type": "httpTrigger",
        "direction": "in",
        "name": "req",
        "methods": [
            "get",
            "post"
        ]
    },
    {
        "type": "http",
        "direction": "out",
        "name": "res"
    }
]

"scriptFile": "__init__.py",
"bindings": [
    {
        "authLevel": "function",
        "type": "httpTrigger",
        "direction": "in",
        "name": "req",
        "methods": [
            "get",
            "post"
        ]
    },
    {
        "type": "http",
        "direction": "out",
        "name": "$return"
    }

"bindings": [
  {
    "authLevel": "function",
    "type": "httpTrigger",
    "direction": "in",
    "name": "Request",
    "methods": [
      "get",
      "post"
    ]
  },
  {
    "type": "http",
    "direction": "out",
    "name": "Response"
  }
]

Elke binding heeft ten minste een type, een richting en een naam. In het bovenstaande voorbeeld heeft de eerste binding het type httpTrigger en de richting in. Voor de richting in is name de naam van een invoerparameter die naar de functie wordt verzonden wanneer deze wordt aangeroepen door de trigger.

De tweede binding in de verzameling heeft de naam res. Deze http-binding is een uitvoerbinding (out) die wordt gebruikt voor het schrijven van het HTTP-antwoord.

Als u vanuit deze functie naar een Azure Storage-wachtrij wilt schrijven, voegt u een out-binding van het type queue met de naam msg toe, zoals wordt weergegeven in de onderstaande code:

    {
      "authLevel": "function",
      "type": "httpTrigger",
      "direction": "in",
      "name": "req",
      "methods": [
        "get",
        "post"
      ]
    },
    {
      "type": "http",
      "direction": "out",
      "name": "res"
    },
    {
      "type": "queue",
      "direction": "out",
      "name": "msg",
      "queueName": "outqueue",
      "connection": "AzureWebJobsStorage"
    }
  ]
}

De tweede binding in de verzameling heeft het type http en de richting out, in welk geval de speciale name van $return aangeeft dat deze binding de retourwaarde van de functie gebruikt in plaats van een invoerparameter aan te leveren.

Als u vanuit deze functie naar een Azure Storage-wachtrij wilt schrijven, voegt u een out-binding van het type queue met de naam msg toe, zoals wordt weergegeven in de onderstaande code:

"bindings": [
  {
    "authLevel": "anonymous",
    "type": "httpTrigger",
    "direction": "in",
    "name": "req",
    "methods": [
      "get",
      "post"
    ]
  },
  {
    "type": "http",
    "direction": "out",
    "name": "$return"
  },
  {
    "type": "queue",
    "direction": "out",
    "name": "msg",
    "queueName": "outqueue",
    "connection": "AzureWebJobsStorage"
  }
]

De tweede binding in de verzameling heeft de naam res. Deze http-binding is een uitvoerbinding (out) die wordt gebruikt voor het schrijven van het HTTP-antwoord.

Als u vanuit deze functie naar een Azure Storage-wachtrij wilt schrijven, voegt u een out-binding van het type queue met de naam msg toe, zoals wordt weergegeven in de onderstaande code:

    {
      "authLevel": "function",
      "type": "httpTrigger",
      "direction": "in",
      "name": "Request",
      "methods": [
        "get",
        "post"
      ]
    },
    {
      "type": "http",
      "direction": "out",
      "name": "Response"
    },
    {
      "type": "queue",
      "direction": "out",
      "name": "msg",
      "queueName": "outqueue",
      "connection": "AzureWebJobsStorage"
    }
  ]
}

In dit geval wordt msg als uitvoerargument aan de functie doorgegeven. Voor een binding van het type queue moet u ook de naam van de wachtrij opgeven in queueName en de naam van de Azure Storage-verbinding (uit local.settings.json) in connection opgeven.

In een C#-project worden de bindingen gedefinieerd als bindingskenmerken in de functiemethode. Specifieke definities zijn afhankelijk van of uw app wordt uitgevoerd in-process (C#-klassebibliotheek) of in een geïsoleerd proces.

[Queue("outqueue"),StorageAccount("AzureWebJobsStorage")] ICollector<string> msg,

[FunctionName("HttpExample")]
public static async Task<IActionResult> Run(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req, 
    [Queue("outqueue"),StorageAccount("AzureWebJobsStorage")] ICollector<string> msg, 
    ILogger log)

public class MultiResponse
{
    [QueueOutput("outqueue",Connection = "AzureWebJobsStorage")]
    public string[] Messages { get; set; }
    public HttpResponseData HttpResponse { get; set; }
}

In een Java-project worden de bindingen gedefinieerd als bindingsaantekeningen in de functiemethode. Het bestand function.json wordt vervolgens automatisch gegenereerd op basis van deze aantekeningen.

Blader naar de locatie van de functiecode onder src/main/java, open het projectbestand Function.java en voeg de volgende parameter aan de methodedefinitie run toe:

@QueueOutput(name = "msg", queueName = "outqueue", connection = "AzureWebJobsStorage") OutputBinding<String> msg

Parameter msg is van het type OutputBinding<T>, dat een verzameling berichten voorstelt die naar een uitvoerbinding wordt geschreven wanneer de functie is voltooid. In dit geval is de uitvoer een opslagwachtrij met de naam outqueue. De verbindingsreeks voor het Storage-account wordt ingesteld door de methode connection. In plaats van de verbindingsreeks zelf, geeft u de toepassingsinstelling door die de verbindingsreeks voor het Storage-account bevat.

De methodedefinitie run moet er nu uitzien als in het volgende voorbeeld:

@FunctionName("HttpTrigger-Java")
public HttpResponseMessage run(
        @HttpTrigger(name = "req", methods = {HttpMethod.GET, HttpMethod.POST}, authLevel = AuthorizationLevel.FUNCTION)  
        HttpRequestMessage<Optional<String>> request, 
        @QueueOutput(name = "msg", queueName = "outqueue", connection = "AzureWebJobsStorage") 
        OutputBinding<String> msg, final ExecutionContext context) {
    ...
}

Werkt HttpExample\__init__.py bij om overeen te komen met de volgende code en voeg de parameter msg toe aan de functiedefinitie en msg.set(name) onder de instructie if name:.

import logging

import azure.functions as func


def main(req: func.HttpRequest, msg: func.Out[func.QueueMessage]) -> str:

    name = req.params.get('name')
    if not name:
        try:
            req_body = req.get_json()
        except ValueError:
            pass
        else:
            name = req_body.get('name')

    if name:
        msg.set(name)
        return func.HttpResponse(f"Hello {name}!")
    else:
        return func.HttpResponse(
            "Please pass a name on the query string or in the request body",
            status_code=400
        )

De parameter msg is een instantie van de azure.functions.Out class. De methode set schrijft een tekenreeksbericht naar de wachtrij, in dit geval de naam die aan de functie is doorgegeven in de URL-querytekenreeks.

Voeg code toe die het bindingsobject van de uitvoer msg in context.bindings gebruikt om een wachtrijbericht te maken. Voeg deze code toe vóór de instructie context.res.

// Add a message to the Storage queue,
// which is the name passed to the function.
context.bindings.msg = (req.query.name || req.body.name);

Op dit moment moet uw functie er als volgt uit zien:

module.exports = async function (context, req) {
    context.log('JavaScript HTTP trigger function processed a request.');

    if (req.query.name || (req.body && req.body.name)) {
        // Add a message to the Storage queue,
        // which is the name passed to the function.
        context.bindings.msg = (req.query.name || req.body.name);
        context.res = {
            // status: 200, /* Defaults to 200 */
            body: "Hello " + (req.query.name || req.body.name)
        };
    }
    else {
        context.res = {
            status: 400,
            body: "Please pass a name on the query string or in the request body"
        };
    }
};

Voeg code toe die het bindingsobject van de uitvoer msg in context.bindings gebruikt om een wachtrijbericht te maken. Voeg deze code toe vóór de instructie context.res.

context.bindings.msg = name;

Op dit moment moet uw functie er als volgt uit zien:

import { AzureFunction, Context, HttpRequest } from "@azure/functions"

const httpTrigger: AzureFunction = async function (context: Context, req: HttpRequest): Promise<void> {
    context.log('HTTP trigger function processed a request.');
    const name = (req.query.name || (req.body && req.body.name));

    if (name) {
        // Add a message to the storage queue, 
        // which is the name passed to the function.
        context.bindings.msg = name; 
        // Send a "hello" response.
        context.res = {
            // status: 200, /* Defaults to 200 */
            body: "Hello " + (req.query.name || req.body.name)
        };
    }
    else {
        context.res = {
            status: 400,
            body: "Please pass a name on the query string or in the request body"
        };
    }
};

export default httpTrigger;

Voeg code toe die gebruikmaakt van de cmdlet Push-OutputBinding om tekst te schrijven naar de wachtrij met de uitvoerbinding msg. Voeg deze code toe voordat u de status Ok in de instructie if instelt.

$outputMsg = $name
Push-OutputBinding -name msg -Value $outputMsg

Op dit moment moet uw functie er als volgt uit zien:

using namespace System.Net

# Input bindings are passed in via param block.
param($Request, $TriggerMetadata)

# Write to the Azure Functions log stream.
Write-Host "PowerShell HTTP trigger function processed a request."

# Interact with query parameters or the body of the request.
$name = $Request.Query.Name
if (-not $name) {
    $name = $Request.Body.Name
}

if ($name) {
    # Write the $name value to the queue, 
    # which is the name passed to the function.
    $outputMsg = $name
    Push-OutputBinding -name msg -Value $outputMsg

    $status = [HttpStatusCode]::OK
    $body = "Hello $name"
}
else {
    $status = [HttpStatusCode]::BadRequest
    $body = "Please pass a name on the query string or in the request body."
}

# Associate values to output bindings by calling 'Push-OutputBinding'.
Push-OutputBinding -Name Response -Value ([HttpResponseContext]@{
    StatusCode = $status
    Body = $body
})

U kunt nu de nieuwe parameter, msg, gebruiken om naar de uitvoerbinding van uw functiecode te schrijven. Voordat u het antwoord krijgt dat de bewerking is geslaagd, voegt u de volgende regel code toe om de waarde van name aan de msg-uitvoerbinding toe te voegen.

msg.setValue(name);

Als u een uitvoerbinding gebruikt, hoeft u niet de Azure Storage SDK-code voor verificatie te gebruiken, een wachtrijverwijzing op te halen of gegevens te schrijven. Deze taken worden voor u verwerkt via Functions-runtime en Queue Storage-uitvoerbinding.

De methode run moet er nu uitzien als in het volgende voorbeeld:

public HttpResponseMessage run(
        @HttpTrigger(name = "req", methods = {HttpMethod.GET, HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS) 
        HttpRequestMessage<Optional<String>> request, 
        @QueueOutput(name = "msg", queueName = "outqueue", 
        connection = "AzureWebJobsStorage") OutputBinding<String> msg, 
        final ExecutionContext context) {
    context.getLogger().info("Java HTTP trigger processed a request.");

    // Parse query parameter
    String query = request.getQueryParameters().get("name");
    String name = request.getBody().orElse(query);

    if (name == null) {
        return request.createResponseBuilder(HttpStatus.BAD_REQUEST)
        .body("Please pass a name on the query string or in the request body").build();
    } else {
        // Write the name to the message queue. 
        msg.setValue(name);

        return request.createResponseBuilder(HttpStatus.OK).body("Hello, " + name).build();
    }
}

De tests bijwerken

Omdat het archetype ook een reeks tests maakt, moet u deze tests bijwerken om de nieuwe parameter msg in de handtekening van methode run te verwerken.

Blader naar de locatie van de testcode onder src/test/java, open projectbestand Function.java en vervang de regel met code onder //Invoke door de volgende code.

@SuppressWarnings("unchecked")
final OutputBinding<String> msg = (OutputBinding<String>)mock(OutputBinding.class);
final HttpResponseMessage ret = new Function().run(req, msg, context);

Gebruik in de map LocalFunctionsProj de opdracht func azure functionapp publish om het project opnieuw te implementeren, waarbij u <APP_NAME> vervangt door de naam van uw app.

func azure functionapp publish <APP_NAME>

Gebruik in de lokale projectmap de volgende Maven-opdracht om het project opnieuw te publiceren:

mvn azure-functions:deploy

• Voorbeelden van complete Function-projecten in C#.

• Naslaginformatie over Azure Functions C# voor ontwikkelaars

• Voorbeelden van complete Function-projecten in Javascript.

• Ontwikkelaarshandleiding voor Azure Functions Javascript

• Voorbeelden van complete Function-projecten in TypeScript.

• Ontwikkelaarshandleiding voor Azure Functions TypeScript

• Voorbeelden van complete Function-projecten in Python.

• Ontwikkelaarshandleiding voor Azure Functions Python

• Voorbeelden van complete Function-projecten in PowerShell.

• Ontwikkelaarshandleiding voor Azure Functions PowerShell