Newer
Older
web-services / data-workflow / v1 / buffer.cfg
@Nicolas Thouvenin Nicolas Thouvenin on 20 Dec 2023 690 bytes workflow like copmputer
[use]
plugin = basics

# On sauvegarde sur disque pour accepter rapidement tous les objets en entrée
# et répondre rapidement au client que le traitmenent asynchnrone est lancé.
#
# Le "fork" se détache uniquement quand tous les objets sont "rentrés" dans le fork
# Si le traitement est plus lent que la sauvegarde sur disque
# il est nécessaire de créer un fichier temporaire
[pack]
[FILESave]
identifier = env('identifier')
location = /tmp/upload
compress = true

[debug]
text = fix('Data received by', env('generator'), 'for', env('identifier')).join(' ')

[exchange]
value = get('filename')

[FILELoad]
compress = true
location = /tmp/upload
[unpack]

[metrics]
bucket = buffer