#!/usr/bin/env python # -*- coding:utf-8 -*- import json from pymongo import MongoClient import time import cx_Oracle def id2time(object_id): ? ? timeStamp = int(object_id[:8], 16) ? ? return time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(timeStamp)) import pymongo import time import datetime from bson.objectid import ObjectId def object_id_from_datetime(from_datetime=None): ? ? ''' According to the time manually generated an ObjectId ''' ? ? if not from_datetime: ? ? ? ? from_datetime = datetime.datetime.now() ? ? return ObjectId.from_datetime(generation_time=from_datetime) def object_id_from_datetime(from_datetime=None): ? ? ''' According to the time manually generated an ObjectId ''' ? ? if not from_datetime: ? ? ? ? from_datetime = datetime.datetime.now() ? ? return ObjectId.from_datetime(generation_time=from_datetime) def range_search(start_timestamp, end_timestamp): ? connection = MongoClient("mongodb://20.5.xx.xx:27017/") ? with connection: ? ? db = connection['mario'] ? ? db.authenticate("mario", "xx") ? ? table = db['alertSetSend'] ? ? a = table.find({ '$and': [{'_id':{'$lt' : end_timestamp, '$gte' : start_timestamp}}]}) ? ? #a = table.find({'_id':{'$lt' : end_timestamp, '$gte' : start_timestamp}}) ? ? #a.find({'idx':'9551097'}) ? ? b=a ? ? #print type(b) ? ? for x in b: ? ? ? ? #print str(x['_id'])+'=>'+id2time(str(x['_id']))+'=>'+str(x) ? ? ? ? try: ? ? ? ? ? ? ?x['tags']['systemName'] ? ? ? ? except: ? ? ? ? ? ? ?x['tags']['systemName']='Other' ? ? ? ? print x ? ? ? ? print id2time(str(x['_id']))+'=>'+x['text']+'=>'+x['tags']['indexName']+'=>'+x['tags']['systemName'] ? ? ? ? ? ? ? ? #print str(x['_id']) + '=>' + id2time(str(x['_id'])) ? ##时间要减去8 ? #start time def getdate(hours,minutes): ? ? ? ? ?today = datetime.datetime.now() # ?offset = datetime.timedelta(hours=-hours,minutes=-minutes) ?re_date = (today + offset).strftime("%Y-%m-%d %H:%M:%S") ?return str(re_date) str1=getdate(8,1) print str1 start_time=datetime.datetime.strptime(str1,"%Y-%m-%d %H:%M:%S") start_timestamp = object_id_from_datetime(start_time) print start_timestamp #end time str2=getdate(8,0) print str2 end_time=datetime.datetime.strptime(str2,"%Y-%m-%d %H:%M:%S") end_timestamp = object_id_from_datetime(end_time) print end_timestamp range_search(start_timestamp, end_timestamp)