sql >> データベース >  >> NoSQL >> MongoDB

mongodbからpandasにデータをインポートする方法は?

    pymongo 以下は私が使用しているいくつかのコードです:

    import pandas as pd
    from pymongo import MongoClient
    
    
    def _connect_mongo(host, port, username, password, db):
        """ A util for making a connection to mongo """
    
        if username and password:
            mongo_uri = 'mongodb://%s:%[email protected]%s:%s/%s' % (username, password, host, port, db)
            conn = MongoClient(mongo_uri)
        else:
            conn = MongoClient(host, port)
    
    
        return conn[db]
    
    
    def read_mongo(db, collection, query={}, host='localhost', port=27017, username=None, password=None, no_id=True):
        """ Read from Mongo and Store into DataFrame """
    
        # Connect to MongoDB
        db = _connect_mongo(host=host, port=port, username=username, password=password, db=db)
    
        # Make a query to the specific DB and Collection
        cursor = db[collection].find(query)
    
        # Expand the cursor and construct the DataFrame
        df =  pd.DataFrame(list(cursor))
    
        # Delete the _id
        if no_id:
            del df['_id']
    
        return df
    


    1. 既存のすべてのフィールドを含め、ドキュメントに新しいフィールドを追加します

    2. MongoDBインデックスを理解する

    3. RedisクライアントAPIの使用を開始する

    4. 認証付きのMongoDBインスタンスのカスタムユーザー接続文字列