Pymongo AssertionError: ids ne correspondent pas
Question
J'utilise:
- MongoDB 1.6.5
- Pymongo 1.9
- Python 2.6.6
J'ai 3 types de daemons. 1er données de charge de Web, 2ème analyser et sauver résultat, et 3e résultat du groupe. Tous les travailler avec MongoDB. À un moment donné 3ème démon jette de nombreuses exceptions comme celle-ci (surtout quand il y a grande quantité de données dans DB):
Traceback (most recent call last):
File "/usr/local/lib/python2.6/dist-packages/gevent-0.13.1-py2.6-linux-x86_64.egg/gevent/greenlet.py", line 405, in run
result = self._run(*self.args, **self.kwargs)
File "/data/www/spider/daemon/scripts/mainconverter.py", line 72, in work
for item in res:
File "/usr/local/lib/python2.6/dist-packages/pymongo-1.9_-py2.6-linux-x86_64.egg/pymongo/cursor.py", line 601, in next
if len(self.__data) or self._refresh():
File "/usr/local/lib/python2.6/dist-packages/pymongo-1.9_-py2.6-linux-x86_64.egg/pymongo/cursor.py", line 564, in _refresh
self.__query_spec(), self.__fields))
File "/usr/local/lib/python2.6/dist-packages/pymongo-1.9_-py2.6-linux-x86_64.egg/pymongo/cursor.py", line 521, in __send_message
**kwargs)
File "/usr/local/lib/python2.6/dist-packages/pymongo-1.9_-py2.6-linux-x86_64.egg/pymongo/connection.py", line 743, in _send_message_with_response
return self.__send_and_receive(message, sock)
File "/usr/local/lib/python2.6/dist-packages/pymongo-1.9_-py2.6-linux-x86_64.egg/pymongo/connection.py", line 724, in __send_and_receive
return self.__receive_message_on_socket(1, request_id, sock)
File "/usr/local/lib/python2.6/dist-packages/pymongo-1.9_-py2.6-linux-x86_64.egg/pymongo/connection.py", line 714, in __receive_message_on_socket
struct.unpack("<i", header[8:12])[0])
AssertionError: ids don't match -561338340 0
<Greenlet at 0x2baa628: <bound method Worker.work of <scripts.mainconverter.Worker object at 0x2ba8450>>> failed with AssertionError
Quelqu'un peut-il dire ce qui cause cette exeption et comment résoudre ce problème.
Merci.
La solution
Ceci est probablement un problème de filetage lié à la façon dont vous utilisez threads de travail avec coroutines de gevent. Il semble que l'objet connexion pymongo est en train de lire une réponse à une demande, il n'a pas fait.
Licencié sous: CC-BY-SA avec attribution
Non affilié à StackOverflow