Créer un service de webhook

L'agent prédéfini que vous avez créé à la dernière étape ne peut pas fournir de données dynamiques telles que des soldes de compte, car tout est codé en dur dans l'agent. Au cours de cette étape du tutoriel, vous allez créer un webhook pouvant fournir des données dynamiques à l'agent. Dans ce tutoriel, les fonctions Cloud Functions permettent d'héberger le webhook en raison de sa simplicité, mais il existe de nombreuses autres façons d'héberger un service de webhook. L'exemple fait également appel au langage de programmation Go, mais vous pouvez utiliser n'importe quel langage compatible avec Cloud Functions.

Créer la fonction

Vous pouvez créer des fonctions Cloud Functions à l'aide de la console Google Cloud (consulter la documentation, ouvrir la console). Pour créer une fonction pour ce tutoriel:

  1. Il est important que votre agent Dialogflow et la fonction se trouvent dans le même projet. Il s'agit du moyen le plus simple pour Dialogflow d'avoir un accès sécurisé à votre fonction. Avant de créer la fonction, sélectionnez votre projet dans la console Google Cloud.

    Accéder au sélecteur de projet

  2. Ouvrez la page de présentation de Cloud Functions.

    Accéder à la présentation de Cloud Functions

  3. Cliquez sur Créer une fonction et définissez les champs suivants:

    • Environnement: 1re génération
    • Nom de la fonction : "tutorial-banking-webhook"
    • Region (Région) : si vous avez spécifié une région pour votre agent, utilisez la même région.
    • HTTP Trigger type (Type de déclencheur HTTP) : HTTP
    • URL: cliquez sur le bouton "Copier" et enregistrez la valeur. Vous aurez besoin de cette URL pour configurer le webhook.
    • Authentification: requiert une authentification.
    • HTTPS requis: coché
  4. Cliquez sur Enregistrer.

  5. Cliquez sur Suivant. Vous n'avez pas besoin de paramètres d'exécution, de compilation, de connexions ou de sécurité spéciaux.

  6. Renseignez les champs ci-dessous comme suit :

    • Runtime (Environnement d'exécution) : sélectionnez le dernier environnement d'exécution Go.
    • Code source: éditeur intégré
    • Point d'entrée: HandleWebhookRequest
  7. Remplacez le code par ce qui suit:

    package estwh
    
    import (
    	"context"
    	"encoding/json"
    	"fmt"
    	"log"
    	"net/http"
    	"os"
    	"strings"
    
    	"cloud.google.com/go/spanner"
      "google.golang.org/grpc/codes"
    )
    
    // client is a Spanner client, created only once to avoid creation
    // for every request.
    // See: https://cloud.google.com/functions/docs/concepts/go-runtime#one-time_initialization
    var client *spanner.Client
    
    func init() {
    	// If using a database, these environment variables will be set.
    	pid := os.Getenv("PROJECT_ID")
    	iid := os.Getenv("SPANNER_INSTANCE_ID")
    	did := os.Getenv("SPANNER_DATABASE_ID")
    	if pid != "" && iid != "" && did != "" {
    		db := fmt.Sprintf("projects/%s/instances/%s/databases/%s",
    			pid, iid, did)
    		log.Printf("Creating Spanner client for %s", db)
    		var err error
    		// Use the background context when creating the client,
    		// but use the request context for calls to the client.
    		// See: https://cloud.google.com/functions/docs/concepts/go-runtime#contextcontext
    		client, err = spanner.NewClient(context.Background(), db)
    		if err != nil {
    			log.Fatalf("spanner.NewClient: %v", err)
    		}
    	}
    }
    
    type queryResult struct {
    	Action     string                 `json:"action"`
    	Parameters map[string]interface{} `json:"parameters"`
    }
    
    type text struct {
    	Text []string `json:"text"`
    }
    
    type message struct {
    	Text text `json:"text"`
    }
    
    // webhookRequest is used to unmarshal a WebhookRequest JSON object. Note that
    // not all members need to be defined--just those that you need to process.
    // As an alternative, you could use the types provided by
    // the Dialogflow protocol buffers:
    // https://godoc.org/google.golang.org/genproto/googleapis/cloud/dialogflow/v2#WebhookRequest
    type webhookRequest struct {
    	Session     string      `json:"session"`
    	ResponseID  string      `json:"responseId"`
    	QueryResult queryResult `json:"queryResult"`
    }
    
    // webhookResponse is used to marshal a WebhookResponse JSON object. Note that
    // not all members need to be defined--just those that you need to process.
    // As an alternative, you could use the types provided by
    // the Dialogflow protocol buffers:
    // https://godoc.org/google.golang.org/genproto/googleapis/cloud/dialogflow/v2#WebhookResponse
    type webhookResponse struct {
    	FulfillmentMessages []message `json:"fulfillmentMessages"`
    }
    
    // accountBalanceCheck handles the similar named action
    func accountBalanceCheck(ctx context.Context, request webhookRequest) (
    	webhookResponse, error) {
    	account := request.QueryResult.Parameters["account"].(string)
    	account = strings.ToLower(account)
    	var table string
    	if account == "savings account" {
    		table = "Savings"
    	} else {
    		table = "Checking"
    	}
    	s := "Your balance is $0"
    	if client != nil {
    		// A Spanner client exists, so access the database.
    		// See: https://pkg.go.dev/cloud.google.com/go/spanner#ReadOnlyTransaction.ReadRow
    		row, err := client.Single().ReadRow(ctx,
    			table,
    			spanner.Key{1}, // The account ID
    			[]string{"Balance"})
    		if err != nil {
    			if spanner.ErrCode(err) == codes.NotFound {
    				log.Printf("Account %d not found", 1)
    			} else {
    				return webhookResponse{}, err
    			}
    		} else {
    			// A row was returned, so check the value
    			var balance int64
    			err := row.Column(0, &balance)
    			if err != nil {
    				return webhookResponse{}, err
    			}
    			s = fmt.Sprintf("Your balance is $%.2f", float64(balance)/100.0)
    		}
    	}
    	response := webhookResponse{
    		FulfillmentMessages: []message{
    			{
    				Text: text{
    					Text: []string{s},
    				},
    			},
    		},
    	}
    	return response, nil
    }
    
    // Define a type for handler functions.
    type handlerFn func(ctx context.Context, request webhookRequest) (
    	webhookResponse, error)
    
    // Create a map from action to handler function.
    var handlers map[string]handlerFn = map[string]handlerFn{
    	"account.balance.check": accountBalanceCheck,
    }
    
    // handleError handles internal errors.
    func handleError(w http.ResponseWriter, err error) {
    	log.Printf("ERROR: %v", err)
    	http.Error(w,
    		fmt.Sprintf("ERROR: %v", err),
    		http.StatusInternalServerError)
    }
    
    // HandleWebhookRequest handles WebhookRequest and sends the WebhookResponse.
    func HandleWebhookRequest(w http.ResponseWriter, r *http.Request) {
    	var request webhookRequest
    	var response webhookResponse
    	var err error
    
    	// Read input JSON
    	if err = json.NewDecoder(r.Body).Decode(&request); err != nil {
    		handleError(w, err)
    		return
    	}
    	log.Printf("Request: %+v", request)
    
    	// Get the action from the request, and call the corresponding
    	// function that handles that action.
    	action := request.QueryResult.Action
    	if fn, ok := handlers[action]; ok {
    		response, err = fn(r.Context(), request)
    	} else {
    		err = fmt.Errorf("Unknown action: %s", action)
    	}
    	if err != nil {
    		handleError(w, err)
    		return
    	}
    	log.Printf("Response: %+v", response)
    
    	// Send response
    	if err = json.NewEncoder(w).Encode(&response); err != nil {
    		handleError(w, err)
    		return
    	}
    }
    
    

  8. Cliquez sur Déployer.

  9. Attendez que l'indicateur d'état indique que la fonction a bien été déployée. En attendant, examinez le code que vous venez de déployer.

Configurer le webhook pour votre agent

Maintenant que le webhook existe en tant que service, vous devez l'associer à votre agent. Pour ce faire, utilisez le fulfillment. Pour activer et gérer le fulfillment pour votre agent:

  1. Accédez à la console Dialogflow ES.
  2. Sélectionnez l'agent prédéfini que vous venez de créer.
  3. Dans le menu de la barre latérale de gauche, sélectionnez Fulfillment.
  4. Définissez le champ Webhook sur Enabled (Activé).
  5. Indiquez l'URL que vous avez copiée ci-dessus. Laissez tous les autres champs vides.
  6. Cliquez sur Enregistrer au bas de la page.

Capture d'écran de l'activation du fulfillment.

Maintenant que le fulfillment est activé pour l'agent, vous devez l'activer pour un intent:

  1. Cliquez sur Intents dans le menu de la barre latérale gauche.
  2. Sélectionnez l'intent account.balance.check.
  3. Faites défiler la page jusqu'à la section Fulfillment.
  4. Activez l'option Activer l'appel webhook pour cet intent.
  5. Cliquez sur Enregistrer.

Essayer l'agent

Votre agent est maintenant prêt à essayer. Cliquez sur le bouton Tester l'agent pour ouvrir le simulateur. Essayez d'avoir la conversation suivante avec l'agent:

Tour de conversation Vous Agent
1 Bonjour, Bonjour. Merci d'avoir choisi la banque ACME.
2 Je veux connaître le solde de mon compte Pour quel compte souhaitez-vous obtenir votre solde: épargne ou compte courant ?
3 Vérification… Voici votre dernier solde: 0,00 $

Au tour de conversation n° 3, vous avez fourni « vérification » comme type de compte. L'intent account.balance.check comporte un paramètre appelé account. Ce paramètre est défini sur "En cours de vérification" dans cette conversation. L'intent comporte également une valeur d'action "account.balance.check". Le service de webhook est appelé, et les valeurs de paramètre et d'action lui sont transmises.

Si vous examinez le code de webhook ci-dessus, vous constatez que cette action déclenche l'appel d'une fonction nommée similaire. La fonction détermine le solde du compte. La fonction vérifie si des variables d'environnement spécifiques sont définies avec des informations permettant de se connecter à la base de données. Si ces variables d'environnement ne sont pas définies, la fonction utilise un solde de compte codé en dur. Au cours des prochaines étapes, vous modifierez l'environnement de la fonction afin qu'elle récupère les données d'une base de données.

Dépannage

Le code de webhook inclut des instructions de journalisation. Si vous rencontrez des problèmes, essayez d'afficher les journaux de votre fonction.

Informations complémentaires

Pour en savoir plus sur les étapes ci-dessus, consultez les articles suivants: