Function Compute:Fonctionnalités avancées des déclencheurs

Envoi par lot

L'envoi par lot regroupe plusieurs messages en une seule invocation de fonction, réduisant ainsi le nombre d'appels et améliorant le débit.

Après avoir activé l'envoi par lot, configurez les deux paramètres suivants :

Fonctionnement du traitement par lots

Un lot est envoyé dès que l'une des conditions suivantes est remplie (selon la première éventualité) :

• Le nombre de messages accumulés atteint la valeur définie dans Batch Push Messages.

• Le délai spécifié dans Batch Push Interval expire.

• La taille cumulée du body atteint la limite d'invocation (32 Mo en mode synchrone, 128 Ko en mode asynchrone).

Exemples

Exemple 1 — déclenchement par intervalle : Définissez Batch Push Messages sur 100 (1 Ko chacun) et Batch Push Interval sur 15 s. Si 50 messages s'accumulent en moins de 15 s, l'envoi se déclenche immédiatement sans attendre d'atteindre 100 messages.

Exemple 2 — déclenchement par nombre de messages : Avec les mêmes paramètres, si 100 messages s'accumulent en 10 s, l'envoi se déclenche aussitôt sans attendre la fin des 15 s.

Exemple 3 — déclenchement par limite de taille du corps (invocation asynchrone) : Configurez Batch Push Messages sur 100 (2 Ko chacun), Batch Push Interval sur 15 s et Invocation Method sur Async Invocation. Lorsque 100 messages s'accumulent en 10 s, la taille totale atteint 100 × 2 Ko = 200 Ko, dépassant ainsi la limite asynchrone de 128 Ko. Function Compute divise alors automatiquement le lot : le premier contient 64 messages et le second 36 messages.

Format d'envoi

Sélectionnez le format des données d'événement remises au point d'entrée de votre fonction.

Les exemples suivants illustrent la charge utile de l'événement pour chaque format, en utilisant un déclencheur de file d'attente Simple Message Queue (anciennement MNS) avec deux messages.

[
    {
        "id": "c2g71017-6f65-fhcf-a814-a396fc8d****",
        "source": "MNS-Function-mnstrigger",
        "specversion": "1.0",
        "type": "mns:Queue:SendMessage",
        "datacontenttype": "application/json; charset=utf-8",
        "subject": "acs:mns:cn-hangzhou:164901546557****:queues/zeus",
        "time": "2021-04-08T06:28:17.093Z",
        "aliyunaccountid": "164901546557****",
        "aliyunpublishtime": "2021-10-15T07:06:34.028Z",
        "aliyunoriginalaccountid": "164901546557****",
        "aliyuneventbusname": "MNS-Function-mnstrigger",
        "aliyunregionid": "cn-chengdu",
        "aliyunpublishaddr": "42.120.XX.XX",
        "data": {
            "requestId": "606EA3074344430D4C81****",
            "messageId": "C6DB60D1574661357FA227277445****",
            "messageBody": "TEST"
        }
    },
    {
        "id": "d2g71017-6f65-fhcf-a814-a396fc8d****",
        "source": "MNS-Function-mnstrigger",
        "specversion": "1.0",
        "type": "mns:Queue:SendMessage",
        "datacontenttype": "application/json; charset=utf-8",
        "subject": "acs:mns:cn-hangzhou:164901546557****:queues/zeus",
        "time": "2021-04-08T06:28:17.093Z",
        "aliyunaccountid": "164901546557****",
        "aliyunpublishtime": "2021-10-15T07:06:34.028Z",
        "aliyunoriginalaccountid": "164901546557****",
        "aliyuneventbusname": "MNS-Function-mnstrigger",
        "aliyunregionid": "cn-chengdu",
        "aliyunpublishaddr": "42.120.XX.XX",
        "data": {
            "requestId": "606EA3074344430D4C81****",
            "messageId": "C6DB60D1574661357FA227277445****",
            "messageBody": "TEST"
        }
    }
]

[
    {
        "requestId": "606EA3074344430D4C81****",
        "messageId": "C6DB60D1574661357FA227277445****",
        "messageBody": "TEST"
    },
    {
        "requestId": "606EA3074344430D4C81****",
        "messageId": "C6DB60D1574661357FA227277445****",
        "messageBody": "TEST"
    }
]

Déclenchement des nouvelles tentatives

FAQ

Les erreurs logiques de la fonction déclenchent-elles la politique de nouvelle tentative ?

Cela dépend de la méthode d'invocation. Pour les invocations synchrones, les erreurs logiques déclenchent la politique de nouvelle tentative. Pour les invocations asynchrones, elles n'activent pas la politique de nouvelle tentative au niveau du déclencheur, mais plutôt la politique distincte dédiée aux invocations asynchrones. Pour plus de détails, consultez Politiques de nouvelle tentative.

Lorsqu'une nouvelle tentative résulte d'une erreur logique de la fonction, évaluez ses chances de succès :

• Si l'erreur est transitoire, mettez en œuvre une logique de nouvelle tentative directement dans la fonction plutôt que de vous fier à la politique du déclencheur.

• Si l'erreur est permanente, les nouvelles tentatives échoueront systématiquement et ne feront qu'augmenter les coûts. Privilégiez alors les paramètres de tolérance aux pannes et de file d'attente de lettres mortes pour gérer le message en échec.