ファイルの書き込みと戻り値のPythonマルチ処理

Question

データベースからデータを読み込んだ後、データを返してcsvファイルに書き出したいとします。どのようにマルチ処理を使用してそれを行うには？

def get_data(): 
    data = get_data_from_database() #a dataframe 
    data.to_csv('data.csv', index=False) #step 1: write to csv file 
    return data #step 2: return data 

手順1と手順2を行うにはマルチプロセスを使用するにはどうすればよいですか？

Answer 1

マルチスレッドを意味しますか？もしそうであれば、あなたはどこか別の場所にファイルを書きたいと思うなら、あなたはロックを使うべきです、そして、それはコードの痛みになるかもしれません！

しかし、あなたは私たちが一般的にここに*マルチプロセッシング*と呼んでいるもののための場所はありません。この

import threading 

def thread_write(data): 
    data.to_csv('data.csv', index=False) # step 1: write to csv file 

def get_data(): 
    data = get_data_from_database() #a dataframe 
    t = threading.Thread(target=thread_write, args=(data,)) #pass your function as target of thread, and it's input variables as a tuple to args 
    t.start() 
    return data # step 2: return data 

Answer 2

これを試してください。

def get_data(): 
     data = [] 
     data = get_data_from_database() #a dataframe 
     if len(data) >0: 
      for i in range (len(data)): 
      data[i].to_csv('data.csv', index=False) #step 1: write to csv file 
     return data #step 2: return data