Inicio rápido: creación de una aplicación sin servidor mediante Azure Functions y Azure SignalR Service

Crear proyecto de Azure Function

Creación de un proyecto local de Azure Function.

1. Desde la línea de comandos, cree un directorio para el proyecto.
2. Cambie al directorio del proyecto.
3. Use el comando func init de Azure Functions para inicializar el proyecto de función.

# Initialize a function project
func init --worker-runtime python

Creación de las funciones

Después de inicializar un proyecto, tendrá que crear funciones. Este proyecto requiere tres funciones:

• index: hospeda una página web para un cliente.
• negotiate: permite que un cliente obtenga un token de acceso.
• broadcast: usa un desencadenador de tiempo para difundir periódicamente mensajes a todos los clientes.

Al ejecutar el comando func new desde el directorio raíz del proyecto, Azure Functions Core Tools anexa el código de función en el archivo function_app.py. Editará el contenido de anuncios de parámetros según sea necesario reemplazando el código predeterminado por el código de la aplicación.

Creación de la función de índice

Puede usar esta función de ejemplo como plantilla para sus propias funciones.

Abra el archivo function_app.py . Este archivo contendrá las funciones. En primer lugar, modifique el archivo para incluir las instrucciones de importación necesarias y defina las variables globales que usaremos en las siguientes funciones.

import azure.functions as func
import os
import requests
import json 

app = func.FunctionApp()

etag = ''
start_count = 0

2. Agregue la función index agregando el código siguiente

@app.route(route="index", auth_level=func.AuthLevel.ANONYMOUS)
def index(req: func.HttpRequest) -> func.HttpResponse:
    f = open(os.path.dirname(os.path.realpath(__file__)) + '/content/index.html')
    return func.HttpResponse(f.read(), mimetype='text/html')

Esta función hospeda una página web para un cliente.

Creación de la función negotiate

Agregue la función negotiate agregando el código siguiente

@app.route(route="negotiate", auth_level=func.AuthLevel.ANONYMOUS, methods=["POST"])
@app.generic_input_binding(arg_name="connectionInfo", type="signalRConnectionInfo", hubName="serverless", connectionStringSetting="AzureSignalRConnectionString")
def negotiate(req: func.HttpRequest, connectionInfo) -> func.HttpResponse:
    return func.HttpResponse(connectionInfo)

Esta función permite a un cliente obtener un token de acceso.

Cree una función de difusión.

Agregue la función broadcast agregando el código siguiente

@app.timer_trigger(schedule="*/1 * * * *", arg_name="myTimer",
              run_on_startup=False,
              use_monitor=False)
@app.generic_output_binding(arg_name="signalRMessages", type="signalR", hubName="serverless", connectionStringSetting="AzureSignalRConnectionString")
def broadcast(myTimer: func.TimerRequest, signalRMessages: func.Out[str]) -> None:
    global etag
    global start_count
    headers = {'User-Agent': 'serverless', 'If-None-Match': etag}
    res = requests.get('https://api.github.com/repos/azure/azure-functions-python-worker', headers=headers)
    if res.headers.get('ETag'):
        etag = res.headers.get('ETag')

    if res.status_code == 200:
        jres = res.json()
        start_count = jres['stargazers_count']

    signalRMessages.set(json.dumps({
        'target': 'newMessage',
        'arguments': [ 'Current star count of https://api.github.com/repos/azure/azure-functions-python-worker is: ' + str(start_count) ]
    }))

Esta función usa un desencadenador de hora para difundir periódicamente mensajes a todos los clientes.

Crear proyecto de Azure Function

Creación de un proyecto local de Azure Function.

1. Desde la línea de comandos, cree un directorio para el proyecto.
2. Cambie al directorio del proyecto.
3. Use el comando func init de Azure Functions para inicializar el proyecto de función.

# Initialize a function project
func init --worker-runtime python --model v1

Creación de las funciones

Después de inicializar un proyecto, tendrá que crear funciones. Este proyecto requiere tres funciones:

• index: hospeda una página web para un cliente.
• negotiate: permite que un cliente obtenga un token de acceso.
• broadcast: usa un desencadenador de tiempo para difundir periódicamente mensajes a todos los clientes.

Al ejecutar el comando func new desde el directorio raíz del proyecto, Azure Functions Core Tools creará archivos de origen de función predeterminados y los almacenará en una carpeta denominada como la función. Editará los archivos según sea necesario reemplazando el código predeterminado por el código de la aplicación.

Creación de la función de índice

Puede usar esta función de ejemplo como plantilla para sus propias funciones.

1. Ejecute el siguiente comando para crear la función index.

func new -n index -t HttpTrigger

1. Edite index/function.json y reemplace el contenido por el código json siguiente:

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

1. Edite index/_init_.py y reemplace el contenido por el código siguiente:

import os

import azure.functions as func

def main(req: func.HttpRequest) -> func.HttpResponse:
    f = open(os.path.dirname(os.path.realpath(__file__)) + '/../content/index.html')
    return func.HttpResponse(f.read(), mimetype='text/html')

Creación de la función negotiate

1. Ejecute el siguiente comando para crear la función negotiate.

func new -n negotiate -t HttpTrigger

1. Edite negotiate/function.json y reemplace el contenido por el código json siguiente:

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "authLevel": "anonymous",
      "type": "httpTrigger",
      "direction": "in",
      "name": "req",
      "methods": [
        "post"
      ]
    },
    {
      "type": "http",
      "direction": "out",
      "name": "$return"
    },
    {
      "type": "signalRConnectionInfo",
      "name": "connectionInfo",
      "hubName": "serverless",
      "connectionStringSetting": "AzureSignalRConnectionString",
      "direction": "in"
    }
  ]
}

1. Edite negotiate/_init_.py y reemplace el contenido por el código siguiente:

import azure.functions as func


def main(req: func.HttpRequest, connectionInfo) -> func.HttpResponse:
    return func.HttpResponse(connectionInfo)

Cree una función de difusión.

1. Ejecute el siguiente comando para crear la función broadcast.

func new -n broadcast -t TimerTrigger
# install requests
pip install requests

1. Edite broadcast/function.json y reemplace el contenido por el código siguiente:

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "myTimer",
      "type": "timerTrigger",
      "direction": "in",
      "schedule": "*/5 * * * * *"
    },
    {
      "type": "signalR",
      "name": "signalRMessages",
      "hubName": "serverless",
      "connectionStringSetting": "AzureSignalRConnectionString",
      "direction": "out"
    }
  ]
}

1. Edite broadcast/_init_.py y reemplace el contenido por el código siguiente:

import requests
import json

import azure.functions as func

etag = ''
start_count = 0

def main(myTimer: func.TimerRequest, signalRMessages: func.Out[str]) -> None:
    global etag
    global start_count
    headers = {'User-Agent': 'serverless', 'If-None-Match': etag}
    res = requests.get('https://api.github.com/repos/azure/azure-signalr', headers=headers)
    if res.headers.get('ETag'):
        etag = res.headers.get('ETag')

    if res.status_code == 200:
        jres = res.json()
        start_count = jres['stargazers_count']

    signalRMessages.set(json.dumps({
        'target': 'newMessage',
        'arguments': [ 'Current star count of https://github.com/Azure/azure-signalr is: ' + str(start_count) ]
    }))