Gatilho e associações do Azure Web PubSub para o Azure Functions

Artigo
01/12/2024

Esta referência explica como manipular eventos Web PubSub no Azure Functions.

O Web PubSub é um serviço gerenciado pelo Azure que ajuda os desenvolvedores a criar facilmente aplicativos Web com recursos em tempo real e padrão de publicação-assinatura.

Ação	Type
Executar uma função quando as mensagens vêm do serviço	Vinculação de gatilho
Vincular solicitação ao objeto de destino em Http trigger para negociação e solicitações upstream	Vinculação de entrada
Invocar ações do serviço	Vinculação de saída

Código-fonte Documentação de referência | da API do pacote | Documentação | do produto Exemplos |

Adicionar à sua aplicação Funções

Trabalhar com o gatilho e as ligações requer que você faça referência ao pacote apropriado. O pacote NuGet é usado para bibliotecas de classe .NET, enquanto o pacote de extensão é usado para todos os outros tipos de aplicativos.

Idioma	Adicionar por...	Observações
C#	Instalando o pacote NuGet, pré-lançamento da versão
Script C#, JavaScript, Python, PowerShell	Instalar extensões explicitamente, Usar pacotes de extensões	A extensão Ferramentas do Azure é recomendada para uso com o Visual Studio Code.
Script C# (somente online no portal do Azure)	Adicionar uma ligação	Para atualizar as extensões de associação existentes sem ter que publicar novamente seu aplicativo de função, consulte Atualizar suas extensões.

Conceitos-chave

Diagrama mostrando o fluxo de trabalho do serviço Azure Web PubSub trabalhando com Aplicativos de Função.

(1)-(2) WebPubSubConnection ligação de entrada com HttpTrigger para gerar conexão de cliente.

(3)-(4) WebPubSubTrigger acionar a ligação ou WebPubSubContext a ligação de entrada com HttpTrigger para lidar com a solicitação de serviço.

(5)-(6) WebPubSub vinculação de saída para solicitar serviço fazer algo.

Vinculação de gatilho

Use o gatilho de função para lidar com solicitações do serviço Azure Web PubSub.

WebPubSubTrigger é usado quando você precisa lidar com solicitações do lado do serviço. O padrão de ponto de extremidade do gatilho seria como abaixo, que deve ser definido no lado do serviço Web PubSub (Portal: configurações -> manipulador de eventos -> Modelo de URL). No padrão de ponto de extremidade, a parte code=<API_KEY> de consulta é NECESSÁRIA quando você estiver usando o Aplicativo de Função do Azure por motivos de segurança . A chave pode ser encontrada no portal do Azure. Encontre seu recurso de aplicativo de função e navegue até Funções ->Chaves de aplicativo ->Chaves do sistema ->webpubsub_extension depois de implantar o aplicativo de função no Azure. No entanto, essa chave não é necessária quando você está trabalhando com funções locais.

<Function_App_Url>/runtime/webhooks/webpubsub?code=<API_KEY>

Screenshot de obter teclas do sistema de função.

Exemplo

[FunctionName("WebPubSubTrigger")]
public static void Run(
    [WebPubSubTrigger("<hub>", WebPubSubEventType.User, "message")] UserEventRequest request, ILogger log)
{
    log.LogInformation($"Request from: {request.ConnectionContext.UserId}");
    log.LogInformation($"Request message data: {request.Data}");
    log.LogInformation($"Request message dataType: {request.DataType}");
}

WebPubSubTrigger A vinculação também oferece suporte ao valor de retorno em cenários de sincronização, por exemplo, evento do sistema Connect e do usuário, quando o servidor pode verificar e negar a solicitação do cliente ou enviar mensagens diretamente para o chamador. Connect O evento respeita e ConnectEventResponse EventErrorResponse, e o evento do usuário respeita UserEventResponse e EventErrorResponse, os tipos rest que não correspondem ao cenário atual são ignorados. E se EventErrorResponse for retornado, o serviço descarta a conexão do cliente.

[FunctionName("WebPubSubTriggerReturnValueFunction")]
public static UserEventResponse Run(
    [WebPubSubTrigger("hub", WebPubSubEventType.User, "message")] UserEventRequest request)
{
    return request.CreateResponse(BinaryData.FromString("ack"), WebPubSubDataType.Text);
}

