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.
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 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: daprBindingOuput,
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 };
}
});
Contoh berikut menunjukkan pemicu Dapr dalam file function.json dan kode PowerShell yang menggunakan pengikatan tersebut.
Berikut adalah file function.json untuk daprBinding
:
{
"bindings":
{
"type": "daprBinding",
"direction": "out",
"bindingName": "%KafkaBindingName%",
"operation": "create",
"name": "messages"
}
}
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-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'))
Atribut
Dalam model dalam proses, gunakan DaprBinding
untuk menentukan pengikatan output pengikatan Dapr, yang mendukung parameter ini:
Parameter | Deskripsi | Dapat dikirim melalui Atribut | Dapat dikirim melalui RequestBody |
---|---|---|---|
BindingName | Nama pengikatan Dapr. | ✔️ | ✔️ |
Operasi | Operasi pengikatan yang dikonfigurasi. | ✔️ | ✔️ |
Metadata | Namespace metadata. | ❌ | ✔️ |
Data | Harus diisi. Data untuk operasi pengikatan. | ❌ | ✔️ |
Anotasi
Anotasi DaprBindingOutput
memungkinkan Anda membuat fungsi yang mengirim pengikatan output.
Elemen | Deskripsi | Dapat dikirim melalui Atribut | Dapat dikirim melalui RequestBody |
---|---|---|---|
bindingName | Nama pengikatan Dapr. | ✔️ | ✔️ |
output | Operasi pengikatan yang dikonfigurasi. | ✔️ | ✔️ |
metadata | Namespace metadata. | ❌ | ✔️ |
data | Harus diisi. Data untuk operasi pengikatan. | ❌ | ✔️ |
Konfigurasi
Tabel berikut menjelaskan properti konfigurasi pengikatan yang Anda tetapkan dalam kode.
Properti | Deskripsi | Dapat dikirim melalui Atribut | Dapat dikirim melalui RequestBody |
---|---|---|---|
bindingName | Nama pengikatan. | ✔️ | ✔️ |
operasi | Operasi pengikatan. | ✔️ | ✔️ |
metadata | Namespace metadata. | ❌ | ✔️ |
data | Harus diisi. Data untuk operasi pengikatan. | ❌ | ✔️ |
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 |
---|---|---|---|
bindingName | Nama pengikatan. | ✔️ | ✔️ |
operasi | Operasi pengikatan. | ✔️ | ✔️ |
metadata | Namespace metadata. | ❌ | ✔️ |
data | Harus diisi. Data untuk operasi pengikatan. | ❌ | ✔️ |
Tabel berikut menjelaskan properti konfigurasi pengikatan untuk @dapp.dapr_binding_output
yang Anda tetapkan dalam kode Python Anda.
Properti | Deskripsi | Dapat dikirim melalui Atribut | Dapat dikirim melalui RequestBody |
---|---|---|---|
binding_name | Nama peristiwa pengikatan. | ✔️ | ✔️ |
operasi | Nama/pengidentifikasi operasi pengikatan. | ✔️ | ✔️ |
metadata | Namespace metadata. | ❌ | ✔️ |
data | Harus diisi. Data untuk operasi pengikatan. | ❌ | ✔️ |
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 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.
- Spesifikasi komponen pengikatan output Dapr
- Cara: Menggunakan pengikatan output untuk berinteraksi dengan sumber daya eksternal
Untuk menggunakan daprBinding
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
Saran dan Komentar
https://aka.ms/ContentUserFeedback.
Segera hadir: Sepanjang tahun 2024 kami akan menghentikan penggunaan GitHub Issues sebagai mekanisme umpan balik untuk konten dan menggantinya dengan sistem umpan balik baru. Untuk mengetahui informasi selengkapnya, lihat:Kirim dan lihat umpan balik untuk