一，配置文件

database = {
    "mysql":{
        "type"   :"mysql",
        "host"   :"xxx",
        "port"   :3306,
        "user"   :"xxx",
        "passwd" :"xxx",
        "db"     :"xxx",
        "charset":"utf8"
    }
    ,"mongodb":{
        "type"  :"mongodb",
        "host"  :"xxx",
        "port"  :27017,
        "user"  :"xxx",
        "passwd":"xxx",
    }
    ,"redis":{
        "type"  :"redis",
        "host"  :"xxx",
        "port"  :6379,
        "passwd":"xx",
        "db"    :'xx',
    }
}

1,连接mongo

from pymongo import MongoClient
client = MongoClient(
    database["mongodb"]["host"],
    database["mongodb"]["port"],
    username=database["mongodb"]["user"],
    password=database["mongodb"]["passwd"],
)
db = client.shujuku    #连接数据库 没有自动创建
table1 = db.table1     #连接表  没有自动创建

2,连接redis

import redis
redis_pool = redis.ConnectionPool(
            host=database["redis"]["host"],
            port=database["redis"]["port"],
            password=database["redis"]["passwd"],
            db=database["redis"]["db"],
        )
redis_client = redis.Redis(connection_pool=redis_pool)
data = redis_client.lpop("reids表名")     #data 是我们取到的数据

3,连接mysql

import MySQLdb   #或者import pymysql as MySQLdb
db = MySQLdb.connect(database["mysql"]["host"],
    database["mysql"]["port"],
    username=database["mysql"]["user"],
    password=database["mysql"]["passwd"],
    db=database["mysql"]["db"],
    charset=database["mysql"]["charset"],)
cursor = db.cursor()