Azure İşlevleri için tetikleyici bağlamasını SignalR Hizmeti

Azure SignalR Hizmeti gönderilen iletilere yanıt vermek için SignalR tetikleyici bağlamasını kullanın. İşlev tetiklendiğinde, işleve geçirilen iletiler json nesnesi olarak ayrıştırılır.

SignalR Hizmeti sunucusuz modda SignalR Hizmeti, istemciden İşlev Uygulamasına ileti göndermek için Yukarı Akış özelliğini kullanır. İşlev Uygulaması bu iletileri işlemek için SignalR Hizmeti tetikleyici bağlamasını kullanır. Genel mimari aşağıda gösterilmiştir:

Kurulum ve yapılandırma ayrıntıları hakkında bilgi için genel bakışa bakın.

Örnek

[Function(nameof(OnClientMessage))]
public static void OnClientMessage(
    [SignalRTrigger("Hub", "messages", "sendMessage", "content", ConnectionStringSetting = "SignalRConnection")]
        SignalRInvocationContext invocationContext, string content, FunctionContext functionContext)
{
    var logger = functionContext.GetLogger(nameof(OnClientMessage));
    logger.LogInformation("Connection {connectionId} sent a message. Message content: {content}", invocationContext.ConnectionId, content);
}

public class HubName1 : ServerlessHub
{
    [FunctionName("SignalRTest")]
    public Task SendMessage([SignalRTrigger]InvocationContext invocationContext, string message, ILogger logger)
    {
        logger.LogInformation($"Receive {message} from {invocationContext.ConnectionId}.");
    }
}

[FunctionName("SignalRTest")]
public static Task Run([SignalRTrigger("SignalRTest", "messages", "SendMessage", parameterNames: new string[] {"message"})]InvocationContext invocationContext, string message, ILogger logger)
{
    logger.LogInformation($"Receive {message} from {invocationContext.ConnectionId}.");
}

[FunctionName("SignalRTest")]
public static Task Run([SignalRTrigger("SignalRTest", "messages", "SendMessage")]InvocationContext invocationContext, [SignalRParameter]string message, ILogger logger)
{
    logger.LogInformation($"Receive {message} from {invocationContext.ConnectionId}.");
}

{
    "type": "signalRTrigger",
    "name": "invocation",
    "hubName": "hubName1",
    "category": "messages",
    "event": "SendMessage",
    "parameterNames": [
        "message"
    ],
    "direction": "in"
}

app.generic("function1",
    {
        trigger: { "type": "signalRTrigger", "name": "invocation", "direction": "in", "hubName": "hubName1", "event": "SendMessage", "category": "messages" },
        handler: (triggerInput, context) => {
            context.log(`Receive ${context.Arguments[0]} from ${triggerInput.ConnectionId}.`)
        }
    })

{
    "type": "signalRTrigger",
    "name": "invocation",
    "hubName": "hubName1",
    "category": "messages",
    "event": "SendMessage",
    "parameterNames": [
        "message"
    ],
    "direction": "in"
}

module.exports = function (context, invocation) {
    context.log(`Receive ${context.bindingData.message} from ${invocation.ConnectionId}.`)
};

import logging
import json
import azure.functions as func

def main(invocation) -> None:
    invocation_json = json.loads(invocation)
    logging.info("Receive {0} from {1}".format(invocation_json['Arguments'][0], invocation_json['ConnectionId']))

Tam örnekler için Örnek bölümüne bakın.

Kullanım

Yük

Tetikleyici giriş türü ya da InvocationContext özel bir tür olarak bildirilir. öğesini seçerseniz InvocationContext, istek içeriğine tam erişim elde edersiniz. Özel bir tür için çalışma zamanı JSON istek gövdesini ayrıştırarak nesne özelliklerini ayarlamaya çalışır.

InvocationContext

InvocationContext , aşağıdaki özellikleri içeren bir SignalR hizmetinden gönderilen iletideki tüm içeriği içerir:

ParameterNames kullanma

özelliği ParameterNames SignalRTrigger , çağrı iletilerinin bağımsız değişkenlerini işlevlerin parametrelerine bağlamanıza olanak tanır. Bağlama ifadelerinin bir parçası olarak tanımladığınız adı diğer bağlamada veya kodunuzda parametre olarak kullanabilirsiniz. Bu, bağımsız değişkenlerine InvocationContexterişmek için daha kullanışlı bir yol sağlar.

Azure İşlevi'nde iki bağımsız değişkenle message1yöntemini broadcast çağırmaya çalışan bir JavaScript SignalR istemciniz olduğunu varsayalım: . message2

await connection.invoke("broadcast", message1, message2);

ayarladıktan parameterNamessonra, tanımladığınız adlar istemci tarafında gönderilen bağımsız değişkenlere karşılık gelir.

[SignalRTrigger(parameterNames: new string[] {"arg1, arg2"})]

Ardından, arg1 öğesinin içeriğini message1ve arg2 içeriğini message2içerir.

ParameterNames Husus -lar

Parametre bağlaması için sıra önemlidir. kullanıyorsanız ParameterNamesiçindeki sıra ParameterNames , istemcide çağırdığınız bağımsız değişkenlerin sırasıyla eşleşir. C# dilinde öznitelik [SignalRParameter] kullanıyorsanız, Azure İşlevi yöntemlerindeki bağımsız değişkenlerin sırası istemcilerdeki bağımsız değişkenlerin sırasıyla eşleşir.

ParameterNamesve özniteliği [SignalRParameter] aynı anda kullanılamaz, aksi durumda bir özel durum alırsınız.

SignalR Hizmeti tümleştirmesi

SignalR Hizmeti SignalR Hizmeti tetikleyici bağlaması kullanırken İşlev Uygulamasına erişmek için bir URL gerekir. URL, SignalR Hizmeti tarafındaki Yukarı Akış Ayarları'nda yapılandırılmalıdır.

SignalR Hizmeti tetikleyicisi kullanılırken URL basit ve aşağıdaki gibi biçimlendirilmiş olabilir:

<Function_App_URL>/runtime/webhooks/signalr?code=<API_KEY>

, Function_App_URL İşlev Uygulamasının Genel Bakış sayfasında bulunabilir ve API_KEY Azure İşlevi tarafından oluşturulur. öğesini İşlev Uygulaması'nın Uygulama anahtarları dikey penceresinden alabilirsiniz.API_KEY signalr_extension

Bir SignalR Hizmeti birden fazla İşlev Uygulamasını birlikte kullanmak istiyorsanız, yukarı akış karmaşık yönlendirme kurallarını da destekleyebilir. Yukarı akış ayarları bölümünde daha fazla ayrıntı bulabilirsiniz.

Adım adım örnek

İşlev Uygulamasında SignalR Hizmeti tetikleyici bağlama ve yukarı akış özelliğiyle sohbet odası dağıtmak için GitHub'daki örneği izleyebilirsiniz: Çift yönlü sohbet odası örneği

Sonraki adımlar

• Azure SignalR Hizmeti ile Azure İşlevleri geliştirme ve yapılandırma
• SignalR Hizmeti Tetikleyici bağlama örneği
• yalıtılmış çalışan işleminde tetikleyici bağlama örneğini SignalR Hizmeti