O exemplo a seguir mostra uma função JavaScript de gatilho Web PubSub.

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

const wpsTrigger = trigger.generic({
    type: 'webPubSubTrigger',
    name: 'request',
    hub: '<hub>',
    eventName: 'message',
    eventType: 'user'
});

app.generic('message', {
    trigger: wpsTrigger,
    handler: async (request, context) => {
        context.log('Request from: ', request.connectionContext.userId);
        context.log('Request message data: ', request.data);
        context.log('Request message dataType: ', request.dataType);
    }
});

WebPubSubTrigger A vinculação também oferece suporte ao valor de retorno em cenários de sincronização, por exemplo, evento System Connect e User, quando o servidor pode verificar e negar a solicitação do cliente ou enviar mensagem diretamente para o cliente de solicitação. Na linguagem JavaScript fracamente tipada, ela é desserializada em relação às chaves de objeto. E EventErrorResponse tem a prioridade mais alta em comparação com objetos rest, que se code estiver no retorno, então ele é analisado EventErrorResponse e a conexão do cliente é descartada.

app.generic('message', {
    trigger: wpsTrigger,
    handler: async (request, context) => {
          return { 
              "data": "ack",
              "dataType" : "text"
          };
    }
});

Defina a ligação de gatilho em function.json.

{
  "disabled": false,
  "bindings": [
    {
      "type": "webPubSubTrigger",
      "direction": "in",
      "name": "data",
      "hub": "<hub>",
      "eventName": "message",
      "eventType": "user"
    }
  ]
}

Definir função em index.js.

module.exports = function (context, data) {
  context.log('Request from: ', context.bindingData.request.connectionContext.userId);
  context.log('Request message data: ', data);
  context.log('Request message dataType: ', context.bindingData.request.dataType);
}

module.exports = async function (context) {
  return { 
    "data": "ack",
    "dataType" : "text"
  };
}

Atributos e anotações

Em bibliotecas de classes C#, use o atributo WebPubSubTrigger .

Aqui está um WebPubSubTrigger atributo em uma assinatura de método:

[FunctionName("WebPubSubTrigger")]
public static void Run([WebPubSubTrigger("<hub>", <WebPubSubEventType>, "<event-name>")] 
    WebPubSubConnectionContext context, ILogger log)
{
    ...
}

Para obter um exemplo completo, consulte Exemplo de C#.

Configuração

A tabela a seguir explica as propriedades de configuração de associação definidas no arquivo function.json .

function.json propriedade	Propriedade Attribute	Description
type	n/d	Obrigatório - deve ser definido como `webPubSubTrigger`.
direção	n/d	Obrigatório - deve ser definido como `in`.
Designação	n/d	Obrigatório - o nome da variável usada no código de função para o parâmetro que recebe os dados do evento.
hub	Hub	Obrigatório - o valor deve ser definido como o nome do hub Web PubSub para que a função seja acionada. Suportamos definir o valor no atributo como prioridade mais alta, ou ele pode ser definido nas configurações do aplicativo como um valor global.
eventType	WebPubSubEventType	Obrigatório - o valor deve ser definido como o tipo de evento de mensagens para que a função seja acionada. O valor deve ser ou `user` `system`.
nome_do_evento	EventName	Obrigatório - o valor deve ser definido como o evento de mensagens para que a função seja acionada. Para `system` o tipo de evento, o nome do evento deve estar em `connect`, `connected`, `disconnected`. Para subprotocolos definidos pelo usuário, o nome do evento é `message`. Para o subprotocolo `json.webpubsub.azure.v1.`suportado pelo sistema, o nome do evento é o nome do evento definido pelo usuário.
conexão	Connection	Opcional - o nome de uma coleção de configurações ou configurações de aplicativo que especifica o serviço Azure Web PubSub upstream. O valor é usado para validação de assinatura. E o valor é resolvido automaticamente com as configurações do aplicativo "WebPubSubConnectionString" por padrão. E `null` significa que a validação não é necessária e sempre bem-sucedida.

Utilizações

Em C#, WebPubSubEventRequest é o parâmetro de vinculação reconhecido do tipo, os parâmetros rest são vinculados pelo nome do parâmetro. Verifique a tabela abaixo dos parâmetros e tipos disponíveis.

