Я имел дело с этим в течение последних 5 часов, и я не знаю, что я делаю неправильно. Он просто печатает «Running pool ...», но, похоже, не выполняет функцию. Он не выдает никаких ошибок, он просто продолжает работать.
conn = pymysql.connect(host, user=user,port=port,passwd=password, db=dbname)
SQL = 'SELECT * FROM Clean_SBIR LIMIT {}, 20000'
def process_data(offset):
print('Offset original: ',offset)
offset = offset * 20000
print('Actual offset: ',offset)
df = pd.read_sql((SQL).format(offset), conn)
print(offset)
return len(df)
if __name__ == "__main__":
with Pool(4) as pool:
print('Running pool...')
result = pool.apply_async(process_data, [1,2,3])
print(result.get())
print(pool.map(process_data, [1,2,3]))