Bagikan melalui

Pemicu Pemanggilan Layanan Dapr untuk Azure Functions

  • Artikel

Azure Functions dapat dipicu pada pemanggilan layanan 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("CreateNewOrder")]
public static void Run(
    [DaprServiceInvocationTrigger] JObject payload,
    [DaprState("%StateStoreName%", Key = "order")] out JToken order,
    ILogger log)
{
    log.LogInformation("C# function processed a CreateNewOrder request from the Dapr Runtime.");

    // payload must be of the format { "data": { "value": "some value" } }
    order = payload["data"];
}

Berikut adalah kode Java untuk pemicu Pemanggilan Layanan Dapr:

@FunctionName("CreateNewOrder")
public String run(
        @DaprServiceInvocationTrigger(
            methodName = "CreateNewOrder") 
)

app Gunakan objek untuk mendaftarkan daprInvokeOutput:

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

app.generic('InvokeOutputBinding', {
    trigger: trigger.generic({
        type: 'httpTrigger',
        authLevel: 'anonymous',
        methods: ['POST'],
        route: "invoke/{appId}/{methodName}",
        name: "req"
    }),
    return: daprInvokeOutput,
    handler: async (request, context) => {
        context.log("Node HTTP trigger function processed a request.");

        const payload = await request.text();
        context.log(JSON.stringify(payload));

        return { body: payload };
    }
});

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

Berikut adalah file function.json untuk daprServiceInvocationTrigger:

{
  "bindings": [
    {
      "type": "daprServiceInvocationTrigger",
      "name": "payload",
      "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 (
    $payload
)

# C# function processed a CreateNewOrder request from the Dapr Runtime.
Write-Host "PowerShell function processed a CreateNewOrder request from the Dapr Runtime."

# Payload must be of the format { "data": { "value": "some value" } }

# Convert the object to a JSON-formatted string with ConvertTo-Json
$jsonString = $payload| ConvertTo-Json

# Associate values to output bindings by calling 'Push-OutputBinding'.
Push-OutputBinding -Name order -Value $payload["data"]

Contoh berikut menunjukkan pemicu Pemanggilan Layanan Dapr, yang menggunakan model pemrograman Python v2. Untuk menggunakan daprServiceInvocationTrigger dalam kode aplikasi fungsi Python Anda:

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="RetrieveOrder")
@app.dapr_service_invocation_trigger(arg_name="payload", method_name="RetrieveOrder")
@app.dapr_state_input(arg_name="data", state_store="statestore", key="order")
def main(payload, data: str) :
    # Function should be invoked with this command: dapr invoke --app-id functionapp --method RetrieveOrder  --data '{}'
    logging.info('Python function processed a RetrieveOrder request from the Dapr Runtime.')
    logging.info(data)

Atribut

Dalam model dalam proses, gunakan DaprServiceInvocationTrigger untuk memicu pengikatan pemanggilan layanan Dapr, yang mendukung properti berikut.

Parameter Deskripsi
MethodName Opsional. Nama metode yang harus digunakan pemanggil Dapr. Jika tidak ditentukan, nama fungsi digunakan sebagai nama metode.

Anotasi

Anotasi DaprServiceInvocationTrigger memungkinkan Anda membuat fungsi yang dipanggil oleh runtime Dapr.

Elemen Deskripsi
methodName Nama metode.

Konfigurasi

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

Properti Deskripsi
jenis Harus diatur ke daprServiceInvocationTrigger.
nama Nama variabel yang mewakili data Dapr dalam kode fungsi.

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

Properti function.json Deskripsi
jenis Harus diatur ke daprServiceInvocationTrigger.
nama Nama variabel yang mewakili data Dapr dalam kode fungsi.

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

Properti Deskripsi
method_name Nama variabel yang mewakili data Dapr.

Lihat Bagian contoh untuk contoh lengkapnya.

Penggunaan

Untuk menggunakan pemicu Pemanggilan Layanan Dapr, pelajari selengkapnya tentang komponen mana yang akan digunakan dengan pemicu Pemanggilan Layanan dan cara mengaturnya dalam dokumentasi Dapr resmi.

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