Deel 4: Voorbeeld van de implementatie van de hoofdtoepassing

Vorig deel: API-implementatie van derden

De hoofd-app in dit scenario is een eenvoudige Flask-app die u implementeert in Azure App Service. De app biedt een openbaar API-eindpunt met de naam /api/v1/getcode, waarmee een code wordt gegenereerd voor een ander doel in de app (bijvoorbeeld met tweeledige verificatie voor menselijke gebruikers). De hoofd-app biedt ook een eenvoudige startpagina die een koppeling naar het API-eindpunt weergeeft.

Het inrichtingsscript van het voorbeeld voert de volgende stappen uit:

  1. Maak de App Service-host en implementeer de code met behulp van de opdracht Azure CLI. az webapp up

  2. Maak een Azure Storage-account voor de hoofd-app met behulp van az storage account create.

  3. Maak een wachtrij in het opslagaccount met de naam 'code-requests' met behulp van az storage queue create.

  4. Om ervoor te zorgen dat de app naar de wachtrij kan schrijven, gebruikt u az role assignment create om de rol Inzender van opslagwachtrijgegevens toe te wijzen aan de app. Zie Rolmachtigingen toewijzen met behulp van de Azure CLI voor meer informatie over rollen.

De hoofd-app-code is als volgt. In de volgende onderdelen van deze reeks vindt u uitleg over belangrijke details.

from flask import Flask, request, jsonify
import requests, random, string, os
from datetime import datetime
from azure.keyvault.secrets import SecretClient
from azure.identity import DefaultAzureCredential
from azure.storage.queue import QueueClient

app = Flask(__name__)
app.config["DEBUG"] = True

number_url = os.environ["THIRD_PARTY_API_ENDPOINT"]

# Authenticate with Azure. First, obtain the DefaultAzureCredential
credential = DefaultAzureCredential()

# Next, get the client for the Key Vault. You must have first enabled managed identity
# on the App Service for the credential to authenticate with Key Vault.
key_vault_url = os.environ["KEY_VAULT_URL"]
keyvault_client = SecretClient(vault_url=key_vault_url, credential=credential)

# Obtain the secret: for this step to work you must add the app's service principal to
# the key vault's access policies for secret management.
api_secret_name = os.environ["THIRD_PARTY_API_SECRET_NAME"]
vault_secret = keyvault_client.get_secret(api_secret_name)

# The "secret" from Key Vault is an object with multiple properties. The key we
# want for the third-party API is in the value property. 
access_key = vault_secret.value

# Set up the Storage queue client to which we write messages
queue_url = os.environ["STORAGE_QUEUE_URL"]
queue_client = QueueClient.from_queue_url(queue_url=queue_url, credential=credential)


@app.route('/', methods=['GET'])
def home():
    return f'Home page of the main app. Make a request to <a href="./api/v1/getcode">/api/v1/getcode</a>.'


def random_char(num):
       return ''.join(random.choice(string.ascii_letters) for x in range(num))


@app.route('/api/v1/getcode', methods=['GET'])
def get_code():
    headers = {
        'Content-Type': 'application/json',
        'x-functions-key': access_key
        }

    r = requests.get(url = number_url, headers = headers)
    
    if (r.status_code != 200):       
        return "Could not get you a code.", r.status_code

    data = r.json()
    chars1 = random_char(3)
    chars2 = random_char(3)
    code_value = f"{chars1}-{data['value']}-{chars2}"
    code = { "code": code_value, "timestamp" : str(datetime.utcnow()) }

    # Log a queue message with the code for, say, a process that invalidates
    # the code after a certain period of time.
    queue_client.send_message(code)

    return jsonify(code)


if __name__ == '__main__':
    app.run()