zoukankan      html  css  js  c++  java
  • mongo utils python

    #encoding=utf-8
    #!/usr/bin/python3

    from pymongo import MongoClient
    import logging

    
    

    myclient =MongoClient("mongodb://192.168.18.129:27017")
    # client = MongoClient(MongoDB_HOST, MongoDB_HOST_PORT)
    # mongo_host="192.168.18.129"
    mongo_database="MYdataBase"
    mongo_collection="mytable"

    
    

    def insert_one(conntent_dist,collection=mongo_collection,database=mongo_database):
    try:
    mydb = myclient[database]
    mycol = mydb[collection]
    #add auth
    mydb.authenticate("mongodb", "ASSS")
    mycol.insert_one(conntent_dist)
    logging.info("save mongoDB ok")
    except Exception as e:
    logging.error("save mongoDB fail and exception is "+str(e))

    
    
    
    def insert_list(collection,conntent_list,database=mongo_database):
        mydb = myclient[database]
        mydb.authenticate("mongodb", "ASSS")
        mycol = mydb[collection]
        mycol.insert_many(conntent_list)
        print("save list ok")
    
    
    
    
    if __name__ == '__main__':
        collection="ggg"
        conntent_dist={"name": "SeatestPy", "addr": "sz", "url": "https://www.123.com"}
        insert_one(conntent_dist)
        mylist = [
          { "_id": 5, "name": "xiaofang", "cn_name": "消防"}, #如果指定了id ,那么会覆盖
          { "name": "Taobao", "alexa": "100", "url": "https://www.taobao.com" },
          { "name": "Github", "alexa": "109", "url": "https://www.github.com" }
                ]
    #     insert_list(collection, mylist)
  • 相关阅读:
    DockerCompose安装与快速体验
    Nginx:Docker部署与负载均衡开发实践
    JAVA基础:反射基础
    JVM:类加载机制
    JAVA基础:注解应用示例
    JAVA基础:注解机制
    JAVA并发(五):关键词final
    JAVA并发(四):关键词volatile
    Linux虚拟机配置作为旁挂路由器
    Linux起不来,如何修复
  • 原文地址:https://www.cnblogs.com/lshan/p/11855590.html
Copyright © 2011-2022 走看看