2

メールボックスの異なるディレクトリから同時にメールをフェッチしようとしている次のコードがあります。しかし、それは以下の問題を示しています。短縮されたスタックトレースを添付しました。

import multiprocessing as mlp
import imaplib as impl

def somefunc(dirc):
    mail.select(dirc)
    result, data = mail.uid("search", None, "All")
    uids = data[0].split()
    print dirc
    for mail_id in uids:
       result, data = mail.uid("fetch", mail_id, "(RFC822)")

if __name__ == '__main__':
    mail = impl.IMAP4_SSL("somedomain")
    mail.login("username","password")

    jobs = []
    p1 = mlp.Process(target = somefunc, args = ("INBOX",))
    jobs.append(p1)
    p1.start()
    p2 = mlp.Process(target = somefunc, args = ("Sent",))
    jobs.append(p2)
    p2.start()
    for i in jobs:
        i.join()

エラーが発生します：

Process Process-2:
Traceback (most recent call last):
File "/usr/lib/python2.7/multiprocessing/process.py", line 258, in _bootstrap
Process Process-1:
Traceback (most recent call last):
File "/usr/lib/python2.7/multiprocessing/process.py", line 258, in _bootstrap
    self.run()
File "/usr/lib/python2.7/multiprocessing/process.py", line 114, in run
    self._target(*self._args, **self._kwargs)
........
File "/usr/lib/python2.7/imaplib.py", line 859, in _command
    raise self.abort('socket error: %s' % val)
abort: socket error: [Errno 32] Broken pipe
    typ, dat = self._simple_command(name, mailbox)
........
error: [Errno 104] Connection reset by peer

imap接続を同時に行うことはできませんか？

ありがとう... ：）

4

1 に答える 1

0

プロセス間でメールソケット接続オブジェクトを共有しようとしているため、問題が発生していると思います。代わりに、各プロセスに接続を作成してもらいます。

import multiprocessing as mlp
import imaplib as impl

def somefunc(domain, name, password, dirc):
    mail = impl.IMAP4_SSL(domain)
    mail.login(name, password)
    mail.select(dirc)
    result, data = mail.uid("search", None, "All")
    uids = data[0].split()
    print dirc
    for mail_id in uids:
       result, data = mail.uid("fetch", mail_id, "(RFC822)")

if __name__ == '__main__':
    jobs = []

    for box in ("INBOX", "Sent"):
        p = mlp.Process(
                target = somefunc, 
                args = ("somedomain", "username", "password", box)
            )
        jobs.append(p)
        p.start()

    for i in jobs:
        i.join()
于 2012-12-25T21:00:38.717 に答える