Как в sqlalchemy выбрать старые записи по дате и времени?

Question

[alekssamos]

Помогите правильно написать запрос.
Выбрать только все, что создано более одного часа назад.
Не могу написать запрос. Не работает. Нужно получить старые записи, для примера, сделанные более одного часа назад, то есть "5 часов" - да, "23 минуты" - нет.
То есть:

• задание, которое создано три часа назад / 7 дней назад — да, должно попасть в выборку
  
• а что создано всего лишь 10 минут назад / 56 минут назад — нет, это в выборку не должно войти
  

Мои попытки:

import datetime
from app import db
from dbmodels import QTasks

# 1)

diff = datetime.datetime.now() - datetime.timedelta(hours=1)

db.session.query(QTasks).filter(diff < datetime.datetime.now()).all()

# 2)

db.session.query(QTasks)
                    .filter(
                        (datetime.datetime.now() - QTasks.created_at > datetime.timedelta(hours=1))
                    )
                                          .all()

Либо выдаёт все записи, даже новые (только что созданные), либо пустой результат.
Есть похожий код на PHP, там я использую функцию time() и запросы пишу вручную, вроде бы как получилось, а здесь, в Python, не получается, не могу понять.

Comments

[Gnifajio None]

Та же самая фигня... Нашел решение?

[alekssamos]

Gnifajio None, Да вот здесь что-то нашёл
job_runner.py

"""
Run scheduled jobs.
Not meant for running job at precise time (+- 1h)
"""
import time
from typing import List

import arrow
from sqlalchemy.sql.expression import or_, and_

def get_jobs_to_run() -> List[Job]:
    # Get jobs that match all conditions:
    #  - Job.state == ready OR (Job.state == taken AND Job.taken_at < now - 30 mins AND Job.attempts < 5)
    #  - Job.run_at is Null OR Job.run_at < now + 10 mins
    taken_at_earliest = arrow.now().shift(minutes=-config.JOB_TAKEN_RETRY_WAIT_MINS)
    run_at_earliest = arrow.now().shift(minutes=+10)
    query = Job.filter(
        and_(
            or_(
                Job.state == JobState.ready.value,
                and_(
                    Job.state == JobState.taken.value,
                    Job.taken_at < taken_at_earliest,
                    Job.attempts < config.JOB_MAX_ATTEMPTS,
                ),
            ),
            or_(Job.run_at.is_(None), and_(Job.run_at <= run_at_earliest)),
        )
    )
    return query.all()


if __name__ == "__main__":
    while True:
        # wrap in an app context to benefit from app setup like database cleanup, sentry integration, etc
        with create_light_app().app_context():
            for job in get_jobs_to_run():
                LOG.d("Take job %s", job)

                # mark the job as taken, whether it will be executed successfully or not
                job.taken = True
                job.taken_at = arrow.now()
                job.state = JobState.taken.value
                job.attempts += 1
                Session.commit()
                process_job(job)

                job.state = JobState.done.value
                Session.commit()

            time.sleep(10)

cron.py

def delete_logs():
    """delete everything that are considered logs"""
    delete_refused_emails()
    delete_old_monitoring()

    for t in TransactionalEmail.filter(
        TransactionalEmail.created_at < arrow.now().shift(days=-7)
    ):
        TransactionalEmail.delete(t.id)

    for b in Bounce.filter(Bounce.created_at < arrow.now().shift(days=-7)):
        Bounce.delete(b.id)

    Session.commit()

    LOG.d("Delete EmailLog older than 2 weeks")

    max_dt = arrow.now().shift(weeks=-2)
    nb_deleted = EmailLog.filter(EmailLog.created_at < max_dt).delete()
    Session.commit()

    LOG.i("Delete %s email logs", nb_deleted)

[Gnifajio None]

alekssamos, спасибо