Записать Pandas DataFrame в коллекции MongoDB с помощью PyMongo - PullRequest
0 голосов
/ 24 октября 2018

Я пытаюсь прочитать CSV-файл с использованием Python, преобразовать его в Pandas Dataframe и записать данные в коллекцию в MongoDB.Ниже приведен исходный код, который я пробую, он работает с 0 ошибками, но я не вижу ожидаемых результатов в коллекциях MongoDB, которые я пытаюсь получить записи.Любые предложения?

import pandas as pd
import pymongo
import json


def import_content(filepath):
    mng_client = pymongo.MongoClient('localhost', 27017)
    mng_db = mng_client['PLM']  # mongo db name
    collection_name = 'Sample'  # mongo db collection name
    db_cm = mng_db[collection_name]
    import os
    cdir = os.path.dirname(__file__)
    file_res = os.path.join(cdir, filepath)

    data = pd.read_csv(file_res)
    data_json = json.loads(data.to_json(orient='values'))
    db_cm.remove()
    db_cm.insert(data_json)


if __name__ == " __main__":
    filepath = 'C:/MongoDB/DataSheets/InputFilecsv.csv'  # pass csv file path
    import_content(filepath)

Процесс завершен с кодом выхода 0

Примечание. Я уже создал имя коллекции "Образец" в MongoDB, как показано ниже

{
    "_id" : ObjectId("5bd048d21e36618d869f5e5e"),
    "specid" : "",
    "specname" : "",
    "shortname" : "",
    "status" : "",
    "wf" : "",
    "cat" : "",
    "subcat" : "",
    "grp" : ""
}
...