Bagikan melalui

Pengikatan output Dapr Publish untuk Azure Functions

  • Artikel

Pengikatan output penerbitan Dapr memungkinkan Anda menerbitkan pesan ke topik Dapr 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 penerbitan Dapr untuk melakukan operasi penerbitan Dapr ke komponen dan topik pub/sub.

[FunctionName("PublishOutputBinding")]
public static void Run(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = "topic/{topicName}")] HttpRequest req,
    [DaprPublish(PubSubName = "%PubSubName%", Topic = "{topicName}")] out DaprPubSubEvent pubSubEvent,
    ILogger log)
{
    string requestBody = new StreamReader(req.Body).ReadToEnd();
    pubSubEvent = new DaprPubSubEvent(requestBody);
}

Contoh berikut membuat "TransferEventBetweenTopics" fungsi menggunakan pengikatan DaprPublishOutput dengan DaprTopicTrigger:

@FunctionName("TransferEventBetweenTopics")
public String run(
        @DaprTopicTrigger(
            pubSubName = "%PubSubName%",
            topic = "A")
            String request,
        @DaprPublishOutput(
            pubSubName = "%PubSubName%",
            topic = "B")
        OutputBinding<String> payload,
        final ExecutionContext context) throws JsonProcessingException {
    context.getLogger().info("Java function processed a TransferEventBetweenTopics request from the Dapr Runtime.");
}

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

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

app.generic('PublishOutputBinding', {
    trigger: trigger.generic({
        type: 'httpTrigger',
        authLevel: 'anonymous',
        methods: ['POST'],
        route: "topic/{topicName}",
        name: "req"
    }),
    return: daprPublishOutput,
    handler: async (request, context) => {
        context.log("Node HTTP trigger function processed a request.");
        const payload = await request.text();
        context.log(JSON.stringify(payload));

        return { payload: payload };
    }
});

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

Berikut adalah file function.json untuk daprPublish:

{
  "bindings": 
    {
      "type": "daprPublish",
      "direction": "out",
      "name": "pubEvent",
      "pubsubname": "%PubSubName%",
      "topic": "B"
    }
}

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

Dalam kode:

using namespace System
using namespace Microsoft.Azure.WebJobs
using namespace Microsoft.Extensions.Logging
using namespace Microsoft.Azure.WebJobs.Extensions.Dapr
using namespace Newtonsoft.Json.Linq

# Example to use Dapr Service Invocation Trigger and Dapr State Output binding to persist a new state into statestore
param (
    $subEvent
)

Write-Host "PowerShell function processed a TransferEventBetweenTopics request from the Dapr Runtime."

# Convert the object to a JSON-formatted string with ConvertTo-Json
$jsonString = $subEvent["data"]

$messageFromTopicA = "Transfer from Topic A: $jsonString".Trim()

$publish_output_binding_req_body = @{
    "payload" = $messageFromTopicA
}

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

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

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="TransferEventBetweenTopics")
@app.dapr_topic_trigger(arg_name="subEvent", pub_sub_name="%PubSubName%", topic="A", route="A")
@app.dapr_publish_output(arg_name="pubEvent", pub_sub_name="%PubSubName%", topic="B")
def main(subEvent, pubEvent: func.Out[bytes]) -> None:
    logging.info('Python function processed a TransferEventBetweenTopics request from the Dapr Runtime.')
    subEvent_json = json.loads(subEvent)
    payload = "Transfer from Topic A: " + str(subEvent_json["data"])
    pubEvent.set(json.dumps({"payload": payload}).encode('utf-8'))

Atribut

Dalam model dalam proses, gunakan DaprPublish untuk menentukan pengikatan output penerbitan Dapr, yang mendukung parameter ini:

Properti function.json Deskripsi Dapat dikirim melalui Atribut Dapat dikirim melalui RequestBody
PubSubName Nama dapr pub/sub untuk mengirim pesan. ✔️ ✔️
Topik Nama topik Dapr untuk mengirim pesan. ✔️ ✔️
Payload Harus diisi. Pesan yang sedang diterbitkan. ❌ ✔️

Anotasi

Anotasi DaprPublishOutput memungkinkan Anda memiliki fungsi mengakses pesan yang diterbitkan.

Elemen Deskripsi Dapat dikirim melalui Atribut Dapat dikirim melalui RequestBody
pubSubName Nama dapr pub/sub untuk mengirim pesan. ✔️ ✔️
topik Nama topik Dapr untuk mengirim pesan. ✔️ ✔️
Payload Harus diisi. Pesan yang sedang diterbitkan. ❌ ✔️

Konfigurasi

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

Properti Deskripsi Dapat dikirim melalui Atribut Dapat dikirim melalui RequestBody
pubsubname Nama layanan komponen penerbit. ✔️ ✔️
topik Nama/pengidentifikasi topik penerbit. ✔️ ✔️
Payload Harus diisi. Pesan yang sedang diterbitkan. ❌ ✔️

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
pubsubname Nama layanan komponen penerbit. ✔️ ✔️
topik Nama/pengidentifikasi topik penerbit. ✔️ ✔️
Payload Harus diisi. Pesan yang sedang diterbitkan. ❌ ✔️

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

Properti Deskripsi Dapat dikirim melalui Atribut Dapat dikirim melalui RequestBody
pub_sub_name Nama peristiwa penerbit. ✔️ ✔️
topik Nama/pengidentifikasi topik penerbit. ✔️ ✔️
Payload Harus diisi. Pesan yang sedang diterbitkan. ❌ ✔️

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 penerbitan Dapr, mulailah dengan menyiapkan komponen dapr pub/sub. Anda dapat mempelajari selengkapnya tentang komponen mana yang akan digunakan dan cara menyiapkannya dalam dokumentasi Resmi Dapr.

Untuk menggunakan daprPublish 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 selengkapnya tentang Dapr menerbitkan dan berlangganan.