Bagikan melalui

Dapr Memanggil pengikatan output untuk Azure Functions

  • Artikel

Pengikatan output pemanggilan Dapr memungkinkan Anda memanggil aplikasi Dapr lain selama eksekusi fungsi.

Untuk informasi tentang penyiapan dan detail konfigurasi ekstensi Dapr, lihat gambaran umum ekstensi Dapr.

Contoh

Fungsi C# dapat dibuat menggunakan salah satu mode C# berikut:

Model eksekusi Deskripsi
Model pekerja terisolasi Kode fungsi Anda berjalan dalam proses pekerja .NET terpisah. Gunakan dengan versi .NET dan .NET Framework yang didukung. Untuk mempelajari lebih lanjut, lihat Mengembangkan fungsi proses pekerja terisolasi .NET.
Model dalam proses Kode fungsi Anda berjalan dalam proses yang sama dengan proses host Azure Functions. Hanya mendukung versi Dukungan Jangka Panjang (LTS) .NET. Untuk mempelajari lebih lanjut, lihat Mengembangkan fungsi pustaka kelas .NET.

Contoh berikut menunjukkan penggunaan pengikatan output pemanggilan Dapr untuk melakukan operasi pemanggilan layanan Dapr yang dihosting di aplikasi berukuran Dapr lain. Dalam contoh ini, fungsi bertindak seperti proksi.

[FunctionName("InvokeOutputBinding")]
public static async Task<IActionResult> Run(
    [HttpTrigger(AuthorizationLevel.Function, "get", Route = "invoke/{appId}/{methodName}")] HttpRequest req,
    [DaprInvoke(AppId = "{appId}", MethodName = "{methodName}", HttpVerb = "post")] IAsyncCollector<InvokeMethodParameters> output,
    ILogger log)
{
    log.LogInformation("C# HTTP trigger function processed a request.");

    string requestBody = await new StreamReader(req.Body).ReadToEndAsync();

    var outputContent = new InvokeMethodParameters
    {
        Body = requestBody
    };

    await output.AddAsync(outputContent);

    return new OkResult();
}

Contoh berikut membuat "InvokeOutputBinding" fungsi menggunakan pengikatan DaprInvokeOutput dengan HttpTrigger:

@FunctionName("InvokeOutputBinding")
public String run(
        @HttpTrigger(
            name = "req",
            methods = {HttpMethod.GET, HttpMethod.POST},
            authLevel = AuthorizationLevel.ANONYMOUS,
            route = "invoke/{appId}/{methodName}")
            HttpRequestMessage<Optional<String>> request,
        @DaprInvokeOutput(
            appId = "{appId}", 
            methodName = "{methodName}", 
            httpVerb = "post")
        OutputBinding<String> payload,
        final ExecutionContext context)

Dalam contoh berikut, pengikatan output pemanggilan Dapr dipasangkan dengan pemicu HTTP, yang didaftarkan oleh app objek:

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

app.generic('InvokeOutputBinding', {
    trigger: trigger.generic({
        type: 'httpTrigger',
        authLevel: 'anonymous',
        methods: ['POST'],
        route: "invoke/{appId}/{methodName}",
        name: "req"
    }),
    return: daprInvokeOutput,
    handler: async (request, context) => {
        context.log("Node HTTP trigger function processed a request.");

        const payload = await request.text();
        context.log(JSON.stringify(payload));

        return { body: payload };
    }
});

Contoh berikut menunjukkan pemicu Dapr dalam file function.json dan kode PowerShell yang menggunakan pengikatan tersebut.

Berikut adalah file function.json untuk daprInvoke:

{
  "bindings":
    {
      "type": "daprInvoke",
      "direction": "out",
      "appId": "{appId}",
      "methodName": "{methodName}",
      "httpVerb": "post",
      "name": "payload"
    }
}

Untuk informasi selengkapnya tentang properti file function.json , lihat bagian Konfigurasi .

Dalam kode:

using namespace System.Net

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

# Write to the Azure Functions log stream.
Write-Host "Powershell InvokeOutputBinding processed a request."

$req_body = $req.Body

$invoke_output_binding_req_body = @{
    "body" = $req_body
}

# Associate values to output bindings by calling 'Push-OutputBinding'.
Push-OutputBinding -Name payload -Value $invoke_output_binding_req_body

Push-OutputBinding -Name res -Value ([HttpResponseContext]@{
    StatusCode = [HttpStatusCode]::OK
    Body = $req_body
})

