Pythonで日付範囲を使用して日付と時刻を使用してデータをプル/クエリする方法

Question

以下はデータを取得し、データをCSVファイルに変換するコードです（これは動作しています）。私は深夜から午後4時（BST（英国夏時間）UTC/GMT +1時間）に返されたデータに焦点を当てようとしています。

誰かが私にこれをどのようにしてくれたらいいか教えてください.DTDTは日付です。

私が達成しようとしていることが意味をなさない場合は、私がそれを説明しようとしていることを知らせてください。

マイコード：

from elasticsearch import Elasticsearch 
import csv 

es = Elasticsearch(["9200"]) 

# Replace the following Query with your own Elastic Search Query 
res = es.search(index="search", body= 
       { 
        "_source": ["DTDT", "TRDT", "SPLE", "RPLE"], 
        "query": { 
         "bool": { 
          "should": [ 
           {"wildcard": {"CN": "TEST1"}} 

          ] 
         } 
        } 
}, size=10) 



header_names = { 'DTDT': 'DATE', 'TRDT': 'TIME', ...} 

with open('mycsvfile.csv', 'w') as f: # Just use 'w' mode in 3.x 
    header_present = False 
    for doc in res['hits']['hits']: 
     my_dict = doc['_source'] 
     if not header_present: 
      w = csv.DictWriter(f, my_dict.keys()) 
      w.writerow(header_names) # will write DATE, TIME, ... in correct place 
      header_present = True 


     w.writerow(my_dict) 

は、例えば、私は（現在の日付を使用して）午後2時までの深夜からデータを返すようにしたいです。

Answer 1

csvファイルに書き込む前に、時間範囲を確認してファイルに書き込むことができます。

は、時間範囲を確認するための関数の下に追加します。与えられた時間は

範囲

である場合

def time_in_range(start, end, x): 
    """Return true if x is in the range [start, end]""" 
    if start <= end: 
     return start <= x <= end 
    else: 
     return start <= x or x <= end 

それが本当次に、あなたのコードでこれを追加します。

import datetime 
#Range here(Midnight to 2 PM) 
start = datetime.time(0,0,0) 
end = datetime.time(14,0,0) 

with open('mycsvfile.csv', 'w') as f: # Just use 'w' mode in 3.x 
    header_present = False 
    for doc in res['hits']['hits']: 
     my_dict = doc['_source'] 
     if not header_present: 
      w = csv.DictWriter(f, my_dict.keys()) 
      w.writerow(header_names) # will write DATE, TIME, ... in correct place 
      header_present = True 

     #Get time 
     curr_time = my_dict['DTDT'] 
     #Conver it into datetime object 
     d_obj = datetime.datetime.strptime(curr_time, '%d/%m/%Y %H:%M') 
     #Check whether it is in range using above function 
     #If in range, then it will write to file 
     if time_in_range(start, end, d_obj.time()): 
      w.writerow(my_dict)