Em linguagem fracamente tipada como JavaScript, name in function.json é usado para vincular o objeto trigger em relação à tabela de mapeamento abaixo. E respeite dataType para converter a mensagem de function.json acordo quando name é definido como data o objeto de ligação para entrada de gatilho. Todos os parâmetros podem ser lidos context.bindingData.<BindingName> e é JObject convertido.

Nome da vinculação	Tipo de Enlace	Description	Propriedades
pedido	`WebPubSubEventRequest`	Descreve a solicitação upstream	A propriedade difere por diferentes tipos de eventos, incluindo classes `ConnectEventRequest`derivadas , `ConnectedEventRequestUserEventRequest` e`DisconnectedEventRequest`
connectionContext	`WebPubSubConnectionContext`	Pedido comum de informações	EventType, EventName, Hub, ConnectionId, UserId, Cabeçalhos, Origem, Assinatura, Estados
dados	`BinaryData`,`string`,`Stream`,`byte[]`	Solicitar dados de mensagem do cliente no evento do usuário `message`	-
Tipo de dados	`WebPubSubDataType`	Request message dataType, que suporta `binary`, `text`, `json`	-
afirmações	`IDictionary<string, string[]>`	Declarações do usuário na solicitação do sistema `connect`	-
query	`IDictionary<string, string[]>`	Consulta do usuário na solicitação do sistema `connect`	-
Subprotocolos	`IList<string>`	Subprotocolos disponíveis na solicitação do sistema `connect`	-
clientCertificados	`IList<ClientCertificate>`	Uma lista de impressão digital de certificado de clientes na solicitação do sistema `connect`	-
reason	`string`	Motivo na solicitação do sistema `disconnected`	-

Importante

Em C#, vários tipos de parâmetro suportados DEVEM ser colocados no primeiro, ou seja, ou data aquele diferente do tipo padrão BinaryData para tornar a função vinculante corretamente. request

Resposta de retorno

WebPubSubTrigger respeita a resposta retornada do cliente para eventos síncronos de e evento do connect usuário. Apenas a resposta correspondente é enviada de volta ao serviço, caso contrário, é ignorada. Além disso, WebPubSubTrigger o objeto de retorno suporta usuários para SetState() e ClearStates() para gerenciar os metadados para a conexão. E a extensão mescla os resultados do valor de retorno com os originais da solicitação WebPubSubConnectionContext.States. O valor na chave existente é substituído e o valor na nova chave é adicionado.

Tipo de Retorno	Description	Propriedades
`ConnectEventResponse`	Resposta ao `connect` evento	Grupos, Funções, UserId, Subprotocolo
`UserEventResponse`	Resposta para evento do usuário	DataType, Dados
`EventErrorResponse`	Resposta de erro para o evento de sincronização	Código, ErrorMessage
`*WebPubSubEventResponse`	Tipo de resposta de base dos suportados usados para casos de retorno incerto	-

Vinculação de entrada

Nossa extensão fornece duas ligações de entrada direcionadas para necessidades diferentes.

WebPubSubConnection

Para permitir que um cliente se conecte ao Serviço Azure Web PubSub, ele deve saber a URL do ponto de extremidade do serviço e um token de acesso válido. A WebPubSubConnection ligação de entrada produz as informações necessárias, portanto, o cliente não precisa lidar com essa geração de token em si. Como o token é limitado no tempo e pode ser usado para autenticar um usuário específico em uma conexão, não armazene o token em cache ou compartilhe-o entre clientes. Um gatilho HTTP trabalhando com essa ligação de entrada pode ser usado para que os clientes recuperem as informações de conexão.
WebPubSubContext

Quando o uso é Static Web Apps, HttpTrigger é o único gatilho suportado e no cenário Web PubSub, fornecemos a WebPubSubContext ligação de entrada ajuda os usuários a desserializar a solicitação http upstream do lado do serviço em protocolos Web PubSub. Assim, os clientes podem obter resultados semelhantes em comparação com WebPubSubTrigger o fácil manuseio em funções. Veja exemplos abaixo. Quando usado com HttpTriggero , o cliente precisa configurar a URL exposta HttpTrigger no manipulador de eventos de acordo.

Exemplo - `WebPubSubConnection`