Contoh berikut menunjukkan pengikatan output Dapr Invoke, yang menggunakan model pemrograman Python v2. Untuk digunakan daprInvoke dalam kode aplikasi fungsi Python Anda:

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="InvokeOutputBinding")
@app.route(route="invoke/{appId}/{methodName}", auth_level=dapp.auth_level.ANONYMOUS)
@app.dapr_invoke_output(arg_name = "payload", app_id = "{appId}", method_name = "{methodName}", http_verb = "post")
def main(req: func.HttpRequest, payload: func.Out[str] ) -> str:
    # request body must be passed this way "{\"body\":{\"value\":{\"key\":\"some value\"}}}" to use the InvokeOutputBinding, all the data must be enclosed in body property.
    logging.info('Python function processed a InvokeOutputBinding request from the Dapr Runtime.')

    body = req.get_body()
    logging.info(body)
    if body is not None:
        payload.set(body)
    else:
        logging.info('req body is none')
    return 'ok'

Atribut

Dalam model dalam proses, gunakan DaprInvoke atribut untuk menentukan pengikatan output pemanggilan Dapr, yang mendukung parameter ini:

Parameter Deskripsi Dapat dikirim melalui Atribut Dapat dikirim melalui RequestBody
AppId ID aplikasi Dapr untuk dipanggil. ✔️ ✔️
MethodName Nama metode aplikasi yang akan dipanggil. ✔️ ✔️
HttpVerb Opsional. Kata kerja HTTP untuk menggunakan aplikasi untuk dipanggil. Defaultnya adalah POST. ✔️ ✔️
Isi Harus diisi. Isi permintaan. ❌ ✔️

Anotasi

Anotasi DaprInvokeOutput memungkinkan Anda untuk memanggil fungsi Anda dan mendengarkan pengikatan output.

Elemen Deskripsi Dapat dikirim melalui Atribut Dapat dikirim melalui RequestBody
appId ID aplikasi aplikasi yang terlibat dalam pengikatan pemanggilan. ✔️ ✔️
methodName Nama variabel metode. ✔️ ✔️
httpVerb Posting atau dapatkan. ✔️ ✔️
body Harus diisi. Isi permintaan. ❌ ✔️

Konfigurasi

Tabel berikut menjelaskan properti konfigurasi pengikatan yang Anda tetapkan dalam kode.

Properti Deskripsi Dapat dikirim melalui Atribut Dapat dikirim melalui RequestBody
appId ID aplikasi aplikasi yang terlibat dalam pengikatan pemanggilan. ✔️ ✔️
metode Posting atau dapatkan. ✔️ ✔️
body Harus diisi. Isi permintaan. ❌ ✔️

Tabel berikut menjelaskan properti konfigurasi pengikatan yang Anda atur di file function.json.

Properti function.json Deskripsi Dapat dikirim melalui Atribut Dapat dikirim melalui RequestBody
appId ID aplikasi aplikasi yang terlibat dalam pengikatan pemanggilan. ✔️ ✔️
methodName Nama variabel metode. ✔️ ✔️
httpVerb Posting atau dapatkan. ✔️ ✔️
body Harus diisi. Isi permintaan. ❌ ✔️

Tabel berikut menjelaskan properti konfigurasi pengikatan untuk @dapp.dapr_invoke_output yang Anda tetapkan dalam kode Python Anda.

Properti Deskripsi Dapat dikirim melalui Atribut Dapat dikirim melalui RequestBody
app_id ID aplikasi aplikasi yang terlibat dalam pengikatan pemanggilan. ✔️ ✔️
method_name Nama variabel metode. ✔️ ✔️
http_verb Atur ke post atau get. ✔️ ✔️
body Harus diisi. Isi permintaan. ❌ ✔️

Jika properti didefinisikan dalam Atribut dan RequestBody, prioritas diberikan ke data yang disediakan dalam RequestBody.

Lihat Bagian contoh untuk contoh lengkapnya.

Penggunaan

Untuk menggunakan pengikatan output pemanggilan layanan Dapr, pelajari lebih lanjut cara menggunakan pemanggilan layanan Dapr dalam dokumentasi Dapr resmi.

Untuk menggunakan daprInvoke di Python v2, siapkan proyek Anda dengan dependensi yang benar.

  1. Membuat dan mengaktifkan lingkungan virtual.

  2. Di file Anda requirements.text , tambahkan baris berikut:

    azure-functions==1.18.0b3

  3. Di terminal, instal pustaka Python.

    pip install -r .\requirements.txt

  4. Ubah file Anda local.setting.json dengan konfigurasi berikut:

    "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1

Langkah berikutnya

Pelajari lebih lanjut tentang pemanggilan layanan Dapr.