Pemicu Topik Dapr untuk Azure Functions
Azure Functions dapat dipicu pada langganan topik Dapr menggunakan peristiwa Dapr berikut.
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. |
[FunctionName("TransferEventBetweenTopics")]
public static void Run(
[DaprTopicTrigger("%PubSubName%", Topic = "A")] CloudEvent subEvent,
[DaprPublish(PubSubName = "%PubSubName%", Topic = "B")] out DaprPubSubEvent pubEvent,
ILogger log)
{
log.LogInformation("C# function processed a TransferEventBetweenTopics request from the Dapr Runtime.");
pubEvent = new DaprPubSubEvent("Transfer from Topic A: " + subEvent.Data);
}
Berikut adalah kode Java untuk berlangganan topik menggunakan pemicu Topik Dapr:
@FunctionName("PrintTopicMessage")
public String run(
@DaprTopicTrigger(
pubSubName = "%PubSubName%",
topic = "B")
String payload,
final ExecutionContext context) throws JsonProcessingException {
Logger logger = context.getLogger();
logger.info("Java function processed a PrintTopicMessage request from the Dapr Runtime.");
app
Gunakan objek untuk mendaftarkan daprTopicTrigger
:
const { app, trigger } = require('@azure/functions');
app.generic('TransferEventBetweenTopics', {
trigger: trigger.generic({
type: 'daprTopicTrigger',
name: "subEvent",
pubsubname: "%PubSubName%",
topic: "A"
}),
return: daprPublishOutput,
handler: async (request, context) => {
context.log("Node function processed a TransferEventBetweenTopics request from the Dapr Runtime.");
context.log(context.triggerMetadata.subEvent.data);
return { payload: context.triggerMetadata.subEvent.data };
}
});
Contoh berikut menunjukkan pemicu Dapr dalam file function.json dan kode PowerShell yang menggunakan pengikatan tersebut.
Berikut adalah file function.json untuk daprTopicTrigger
:
{
"bindings": [
{
"type": "daprTopicTrigger",
"pubsubname": "%PubSubName%",
"topic": "B",
"name": "subEvent",
"direction": "in"
}
]
}
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
param (
$subEvent
)
Write-Host "PowerShell function processed a PrintTopicMessage request from the Dapr Runtime."
# Convert the object to a JSON-formatted string with ConvertTo-Json
$jsonString = $subEvent["data"] | ConvertTo-Json -Compress
Write-Host "Topic B received a message: $jsonString"
Contoh berikut menunjukkan pemicu Topik Dapr, yang menggunakan model pemrograman Python v2. Untuk menggunakan daprTopicTrigger
dalam kode aplikasi fungsi Python Anda:
import logging
import json
import azure.functions as func
app = func.FunctionApp()
@app.function_name(name="PrintTopicMessage")
@app.dapr_topic_trigger(arg_name="subEvent", pub_sub_name="%PubSubName%", topic="B", route="B")
def main(subEvent) -> None:
logging.info('Python function processed a PrintTopicMessage request from the Dapr Runtime.')
subEvent_json = json.loads(subEvent)
logging.info("Topic B received a message: " + subEvent_json["data"])
Atribut
Dalam model dalam proses, gunakan DaprTopicTrigger
untuk memicu pengikatan pub/sub Dapr, yang mendukung properti berikut.
Parameter | Deskripsi |
---|---|
PubSubName | Nama dapr pub/sub. |
Topik | Nama topik Dapr. |
Anotasi
Anotasi DaprTopicTrigger
memungkinkan Anda membuat fungsi yang berjalan saat topik diterima.
Elemen | Deskripsi |
---|---|
pubSubName | Nama dapr pub/sub. |
topik | Nama topik Dapr. |
Konfigurasi
Tabel berikut menjelaskan properti konfigurasi pengikatan yang Anda tetapkan dalam kode.
Properti | Deskripsi |
---|---|
pubsubname | Nama jenis komponen dapr pub/sub. |
topik | Nama topik. |
Tabel berikut menjelaskan properti konfigurasi pengikatan yang Anda atur di file function.json.
Properti function.json | Deskripsi |
---|---|
pubsubname | Nama jenis komponen dapr pub/sub. |
topik | Nama topik. |
Tabel berikut menjelaskan properti konfigurasi pengikatan untuk @dapp.dapr_topic_trigger
yang Anda tetapkan dalam kode Python Anda.
Properti | Deskripsi | Dapat dikirim melalui Atribut | Dapat dikirim melalui RequestBody |
---|---|---|---|
pub_sub_name | Nama jenis komponen langganan Dapr. | ✔️ | ❌ |
topik | Topik langganan. | ✔️ | ❌ |
Lihat Bagian contoh untuk contoh lengkapnya.
Penggunaan
Untuk menggunakan pemicu Topik Dapr, mulailah dengan menyiapkan komponen pub/sub Dapr. Anda dapat mempelajari selengkapnya tentang komponen mana yang akan digunakan dan cara menyiapkannya dalam dokumentasi Resmi Dapr.
Untuk menggunakan daprTopicTrigger
di Python v2, siapkan proyek Anda dengan dependensi yang benar.
Membuat dan mengaktifkan lingkungan virtual.
Di file Anda
requirements.text
, tambahkan baris berikut:azure-functions==1.18.0b3
Di terminal, instal pustaka Python.
pip install -r .\requirements.txt
Ubah file Anda
local.setting.json
dengan konfigurasi berikut:"PYTHON_ISOLATE_WORKER_DEPENDENCIES":1
Langkah berikutnya
Pelajari selengkapnya tentang Dapr menerbitkan dan berlangganan.