Megosztás a következőn keresztül:

RabbitMQ kimeneti kötés az Azure Functionshez – áttekintés

A RabbitMQ kimeneti kötéssel üzeneteket küldhet egy RabbitMQ-üzenetsorba.

Feljegyzés

A RabbitMQ-kötések csak rugalmas Prémium és Dedikált (App Service) csomagokban támogatottak teljes mértékben. A rugalmas felhasználású és a használati csomagok még nem támogatottak.

A RabbitMQ-kötéseket az Azure Functions 1.x-es futtatókörnyezete nem támogatja.

A beállítással és a konfigurációval kapcsolatos információkért tekintse meg az áttekintést.

Példa

C# függvényt az alábbi C# módok egyikével hozhat létre:

  • Izolált feldolgozómodell: Lefordított C# függvény, amely a futtatókörnyezettől elkülönített feldolgozói folyamatban fut. Izolált feldolgozói folyamat szükséges a hosszú távú támogatáson (LTS) futó C# függvények támogatásához, valamint a .NET és a .NET-keretrendszer nem LTS-verzióihoz.
  • Folyamatban lévő modell: Lefordított C# függvény, amely ugyanabban a folyamatban fut, mint az Azure Functions futtatókörnyezete.
  • C#-szkript: Elsősorban C#-függvények Azure Portalon való létrehozásakor használatos.

Fontos

A folyamaton belüli modell támogatása 2026. november 10-én megszűnik. Erősen javasoljuk, hogy az alkalmazásokat az elkülönített feldolgozói modellbe migrálja a teljes támogatás érdekében.

[Function(nameof(RabbitMQFunction))]
[RabbitMQOutput(QueueName = "destinationQueue", ConnectionStringSetting = "RabbitMQConnection")]
public static string Run([RabbitMQTrigger("queue", ConnectionStringSetting = "RabbitMQConnection")] string item,
    FunctionContext context)
{
    var logger = context.GetLogger(nameof(RabbitMQFunction));

    logger.LogInformation(item);

    var message = $"Output message created at {DateTime.Now}";
    return message;
}

Az alábbi Java-függvény a @RabbitMQOutput Java RabbitMQ-típusok megjegyzéseit használja a RabbitMQ-üzenetsor kimeneti kötésének konfigurálásához. A függvény 5 percenként üzenetet küld a RabbitMQ üzenetsornak, amikor egy TimerTrigger aktiválja.

@FunctionName("RabbitMQOutputExample")
public void run(
@TimerTrigger(name = "keepAliveTrigger", schedule = "0 */5 * * * *") String timerInfo,
@RabbitMQOutput(connectionStringSetting = "rabbitMQConnectionAppSetting", queueName = "hello") OutputBinding<String> output,
final ExecutionContext context) {
    output.setValue("Some string");
}

Az alábbi példa egy RabbitMQ kimeneti kötést mutat be egy function.json fájlban, és egy JavaScript-függvényt , amely a kötést használja. A függvény beolvassa az üzenetet egy HTTP-eseményindítóból, és a RabbitMQ-üzenetsorba küldi.

A kötési adatok a function.json fájlban:

{
    "bindings": [
        {
            "type": "httpTrigger",
            "direction": "in",
            "authLevel": "function",
            "name": "input",
            "methods": [
                "get",
                "post"
            ]
        },
        {
            "type": "rabbitMQ",
            "name": "outputMessage",
            "queueName": "outputQueue",
            "connectionStringSetting": "rabbitMQConnectionAppSetting",
            "direction": "out"
        }
    ]
}

Az alábbi JavaScript-kód:

module.exports = async function (context, input) {
    context.bindings.outputMessage = input.body;
};

Az alábbi példa egy RabbitMQ kimeneti kötést mutat be egy function.json fájlban és egy Python-függvényt, amely a kötést használja. A függvény beolvassa az üzenetet egy HTTP-eseményindítóból, és a RabbitMQ-üzenetsorba küldi.

A kötési adatok a function.json fájlban:

{
    "scriptFile": "__init__.py",
    "bindings": [
        {
            "authLevel": "function",
            "type": "httpTrigger",
            "direction": "in",
            "name": "req",
            "methods": [
                "get",
                "post"
            ]
        },
        {
            "type": "http",
            "direction": "out",
            "name": "$return"
        },​​
        {
            "type": "rabbitMQ",
            "name": "outputMessage",
            "queueName": "outputQueue",
            "connectionStringSetting": "rabbitMQConnectionAppSetting",
            "direction": "out"
        }
    ]
}

A _init_.py:

import azure.functions as func

def main(req: func.HttpRequest, outputMessage: func.Out[str]) -> func.HttpResponse:
    input_msg = req.params.get('message')
    outputMessage.set(input_msg)
    return 'OK'

Attribútumok

Az izolált feldolgozói folyamatok és a folyamatban lévő C# kódtárak is attribútumot használnak egy kimeneti kötés definiálásához, amely egy RabbitMQ-üzenetsorba ír.

A RabbitMQOutputAttribute konstruktor a következő paramétereket fogadja el:

