elasticsearch-py et multiprocessing

Question

Quelle est la bonne façon d'utiliser elasticsearch-py dans un script multitraitement? Dois-je créer un nouvel objet client avant de démarrer les processus et utiliser cet objet ou dois-je créer un nouvel objet dans chacun des processus. Le 2ème me donne une erreur avec des problèmes de connexion de ElasticSearch

Merci Kiran

Answer 1

La méthode recommandée est de créer un objet client unique et vous pouvez augmenter le nombre de fils simultanément en utilisant la maxsize (10 par défaut).

es = Elasticsearch("host1", maxsize=25)

Source