O exemplo a seguir mostra uma função C# que adquire informações de conexão Web PubSub usando a associação de entrada e as retorna por HTTP. No exemplo abaixo, o UserId é passado através da parte de consulta de solicitação do cliente como ?userid={User-A}.

[FunctionName("WebPubSubConnectionInputBinding")]
public static WebPubSubConnection Run(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")] HttpRequest req,
    [WebPubSubConnection(Hub = "<hub>", UserId = "{query.userid}")] WebPubSubConnection connection)
{
    return connection;
}

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

const connection = input.generic({
    type: 'webPubSubConnection',
    name: 'connection',
    userId: '{query.userId}',
    hub: '<hub>'
});

app.http('negotiate', {
    methods: ['GET', 'POST'],
    authLevel: 'anonymous',
    extraInputs: [connection],
    handler: async (request, context) => {
        return { body: JSON.stringify(context.extraInputs.get('connection')) };
    },
});

Defina associações de entrada em function.json.

{
  "disabled": false,
  "bindings": [
    {
      "authLevel": "anonymous",
      "type": "httpTrigger",
      "direction": "in",
      "name": "req"
    },
    {
      "type": "http",
      "direction": "out",
      "name": "res"
    },
    {
      "type": "webPubSubConnection",
      "name": "connection",
      "userId": "{query.userid}",
      "hub": "<hub>",
      "direction": "in"
    }
  ]
}

Definir função em index.js.

module.exports = function (context, req, connection) {
  context.res = { body: connection };
  context.done();
};

Tokens autenticados

Se a função for acionada por um cliente autenticado, você poderá adicionar uma declaração de ID de usuário ao token gerado. Você pode facilmente adicionar autenticação a um aplicativo de função usando a Autenticação do Serviço de Aplicativo.

A Autenticação do Serviço de Aplicativo define cabeçalhos HTTP nomeados x-ms-client-principal-id e x-ms-client-principal-name que contêm o ID principal e o nome do cliente do usuário autenticado, respectivamente.

Você pode definir a propriedade UserId da associação para o valor de qualquer cabeçalho usando uma expressão de ligação: {headers.x-ms-client-principal-id} ou {headers.x-ms-client-principal-name}.

[FunctionName("WebPubSubConnectionInputBinding")]
public static WebPubSubConnection Run(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")] HttpRequest req,
    [WebPubSubConnection(Hub = "<hub>", UserId = "{headers.x-ms-client-principal-name}")] WebPubSubConnection connection)
{
    return connection;
}

Nota

Limitado aos tipos de parâmetros de vinculação não suportam uma maneira de passar lista nem matriz, o não é totalmente suportado com todos os parâmetros que o WebPubSubConnection SDK do servidor tem, especialmente roles, e também inclui groups e expiresAfter. Caso o cliente precise adicionar funções ou atrasar a criação do token de acesso na função, sugere-se trabalhar com o SDK do servidor para C#.

