Bagikan melalui

Pengikatan output Pengikatan Dapr untuk Azure Functions

Pengikatan output Dapr memungkinkan Anda mengirim nilai ke pengikatan output Dapr selama eksekusi fungsi.

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

Example

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

Execution model Description
Model pekerja terisolasi Kode fungsi Anda berjalan dalam proses pekerja .NET terpisah. Gunakan dengan versi .NET dan .NET Framework yang didukung. Untuk mempelajari selengkapnya, lihat Panduan untuk menjalankan C# Azure Functions dalam model pekerja yang terisolasi.
In-process model 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 C# dengan menggunakan Azure Functions.

Contoh berikut menunjukkan penggunaan pemicu pemanggilan layanan Dapr dan pengikatan output Dapr untuk membaca dan memproses permintaan pengikatan.

[FunctionName("SendMessageToKafka")]
public static async Task Run(
    [DaprServiceInvocationTrigger] JObject payload,
    [DaprBinding(BindingName = "%KafkaBindingName%", Operation = "create")] IAsyncCollector<object> messages,
    ILogger log)
{
    log.LogInformation("C#  function processed a SendMessageToKafka request.");
    await messages.AddAsync(payload);
}

Contoh berikut membuat "SendMessageToKafka" fungsi menggunakan pengikatan DaprBindingOutput dengan DaprServiceInvocationTrigger:

@FunctionName("SendMessageToKafka")
public String run(
        @DaprServiceInvocationTrigger(
            methodName = "SendMessageToKafka") 
        String payload,
        @DaprBindingOutput(
            bindingName = "%KafkaBindingName%", 
            operation = "create")
        OutputBinding<String> product,
        final ExecutionContext context) {
    context.getLogger().info("Java  function processed a SendMessageToKafka request.");
    product.setValue(payload);

    return payload;
}

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

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

app.generic('SendMessageToKafka', {
    trigger: trigger.generic({
        type: 'daprServiceInvocationTrigger',
        name: "payload"
    }),
    return: daprBindingOutput,
    handler: async (request, context) => {
        context.log("Node function processed a SendMessageToKafka request from the Dapr Runtime.");
        context.log(context.triggerMetadata.payload)

        return { "data": context.triggerMetadata.payload };
    }
});

The following examples show Dapr triggers in a function.json file and PowerShell code that uses those bindings.

Here's the function.json file for daprBinding:

{
  "bindings": 
    {
      "type": "daprBinding",
      "direction": "out",
      "bindingName": "%KafkaBindingName%",
      "operation": "create",
      "name": "messages"
    }
}

For more information about function.json file properties, see the Configuration section.

In code:

using namespace System.Net

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

Write-Host "Powershell SendMessageToKafka processed a request."

$invoke_output_binding_req_body = @{
    "data" = $req
}

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

Contoh berikut menunjukkan pengikatan output Pengikatan Dapr, yang menggunakan model pemrograman Python v2. Untuk digunakan @dapp.dapr_binding_output dalam kode aplikasi fungsi Python Anda:

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="SendMessageToKafka")
@app.dapr_service_invocation_trigger(arg_name="payload", method_name="SendMessageToKafka")
@app.dapr_binding_output(arg_name="messages", binding_name="%KafkaBindingName%", operation="create")
def main(payload: str, messages: func.Out[bytes]) -> None:
    logging.info('Python processed a SendMessageToKafka request from the Dapr Runtime.')
    messages.set(json.dumps({"data": payload}).encode('utf-8'))

Attributes

In the in-process model, use the DaprBinding to define a Dapr binding output binding, which supports these parameters:

Parameter Description Dapat dikirim melalui Atribut Dapat dikirim melalui RequestBody
BindingName Nama pengikatan Dapr. ✔️ ✔️
Operation Operasi pengikatan yang dikonfigurasi. ✔️ ✔️
Metadata Namespace metadata. ❌ ✔️
Data Required. Data untuk operasi pengikatan. ❌ ✔️

Annotations

Anotasi DaprBindingOutput memungkinkan Anda membuat fungsi yang mengirim pengikatan output.

Element Description Dapat dikirim melalui Atribut Dapat dikirim melalui RequestBody
bindingName Nama pengikatan Dapr. ✔️ ✔️
output Operasi pengikatan yang dikonfigurasi. ✔️ ✔️
metadata Namespace metadata. ❌ ✔️
data Required. Data untuk operasi pengikatan. ❌ ✔️

Configuration

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

Property Description Dapat dikirim melalui Atribut Dapat dikirim melalui RequestBody
bindingName Nama pengikatan. ✔️ ✔️
operation Operasi pengikatan. ✔️ ✔️
metadata Namespace metadata. ❌ ✔️
data Required. Data untuk operasi pengikatan. ❌ ✔️

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

function.json property Description Dapat dikirim melalui Atribut Dapat dikirim melalui RequestBody
bindingName Nama pengikatan. ✔️ ✔️
operation Operasi pengikatan. ✔️ ✔️
metadata Namespace metadata. ❌ ✔️
data Required. Data untuk operasi pengikatan. ❌ ✔️

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

Property Description Dapat dikirim melalui Atribut Dapat dikirim melalui RequestBody
binding_name Nama peristiwa pengikatan. ✔️ ✔️
operation Nama/pengidentifikasi operasi pengikatan. ✔️ ✔️
metadata Namespace metadata. ❌ ✔️
data Required. Data untuk operasi pengikatan. ❌ ✔️

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

See the Example section for complete examples.

Usage

Untuk menggunakan pengikatan output Dapr, mulailah dengan menyiapkan komponen pengikatan output Dapr. Anda dapat mempelajari selengkapnya tentang komponen mana yang akan digunakan dan cara menyiapkannya dalam dokumentasi Resmi Dapr.

Untuk menggunakan daprBinding 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

Next steps

Pelajari lebih lanjut tentang pemanggilan layanan Dapr.

  • Last updated on