У меня есть данные в Кассандре, и я пытаюсь получить данные из БД в диапазоне дат и времени.
Ниже приведен код.
fromdate = datetime.combine(dt, datetime.min.time())
todate = datetime.combine(datetime.now().date(), time(23, 59, 59))
print(fromdate)
print(todate)
batch = BatchStatement()
batch.add(SimpleStatement("SELECT * FROM datadump WHERE 'pickup_time' >= '%s' AND 'pickup_time' <= '%s' ALLOW FILTERING;"),
(fromdate, todate,))
data = session.execute(batch)
Приведенный выше код не работает, когда я пытаюсь получить данные в пределах диапазона времени / даты, но если я пытаюсь получить все данные, такие как «SELECT * from DataPump "это работает.
Может кто-нибудь, пожалуйста, дайте мне знать, что не так с вышеуказанным подходом?
Заранее спасибо!