Paraméter Leírás
QueueName Annak az üzenetsornak a neve, amelyből üzeneteket szeretne fogadni.
HostName Ez a paraméter már nem támogatott, és figyelmen kívül hagyja. Egy későbbi verzióban el lesz távolítva.
ConnectionStringSetting A RabbitMQ-kiszolgáló kapcsolati sztringet tartalmazó alkalmazásbeállítás neve. Ez a beállítás csak egy alkalmazásbeállítási kulcs nevét veszi fel, nem állíthat be közvetlenül kapcsolati sztringértéket. További információ: Kapcsolatok.
UserNameSetting Ez a paraméter már nem támogatott, és figyelmen kívül hagyja. Egy későbbi verzióban el lesz távolítva.
PasswordSetting Ez a paraméter már nem támogatott, és figyelmen kívül hagyja. Egy későbbi verzióban el lesz távolítva.
Kikötő Lekéri vagy beállítja a használt portot. Alapértelmezés szerint 0, amely a RabbitMQ-ügyfél alapértelmezett portbeállítására 5672mutat.
DisableCertificateValidation Lekéri vagy beállít egy értéket, amely jelzi, hogy le kell-e tiltani a tanúsítványérvényesítést. Éles környezetben nem ajánlott. Nem érvényes, ha az SSL le van tiltva.

Jegyzetek

A RabbitMQOutput széljegyzet lehetővé teszi, hogy egy RabbitMQ-üzenet létrehozásakor futó függvényt hozzon létre.

A széljegyzet a következő konfigurációs beállításokat támogatja:

Beállítás Leírás
queueName Annak az üzenetsornak a neve, amelyből üzeneteket szeretne fogadni.
connectionStringSetting A RabbitMQ-kiszolgáló kapcsolati sztringet tartalmazó alkalmazásbeállítás neve. Ez a beállítás csak egy alkalmazásbeállítási kulcs nevét veszi fel, nem állíthat be közvetlenül kapcsolati sztringértéket. További információ: Kapcsolatok.
disableCertificateValidation Lekéri vagy beállít egy értéket, amely jelzi, hogy le kell-e tiltani a tanúsítványérvényesítést. Éles környezetben nem ajánlott. Nem érvényes, ha az SSL le van tiltva.

Konfiguráció

Az alábbi táblázat a function.json fájlban beállított kötéskonfigurációs tulajdonságokat ismerteti.

function.json tulajdonság Leírás
típus A beállításnak a RabbitMQkövetkezőnek kell lennie: .
irány A beállításnak a outkövetkezőnek kell lennie: .
név Annak a változónak a neve, amely az üzenetsort jelöli a függvénykódban.
queueName Annak az üzenetsornak a neve, amelybe üzeneteket szeretne küldeni.
connectionStringSetting A RabbitMQ-kiszolgáló kapcsolati sztringet tartalmazó alkalmazásbeállítás neve. Ez a beállítás csak egy alkalmazásbeállítási kulcs nevét veszi fel, nem állíthat be közvetlenül kapcsolati sztringértéket. További információ: Kapcsolatok.
disableCertificateValidation Lekéri vagy beállít egy értéket, amely jelzi, hogy le kell-e tiltani a tanúsítványérvényesítést. Éles környezetben nem ajánlott. Nem érvényes, ha az SSL le van tiltva.

Helyi fejlesztéskor adja hozzá az alkalmazásbeállításokat a gyűjtemény local.settings.json fájljáhozValues.

A teljes példákért tekintse meg a Példa szakaszt .

Használat

A RabbitMQ-eseményindító által támogatott paramétertípus a Functions futtatókörnyezet verziójától, a bővítménycsomag verziójától és a használt C# módtól függ.

A RabbitMQ-kötések jelenleg csak sztring- és szerializálható objektumtípusokat támogatnak, ha izolált feldolgozófolyamatban futnak.

A kimeneti kötéshez használja a következő paramétertípusokat:

  • byte[] – Ha a paraméter értéke null, amikor a függvény kilép, a Functions nem hoz létre üzenetet.
  • string – Ha a paraméter értéke null, amikor a függvény kilép, a Functions nem hoz létre üzenetet.
  • POJO – Ha a paraméter értéke nem Java-objektumként van formázva, hibaüzenet jelenik meg.

Az üzenetsor-üzenet azon keresztül context.bindings.<NAME> érhető el, ahol <NAME> egyezik a function.json definiált névvel. Ha a hasznos adat JSON, az érték deszerializálva lesz egy objektumba.

Connections

Fontos

A RabbitMQ-kötés nem támogatja a Microsoft Entra-hitelesítést és a felügyelt identitásokat. Az Azure Key Vault használatával központilag felügyelheti a RabbitMQ-kapcsolati sztring. További információ: Kapcsolatok kezelése.

A bővítmény hostNameuserNameSettingpasswordSetting 2.x verziójától kezdve a továbbiakban nem támogatott a RabbitMQ-kiszolgálóhoz való kapcsolat definiálása. Ehelyett a következőt kell használnia connectionStringSetting:

A connectionStringSetting tulajdonság csak egy kulcs-érték pár nevét fogadja el az alkalmazásbeállításokban. Közvetlenül nem állíthat be kapcsolati sztringértéket a kötésben.

Ha például a kötésdefinícióban beállította connectionStringSettingrabbitMQConnection , a függvényalkalmazásnak rendelkeznie kell egy olyan alkalmazásbeállítással rabbitMQConnection , amely egy kapcsolati értéket, például amqp://myuser:***@contoso.rabbitmq.example.com:5672 egy Azure Key Vault-hivatkozást ad vissza.

Helyi futtatáskor meg kell adnia a local.settings.json fájlban definiált connectionStringSetting kulcsértéket is. Ellenkező esetben az alkalmazás nem tud csatlakozni a szolgáltatáshoz a helyi számítógépről, és hiba történik.

  • Last updated on