Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Exécuteur séquentiel

Quand l’utiliser

A SEQUENTIAL_EXECUTOR exécute une série de fonctions une par une, dans l'ordre. Chaque étape peut utiliser les résultats des étapes précédentes.

SEQUENTIAL_EXECUTORÀ utiliser lorsque votre logique nécessite plusieurs étapes qui dépendent des résultats des uns et des autres. Les cas d'utilisation courants incluent la récupération de données d'identité, puis leur utilisation pour récupérer des segments d'audience, l'exécution d'une étape de classification, puis l'appel conditionnel de différents services externes en fonction du résultat, et la création d'URL de demandes d'annonces complexes à partir de plusieurs sources de données.

Champs de configuration

Une SEQUENTIAL_EXECUTOR fonction comporte les champs suivants :

Exécution ordonnée et flux de données

MediaTailor exécute chaque étape de la séquence de la première à la dernière. Une fois chaque étape terminée, les valeurs produites sont fusionnées dans un ensemble de résultats. Les étapes suivantes peuvent accéder aux données de session d'origine ainsi qu'à toutes les valeurs produites par les étapes précédentes.

Les données temporaires constituent le principal mécanisme de transmission des données entre les étapes. Lorsqu'une fonction écrit sur une temp.* touche, l'étape suivante permet de lire cette valeur. Les paramètres du joueur et les champs de demande d'annonces écrits lors des étapes précédentes sont également visibles lors des étapes suivantes.

Per-step conditions de course

Chaque étape de la séquence comporte un RunCondition champ facultatif. Ce champ contient une expression qui renvoie true oufalse. MediaTailor évalue l'RunConditionexpression immédiatement avant d'exécuter cette étape.

Si l'RunConditionexpression est évaluée àfalse, MediaTailor saute complètement l'étape et passe à la suivante. Si le RunCondition champ est omis, l'étape est toujours exécutée.

{ "FunctionId": "retryFetch", "RunCondition": "{%temp.statusCode = 500%}" }

Ce mécanisme vous permet de créer des pipelines conditionnels. Par exemple, vous pouvez exécuter une recherche d'identité à l'étape 1, puis exécuter une recherche de segment de manière conditionnelle à l'étape 2 uniquement si l'étape 1 a renvoyé une identité valide.

Comment fonctionne le bloc de sortie

Le bloc de sortie sur a SEQUENTIAL_EXECUTOR contrôle ce que produit la séquence une fois toutes les étapes terminées :

Configuration du délai d’attente

Le TimeoutMilliseconds champ définit une date limite pour l'ensemble de la séquence. Ce délai couvre toutes les étapes, y compris les appels HTTP effectués par les fonctions. Si la séquence dépasse le délai d'attente, MediaTailor supprime toutes les sorties de la séquence et procède comme si aucune fonction n'était attachée.

Les HTTP_REQUEST fonctions individuelles respectent toujours leur propre RequestTimeoutMilliseconds réglage. Le délai d'attente de la séquence agit comme une limite extérieure qui limite le temps d'exécution total.

Exemple : Réessayez en cas d'échec HTTP

Cet exemple appelle une API d'identité et réessaie automatiquement si le premier appel renvoie une erreur de serveur. Il utilise deux fonctions HTTP_REQUEST orchestrées par un SEQUENTIAL_EXECUTOR.

Étape 1 — Récupération principale (fetchIdentity) :

{
    "FunctionId": "fetchIdentity",
    "FunctionType": "HTTP_REQUEST",
    "HttpRequestConfiguration": {
        "Runtime": "JSONATA",
        "MethodType": "GET",
        "Url": "{%'https://identity.example.com/v1/resolve?ip=' & session.client_ip%}",
        "Headers": {
            "Accept": "application/json"
        },
        "RequestTimeoutMilliseconds": 1000,
        "Output": {
            "temp.statusCode": "{%response.statusCode%}",
            "temp.envelope": "{%response.statusCode = 200 ? response.body.envelope : null%}"
        }
    }
}

Étape 2 — Réessayez en cas d'échec (retryIdentity) :

{
    "FunctionId": "retryIdentity",
    "FunctionType": "HTTP_REQUEST",
    "HttpRequestConfiguration": {
        "Runtime": "JSONATA",
        "MethodType": "GET",
        "Url": "{%'https://identity-fallback.example.com/v1/resolve?ip=' & session.client_ip%}",
        "Headers": {
            "Accept": "application/json"
        },
        "RequestTimeoutMilliseconds": 1000,
        "Output": {
            "temp.statusCode": "{%response.statusCode%}",
            "temp.envelope": "{%response.statusCode = 200 ? response.body.envelope : null%}"
        }
    }
}

Séquence (identityWithRetry) :

{
    "FunctionId": "identityWithRetry",
    "FunctionType": "SEQUENTIAL_EXECUTOR",
    "SequentialExecutorConfiguration": {
        "Runtime": "JSONATA",
        "TimeoutMilliseconds": 2000,
        "FunctionList": [
            { "FunctionId": "fetchIdentity" },
            { "FunctionId": "retryIdentity", "RunCondition": "{%temp.statusCode >= 500%}" }
        ],
        "Output": {
            "player_params.envelope": "{%temp.envelope%}"
        }
    }
}

Comment ça fonctionne :