[FunctionName("WebPubSubConnectionCustomRoles")]
public static async Task<Uri> Run(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")] HttpRequest req)
{
    var serviceClient = new WebPubSubServiceClient(new Uri(endpoint), "<hub>", "<web-pubsub-connection-string>");
    var userId = req.Query["userid"].FirstOrDefault();
    // your method to get custom roles.
    var roles = GetRoles(userId);
    return await serviceClient.GetClientAccessUriAsync(TimeSpan.FromMinutes(5), userId, roles);
}

Nota

const { app } = require('@azure/functions');
const { WebPubSubServiceClient } = require('@azure/web-pubsub');
app.http('negotiate', {
    methods: ['GET', 'POST'],
    authLevel: 'anonymous',
    handler: async (request, context) => {
        const serviceClient = new WebPubSubServiceClient(process.env.WebPubSubConnectionString, "<hub>");
        let token = await serviceClient.getAuthenticationToken({ userId: req.query.userid, roles: ["webpubsub.joinLeaveGroup", "webpubsub.sendToGroup"] });
        return { body: token.url };
    },
});

Nota

Defina associações de entrada em function.json.

{
  "disabled": false,
  "bindings": [
    {
      "authLevel": "anonymous",
      "type": "httpTrigger",
      "direction": "in",
      "name": "req"
    },
    {
      "type": "http",
      "direction": "out",
      "name": "res"
    }
  ]
}

Definir função em index.js.

const { WebPubSubServiceClient } = require('@azure/web-pubsub');

module.exports = async function (context, req) {
  const serviceClient = new WebPubSubServiceClient(process.env.WebPubSubConnectionString, "<hub>");
  let token = await serviceClient.getAuthenticationToken({ userId: req.query.userid, roles: ["webpubsub.joinLeaveGroup", "webpubsub.sendToGroup"] });
  context.res = { body: token.url };
  context.done();
};

Exemplo - `WebPubSubContext`

O exemplo a seguir mostra uma função C# que adquire informações de solicitação upstream do Web PubSub usando a associação de entrada em connect tipo de evento e as retorna por HTTP.

[FunctionName("WebPubSubContextInputBinding")]
public static object Run(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")] HttpRequest req,
    [WebPubSubContext] WebPubSubContext wpsContext)
{
    // in the case request is a preflight or invalid, directly return prebuild response by extension.
    if (wpsContext.IsPreflight || wpsContext.HasError)
    {
        return wpsContext.Response;
    }
    var request = wpsContext.Request as ConnectEventRequest;
    var response = new ConnectEventResponse
    {
        UserId = wpsContext.Request.ConnectionContext.UserId
    };
    return response;
}

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

const wpsContext = input.generic({
    type: 'webPubSubContext',
    name: 'wpsContext'
});

app.http('connect', {
    methods: ['GET', 'POST'],
    authLevel: 'anonymous',
    extraInputs: [wpsContext],
    handler: async (request, context) => {
        var wpsRequest = context.extraInputs.get('wpsContext');

        return { "userId": wpsRequest.request.connectionContext.userId };
    }
});

Defina associações de entrada em function.json.

{
  "disabled": false,
  "bindings": [
    {
      "authLevel": "anonymous",
      "type": "httpTrigger",
      "direction": "in",
      "name": "req",
      "methods": ["get", "post"]
    },
    {
      "type": "http",
      "direction": "out",
      "name": "$return"
    },
    {
      "type": "webPubSubContext",
      "name": "wpsContext",
      "direction": "in"
    }
  ]
}

Definir função em index.js.

module.exports = async function (context, req, wpsContext) {
  // in the case request is a preflight or invalid, directly return prebuild response by extension.
  if (wpsContext.hasError || wpsContext.isPreflight)
  {
    return wpsContext.response;
  }
  // return an http response with connect event response as body.
  return { body: {"userId": wpsContext.connectionContext.userId} };
};

Configuração

WebPubSubConexão

A tabela a seguir explica as propriedades de configuração de associação definidas no arquivo function.json e no WebPubSubConnection atributo.

function.json propriedade	Propriedade Attribute	Description
type	n/d	Deve ser definido como `webPubSubConnection`
direção	n/d	Deve ser definido como `in`
Designação	n/d	Nome da variável usado no código da função para o objeto de ligação de conexão de entrada.
hub	Hub	Obrigatório - O valor deve ser definido como o nome do hub Web PubSub para que a função seja acionada. Suportamos definir o valor no atributo como prioridade mais alta, ou ele pode ser definido nas configurações do aplicativo como um valor global.
userId	UserId	Opcional - o valor da declaração de identificador de usuário a ser definido no token de chave de acesso.
conexão	Connection	Obrigatório - O nome da configuração do aplicativo que contém a cadeia de conexão do Serviço Web PubSub (o padrão é "WebPubSubConnectionString").

WebPubSubContext

A tabela a seguir explica as propriedades de configuração de associação definidas no arquivo functions.json e no WebPubSubContext atributo.

function.json propriedade	Propriedade Attribute	Description
type	n/d	Deve ser definido como `webPubSubContext`.
direção	n/d	Deve ser definido como `in`.
Designação	n/d	Nome da variável usado no código de função para a solicitação Web PubSub de entrada.
conexão	Connection	Opcional - o nome de uma coleção de configurações ou configurações de aplicativo que especifica o serviço Azure Web PubSub upstream. O valor é usado para Proteção contra abuso e validação de assinatura. O valor é resolvido automaticamente com "WebPubSubConnectionString" por padrão. E `null` significa que a validação não é necessária e sempre bem-sucedida.

Utilização

WebPubSubConexão

WebPubSubConnection fornece as propriedades abaixo.

Nome da vinculação	Tipo de Enlace	Description
BaseUri	URI	Uri de conexão do cliente Web PubSub.
URI	URI	Uri absoluto da conexão Web PubSub, contém `AccessToken` a base gerada na solicitação.
AccessToken	string	Gerado `AccessToken` com base na solicitação UserId e informações de serviço.

WebPubSubConnection fornece as propriedades abaixo.

Nome da vinculação	Description
baseUrl	Uri de conexão do cliente Web PubSub.
url	Uri absoluto da conexão Web PubSub, contém `AccessToken` a base gerada na solicitação.
accessToken	Gerado `AccessToken` com base na solicitação UserId e informações de serviço.

WebPubSubConnection fornece as propriedades abaixo.

Nome da vinculação	Description
baseUrl	Uri de conexão do cliente Web PubSub.
url	Uri absoluto da conexão Web PubSub, contém `AccessToken` a base gerada na solicitação.
accessToken	Gerado `AccessToken` com base na solicitação UserId e informações de serviço.

WebPubSubContext

WebPubSubContext fornece as propriedades abaixo.

Nome da vinculação	Tipo de Enlace	Description	Propriedades
pedido	`WebPubSubEventRequest`	Solicitação do cliente, consulte a tabela abaixo para obter detalhes.	`WebPubSubConnectionContext` do cabeçalho da solicitação e outras propriedades desserializadas do corpo da solicitação Descreva a solicitação, por exemplo, `Reason` para `DisconnectedEventRequest`.
resposta	`HttpResponseMessage`	A extensão cria resposta principalmente para `AbuseProtection` casos e erros.	-
errorMessage	string	Descreva os detalhes do erro ao processar a solicitação upstream.	-
hasError	booleano	Sinalizador para indicar se é uma solicitação upstream válida do Web PubSub.	-
isComprovação	booleano	Sinalizar para indicar se é uma solicitação de comprovação de `AbuseProtection`.	-

Para WebPubSubEventRequesto , ele é desserializado para classes diferentes que fornecem informações diferentes sobre o cenário de solicitação. Para PreflightRequest casos válidos ou não, o usuário pode verificar as bandeiras IsPreflight e HasError saber. Sugere-se retornar a resposta WebPubSubContext.Response de compilação do sistema diretamente, ou o cliente pode registrar erros sob demanda. Em diferentes cenários, o cliente pode ler as propriedades da solicitação como abaixo.

Classe derivada	Description	Propriedades
`PreflightRequest`	Usado em `AbuseProtection` quando `IsPreflight` é verdadeiro	-
`ConnectEventRequest`	Usado no tipo de evento do sistema `Connect`	Declarações, Consulta, Subprotocolos, ClientCertificates
`ConnectedEventRequest`	Usado no tipo de evento do sistema `Connected`	-
`UserEventRequest`	Usado no tipo de evento do usuário	Dados, DataType
`DisconnectedEventRequest`	Usado no tipo de evento do sistema `Disconnected`	Razão

Nota

Embora o é uma ligação de entrada fornece uma maneira de desserialização de solicitação semelhante em HttpTrigger comparação com WebPubSubTriggero , há limitações, ou seja, o WebPubSubContext estado da conexão pós-mesclagem não é suportado. A resposta de retorno ainda é respeitada pelo lado do serviço, mas os usuários precisam criar a resposta por conta própria. Se os usuários tiverem necessidade de definir a resposta do evento, você deverá retornar um contém ConnectEventResponse ou mensagens para o evento do usuário como corpo de resposta e colocar o HttpResponseMessage estado da conexão com a chave ce-connectionstate no cabeçalho da resposta.

Vinculação de saída

Use a associação de saída Web PubSub para invocar o serviço Azure Web PubSub para fazer algo. Você pode transmitir uma mensagem para:

Todos os clientes conectados
Clientes conectados autenticados para um usuário específico
Clientes conectados ingressaram em um grupo específico
Uma conexão de cliente específica

A associação de saída também permite gerenciar clientes e grupos, bem como conceder/revogar permissões direcionadas a connectionId específicos com grupo.

Adicionar ligação ao grupo
Adicionar usuário ao grupo
Remover conexão de um grupo
Remover usuário de um grupo
Remover usuário de todos os grupos
Feche todas as conexões do cliente
Fechar uma conexão de cliente específica
Fechar conexões em um grupo
Conceder permissão de uma conexão
Revogar a permissão de uma conexão

Para obter informações sobre detalhes de instalação e configuração, consulte a visão geral.

Exemplo

[FunctionName("WebPubSubOutputBinding")]
public static async Task RunAsync(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")] HttpRequest req,
    [WebPubSub(Hub = "<hub>")] IAsyncCollector<WebPubSubAction> actions)
{
    await actions.AddAsync(WebPubSubAction.CreateSendToAllAction("Hello Web PubSub!", WebPubSubDataType.Text));
}

const { app, output } = require('@azure/functions');
const wpsMsg = output.generic({
    type: 'webPubSub',
    name: 'actions',
    hub: '<hub>',
});

app.http('message', {
    methods: ['GET', 'POST'],
    authLevel: 'anonymous',
    extraOutputs: [wpsMsg],
    handler: async (request, context) => {
        context.extraOutputs.set(wpsMsg, [{
            "actionName": "sendToAll",
            "data": `Hello world`,
            "dataType": `text`
        }]);
    }
});

Defina associações em functions.json.

{
  "disabled": false,
  "bindings": [
    {
      "type": "webPubSub",
      "name": "actions",
      "hub": "<hub>",
      "direction": "out"
    }
  ]
}

Definir função em index.js.

module.exports = async function (context) {
  context.bindings.actions = {
    "actionName": "sendToAll",
    "data": "hello",
    "dataType": "text"
  };
  context.done();
}

WebPubSubAction

WebPubSubAction é o tipo abstrato base de ligações de saída. Os tipos derivados representam a ação que o servidor deseja que o serviço invoque.

Na linguagem C#, fornecemos alguns métodos estáticos para WebPubSubAction ajudar a descobrir as ações disponíveis. Por exemplo, o usuário pode criar o SendToAllAction por chamada WebPubSubAction.CreateSendToAllAction().

Classe derivada	Propriedades
`SendToAllAction`	Dados, DataType, Excluídos
`SendToGroupAction`	Grupo, Dados, DataType, Excluído
`SendToUserAction`	UserId, Dados, DataType
`SendToConnectionAction`	ConnectionId, Dados, DataType
`AddUserToGroupAction`	UserId, Grupo
`RemoveUserFromGroupAction`	UserId, Grupo
`RemoveUserFromAllGroupsAction`	UserId
`AddConnectionToGroupAction`	ConnectionId, Grupo
`RemoveConnectionFromGroupAction`	ConnectionId, Grupo
`CloseAllConnectionsAction`	Excluído, Razão
`CloseClientConnectionAction`	ConnectionId, Razão
`CloseGroupConnectionsAction`	Grupo, Excluído, Razão
`GrantPermissionAction`	ConnectionId, Permissão, TargetName
`RevokePermissionAction`	ConnectionId, Permissão, TargetName

Em linguagem fracamente tipada como javascript, actionName é o parâmetro chave para resolver o tipo, as ações disponíveis estão listadas abaixo.

ActionName	Propriedades
`sendToAll`	Dados, DataType, Excluídos
`sendToGroup`	Grupo, Dados, DataType, Excluído
`sendToUser`	UserId, Dados, DataType
`sendToConnection`	ConnectionId, Dados, DataType
`addUserToGroup`	UserId, Grupo
`removeUserFromGroup`	UserId, Grupo
`removeUserFromAllGroups`	UserId
`addConnectionToGroup`	ConnectionId, Grupo
`removeConnectionFromGroup`	ConnectionId, Grupo
`closeAllConnections`	Excluído, Razão
`closeClientConnection`	ConnectionId, Razão
`closeGroupConnections`	Grupo, Excluído, Razão
`grantPermission`	ConnectionId, Permissão, TargetName
`revokePermission`	ConnectionId, Permissão, TargetName

Importante

A propriedade message data nas ações relacionadas a enviar mensagem deve ser string se o tipo de dados estiver definido como json ou text para evitar ambiguidade na conversão de dados. Por favor, use JSON.stringify() para converter o objeto json em necessidade. Isso é aplicado a qualquer lugar usando a propriedade message, por exemplo, UserEventResponse.Data trabalhando com WebPubSubTrigger.

Quando o tipo de dados é definido como binary, é permitido aproveitar a vinculação naturalmente suportadadataType, conforme binary configurado no , consulte Definições de gatilho function.jsone vinculação para obter detalhes.

Em linguagem fracamente tipada como javascript, actionName é o parâmetro chave para resolver o tipo, as ações disponíveis estão listadas abaixo.

ActionName	Propriedades
`sendToAll`	Dados, DataType, Excluídos
`sendToGroup`	Grupo, Dados, DataType, Excluído
`sendToUser`	UserId, Dados, DataType
`sendToConnection`	ConnectionId, Dados, DataType
`addUserToGroup`	UserId, Grupo
`removeUserFromGroup`	UserId, Grupo
`removeUserFromAllGroups`	UserId
`addConnectionToGroup`	ConnectionId, Grupo
`removeConnectionFromGroup`	ConnectionId, Grupo
`closeAllConnections`	Excluído, Razão
`closeClientConnection`	ConnectionId, Razão
`closeGroupConnections`	Grupo, Excluído, Razão
`grantPermission`	ConnectionId, Permissão, TargetName
`revokePermission`	ConnectionId, Permissão, TargetName

Importante

Configuração

WebPubSub

A tabela a seguir explica as propriedades de configuração de associação definidas no arquivo function.json e no WebPubSub atributo.

function.json propriedade	Propriedade Attribute	Description
type	n/d	Deve ser definido como `webPubSub`
direção	n/d	Deve ser definido como `out`
Designação	n/d	Nome da variável usado no código da função para o objeto de vinculação de saída.
hub	Hub	O valor deve ser definido como o nome do hub Web PubSub para que a função seja acionada. Suportamos definir o valor no atributo como prioridade mais alta, ou ele pode ser definido nas configurações do aplicativo como um valor global.
conexão	Connection	O nome da configuração do aplicativo que contém a cadeia de conexão do Serviço Web PubSub (o padrão é "WebPubSubConnectionString").

Resolução de Problemas

Configurando o registro em log do console

Você também pode habilitar facilmente o registro do console se quiser se aprofundar nas solicitações que está fazendo contra o serviço.

Próximos passos

Use estes recursos para começar a criar seu próprio aplicativo:

Tutorial: Publicar e subscrever mensagens no Azure Web PubSub

Tutorial: Criar uma sala de chat simples com o Azure Web PubSub

Tutorial: Usar um subprotocolo suportado por serviço para streaming de cliente

Tutorial: Criar chat sem servidor com o Azure Functions e o Web PubSub

Tutorial: Configurar um ouvinte de eventos

Jogue com demonstrações ao vivo

Explore mais exemplos do Azure Web PubSub

Partilhar via

Gatilho e associações do Azure Web PubSub para o Azure Functions

Adicionar à sua aplicação Funções

Conceitos-chave

Vinculação de gatilho

Exemplo

Atributos e anotações

Configuração

Utilizações

Resposta de retorno

Vinculação de entrada

Exemplo - `WebPubSubConnection`

Tokens autenticados

Exemplo - `WebPubSubContext`

Configuração

WebPubSubConexão

WebPubSubContext

Utilização

WebPubSubConexão

WebPubSubContext

Vinculação de saída

Exemplo

WebPubSubAction

Configuração

WebPubSub

Resolução de Problemas

Configurando o registro em log do console

Próximos passos

Comentários

Recursos adicionais

Partilhar via

Gatilho e associações do Azure Web PubSub para o Azure Functions

Adicionar à sua aplicação Funções

Conceitos-chave

Vinculação de gatilho

Exemplo

Atributos e anotações

Configuração

Utilizações

Resposta de retorno

Vinculação de entrada

Exemplo - WebPubSubConnection

Tokens autenticados

Exemplo - WebPubSubContext

Configuração

WebPubSubConexão

WebPubSubContext

Utilização

WebPubSubConexão

WebPubSubContext

Vinculação de saída

Exemplo

WebPubSubAction

Configuração

WebPubSub

Resolução de Problemas

Configurando o registro em log do console

Próximos passos

Comentários

Recursos adicionais

Exemplo - `WebPubSubConnection`

Exemplo - `WebPubSubContext`