Bagikan melalui

Pemicu Pengikatan Input Dapr untuk Azure Functions

  • Artikel

Azure Functions dapat dipicu pada pengikatan input 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("ConsumeMessageFromKafka")]
public static void Run(
    // Note: the value of BindingName must match the binding name in components/kafka-bindings.yaml
    [DaprBindingTrigger(BindingName = "%KafkaBindingName%")] JObject triggerData,
    ILogger log)
{
    log.LogInformation("Hello from Kafka!");
    log.LogInformation($"Trigger data: {triggerData}");
}

Berikut adalah kode Java untuk pemicu Pengikatan Input Dapr:

@FunctionName("ConsumeMessageFromKafka")
public String run(
        @DaprBindingTrigger(
            bindingName = "%KafkaBindingName%")
)

app Gunakan objek untuk mendaftarkan daprBindingTrigger:

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

app.generic('ConsumeMessageFromKafka', {
    trigger: trigger.generic({
        type: 'daprBindingTrigger',
        bindingName: "%KafkaBindingName%",
        name: "triggerData"
    }),
    handler: async (request, context) => {
        context.log("Node function processed a ConsumeMessageFromKafka request from the Dapr Runtime.");
        context.log(context.triggerMetadata.triggerData)
    }
});

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

Berikut adalah file function.json untuk daprBindingTrigger:

{
  "bindings": [
    {
      "type": "daprBindingTrigger",
      "bindingName": "%KafkaBindingName%",
      "name": "triggerData",
      "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 (
    $triggerData
)

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

$jsonString = $triggerData | ConvertTo-Json

Write-Host "Trigger data: $jsonString"

Contoh berikut menunjukkan pemicu Pengikatan Input Dapr, yang menggunakan model pemrograman Python v2. Untuk menggunakan daprBinding dalam kode aplikasi fungsi Python Anda:

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="ConsumeMessageFromKafka")
@app.dapr_binding_trigger(arg_name="triggerData", binding_name="%KafkaBindingName%")
def main(triggerData: str) -> None:
    logging.info('Python function processed a ConsumeMessageFromKafka request from the Dapr Runtime.')
    logging.info('Trigger data: ' + triggerData)

Atribut

Dalam model dalam proses, gunakan DaprBindingTrigger untuk memicu pengikatan input Dapr, yang mendukung properti berikut.

Parameter Deskripsi
BindingName Nama pemicu Dapr. Jika tidak ditentukan, nama fungsi digunakan sebagai nama pemicu.

Anotasi

Anotasi DaprBindingTrigger memungkinkan Anda membuat fungsi yang dipicu oleh komponen pengikatan yang Anda buat.

Elemen Deskripsi
bindingName Nama pengikatan Dapr.

Konfigurasi

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

Properti Deskripsi
bindingName Nama pengikatan.

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

Properti function.json Deskripsi
bindingName Nama pengikatan.

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

Properti Deskripsi
binding_name Nama pengikatan.

Lihat Bagian contoh untuk contoh lengkapnya.

Penggunaan

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

Untuk menggunakan daprBindingTrigger 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.