Я попытался переписать код чтения csv, чтобы иметь возможность запускать его на нескольких ядрах в Python 3.2.2. Я пробовал использовать Pool
объект многопроцессорности, который адаптировал из рабочих примеров (и уже работал у меня для другой части моего проекта). Я столкнулся с сообщением об ошибке, которое было трудно расшифровать и устранить.
Ошибка:
Traceback (most recent call last):
File "parser5_nodots_parallel.py", line 256, in <module>
MG,ppl = csv2graph(r)
File "parser5_nodots_parallel.py", line 245, in csv2graph
node_chunks)
File "/Library/Frameworks/Python.framework/Versions/3.2/lib/python3.2/multiprocessing/pool.py", line 251, in map
return self.map_async(func, iterable, chunksize).get()
File "/Library/Frameworks/Python.framework/Versions/3.2/lib/python3.2/multiprocessing/pool.py", line 552, in get
raise self._value
AttributeError: __exit__
Соответствующий код:
import csv
import time
import datetime
import re
from operator import itemgetter
from multiprocessing import Pool
import itertools
def chunks(l,n):
"""Divide a list of nodes `l` in `n` chunks"""
l_c = iter(l)
while 1:
x = tuple(itertools.islice(l_c,n))
if not x:
return
yield x
def csv2nodes(r):
strptime = time.strptime
mktime = time.mktime
l = []
ppl = set()
pattern = re.compile(r"""[A-Za-z0-9"/]+?(?=[,\n])""")
for row in r:
with pattern.findall(row) as f:
cell = int(f[3])
id = int(f[2])
st = mktime(strptime(f[0],'%d/%m/%Y'))
ed = mktime(strptime(f[1],'%d/%m/%Y'))
# collect list
l.append([(id,cell,{1:st,2: ed})])
# collect separate sets
ppl.add(id)
return (l,ppl)
def csv2graph(source):
MG=nx.MultiGraph()
# Remember that I use integers for edge attributes, to save space! Dic above.
# start: 1
# end: 2
p = Pool()
node_divisor = len(p._pool)
node_chunks = list(chunks(source,int(len(source)/int(node_divisor))))
num_chunks = len(node_chunks)
pedgelists = p.map(csv2nodes,
node_chunks)
ll = []
ppl = set()
for l in pedgelists:
ll.append(l[0])
ppl.update(l[1])
MG.add_edges_from(ll)
return (MG,ppl)
with open('/Users/laszlosandor/Dropbox/peers_prisons/python/codetenus_test.txt','r') as source:
r = source.readlines()
MG,ppl = csv2graph(r)
Какой хороший способ устранить это?
None
сдал экзамен из-за проблем с определением объема.Class SomeClass(object):
будто я явно имел выход в моем классе. Как только я снял с него наследство,object
все заработало.Ответы:
Проблема в этой строке:
with pattern.findall(row) as f:
Вы используете
with
заявление. Для этого требуется объект__enter__
и__exit__
методы. Ноpattern.findall
возвращаетlist
,with
пытается сохранить__exit__
метод, но не может его найти и выдает ошибку. Просто используйтевместо.
источник
В данном случае это не проблема автора, но первый шаг по устранению неполадок для общего «AttributeError: __exit__» должен заключаться в том, чтобы убедиться в наличии скобок, например
with SomeContextManager() as foo: #works because a new object is referenced...
не
with SomeContextManager as foo: #AttributeError because the class is referenced
Время от времени ловит меня, и я оказываюсь здесь -__-
источник
Ошибка также возникает при попытке использовать
with multiprocessing.Pool() as pool: # ...
со слишком старой версией Python (например, Python 2.X) и не поддерживает использование
with
вместе с пулами многопроцессорной обработки.(См. Этот ответ https://stackoverflow.com/a/25968716/1426569 на другой вопрос для получения более подробной информации)
источник
Причина этой ошибки: приложение Flask уже запущено, не закрылось, и в середине этого мы пытаемся запустить другой экземпляр с помощью: with app.app_context (): #Code Перед тем, как использовать это с оператором, нам нужно сделать убедитесь, что область действия предыдущего запущенного приложения закрыта.
источник