import pytz
from pymongo import MongoClient
from datetime import datetime
tzinfo = pytz.timezone('Asia/Shanghai')

client = MongoClient(
  host="127.0.0.1",
  port=27017,
  username="root",
  password="123456",
  authSource="admin", # 在哪個(gè)數(shù)據(jù)庫(kù)進(jìn)行身份驗(yàn)證，默認(rèn)是admin
  tz_aware=True, # 設(shè)置為T(mén)rue
  tzinfo=tzinfo  # 加入時(shí)區(qū)信息
)
db = client["test"]
collection = db["mytest"]

datetime.now() # 2020-04-11 10:42:42.452433
ret = collection.insert_one({
  "name": "測(cè)試5",
  "create_time": tzinfo.localize(datetime.now()) 
})
# create_time不能使用datetime.now()獲取時(shí)間，
# 應(yīng)該使用 datetime.utcnow()或 tzinfo.localize(datetime.now())或 datetime.now(tz=tzinfo)
# 這樣讀取數(shù)據(jù)時(shí)日期時(shí)間才是標(biāo)準(zhǔn)的中國(guó)時(shí)間
res = collection.find_one({"name": "測(cè)試5"})
print(res)
# {'_id': ObjectId('5e912ea261d252f76350728a'), 'name': '測(cè)試5', 'create_time': datetime.datetime(2020, 4, 11, 10, 42, 42, 452000, tzinfo=<DstTzInfo 'Asia/Shanghai' CST+8:00:00 STD>)}

# 下面測(cè)試直接使用datetime.now()的情形
datetime.now() # 2020-04-11 10:49:41.899445
collection.insert_one({
  "name": "測(cè)試6",
  "create_time": datetime.now()
})
res = collection.find_one({"name": "測(cè)試6"})
# {'_id': ObjectId('5e913045143015041d776d08'), 'name': '測(cè)試6', 'create_time': datetime.datetime(2020, 4, 11, 18, 49, 41, 899000, tzinfo=<DstTzInfo 'Asia/Shanghai' CST+8:00:00 STD>)}
# 可以看到時(shí)間+8小時(shí)

from pymongo import MongoClient 
client=MongoClient('localhost',27017)
db=client.adv.message
from datetime import datetime
import pandas as pd
#db.insert_one({'player_id':js2['player_id'],'message':js2['message'],
#        'label':label,'predict_time':datetime.datetime.now()})

#按照時(shí)間查詢
q1={"predict_time":{"$gte" :datetime(2019,9,25) ,"$lte": datetime(2019,9,28)}}  
l1=list(db.find(q1))

#l1=list(db.find({}))
df=pd.DataFrame(l1)