Impossible de fermer un flux ouvert avec pycurl

Question

Je travaille sur un client pour un service web utilisant pycurl. Le client ouvre une connexion à un service de flux et l'engendre dans un thread séparé. Voici une version dépouillée de la façon dont la connexion est établie:

def _setup_connection(self): 
    self.conn = pycurl.Curl() 
    self.conn.setopt(pycurl.URL, FILTER_URL) 
    self.conn.setopt(pycurl.POST, 1) 
    . 
    . 
    . 
    self.conn.setopt(pycurl.HTTPHEADER, headers_list) 
    self.conn.setopt(pycurl.WRITEFUNCTION, self.local_callback) 

def up(self): 
    if self.conn is None: 
     self._setup_connection() 
    self.perform() 

Maintenant, quand je veux fermer la connexion vers le bas, si je l'appelle

self.conn.close() 

je reçois l'exception suivante:

error: cannot invoke close() - perform() is currently running 

Ce qui, d'une certaine manière, a du sens, la connexion est constamment ouverte. J'ai été la chasse autour et ne peux pas sembler trouver un moyen de contourner ce problème et de fermer la connexion proprement.

Answer 1

Vous avez évidemment montré quelques méthodes d'une classe wrapper curl, ce que vous devez faire est de laisser l'objet se manipule lui-même.

def __del__(self): 
    self.conn.close() 

et n'appelez pas explicitement la fermeture. Lorsque l'objet termine son travail et que toutes les références sont supprimées, la connexion curl sera fermée.

Answer 2

Il semble que vous appeliez close() dans un thread alors qu'un autre thread exécute perform(). Heureusement, la bibliothèque vous prévient plutôt que de descendre dans un comportement inconnu.

Vous ne devez utiliser la session curl qu'à partir d'un thread - ou faire en sorte que le thread perform() communique quand l'appel à perform() est terminé.