Как я могу сохранить DF в Монго с помощью метода пакетной обработки? - PullRequest
Новая
       5

Как я могу сохранить DF в Монго с помощью метода пакетной обработки?

0 голосов
/ 02 февраля 2019

При сканировании данных из Интернета.Мне нужно автоматически сохранять сотни pandas.dataframes в mongoDB. Однако до сих пор я могу сохранить только один df в mongodb с помощью pymongo.У каждого df есть определенный df_id, как я могу автоматически сохранить их в базе данных mongoDB и назвать каждую коллекцию одного df своим df_id?Я попробовал приведенный ниже код, но он не сработал. 

def df2bson(df):#将df_to_bson
    data = json.loads(df.T.to_json()).values()
    return data
def df2mongo(self,df_id):#save_to_MongoDB
    bson_data = df2bson(df)
    mclient = MongoClient()
    mydb = mclient["database1"]
    collection = mydb.df_id
    return collection

как я могу изменить свой код, чтобы я мог сохранить свои данные в mongoDB?

...