Как сделать запланированную отправку электронной почты с помощью django-mailer

Я делаю приложение django, которое должно иметь возможность отправлять электронные письма, а затем отправлять их в определенное время. Я думал, что могу использовать django-mailer, чтобы ставить вещи в очередь, а затем отправлять их. Но даже несмотря на то, что в их списке примерных случаев указано, что это функция, я не могу понять, как это сделать.

Что мне нужно, так это иметь возможность установить поле «when_to_send» в модели сообщений django-mailer, и когда задание cron запускает функцию send_mail, это должно отфильтровать те, у которых есть дата «when_to_send», которая больше, чем текущее время...

def send_all():
    """
    Send all eligible messages in the queue.
    """

    lock = FileLock("send_mail")

    logging.debug("acquiring lock...")
    try:
        lock.acquire(LOCK_WAIT_TIMEOUT)
    except AlreadyLocked:
        logging.debug("lock already in place. quitting.")
        return
    except LockTimeout:
        logging.debug("waiting for the lock timed out. quitting.")
        return
    logging.debug("acquired.")

    start_time = time.time()

    dont_send = 0
    deferred = 0
    sent = 0

    try:
        for message in prioritize():
            if DontSendEntry.objects.has_address(message.to_address):
                logging.info("skipping email to %s as on don't send list " % message.to_address)
                MessageLog.objects.log(message, 2) # @@@ avoid using literal result code
                message.delete()
                dont_send += 1
            else:
                try:
                    logging.info("sending message '%s' to %s" % (message.subject.encode("utf-8"), message.to_address.encode("utf-8")))
                    core_send_mail(message.subject, message.message_body, message.from_address, [message.to_address])
                    MessageLog.objects.log(message, 1) # @@@ avoid using literal result code
                    message.delete()
                    sent += 1
                except (socket_error, smtplib.SMTPSenderRefused, smtplib.SMTPRecipientsRefused, smtplib.SMTPAuthenticationError), err:
                    message.defer()
                    logging.info("message deferred due to failure: %s" % err)
                    MessageLog.objects.log(message, 3, log_message=str(err)) # @@@ avoid using literal result code
                    deferred += 1
    finally:
        logging.debug("releasing lock...")
        lock.release()
        logging.debug("released.")

    logging.info("")
    logging.info("%s sent; %s deferred; %s don't send" % (sent, deferred, dont_send))
    logging.info("done in %.2f seconds" % (time.time() - start_time))

Кто-нибудь видел, как настроить эту функцию, чтобы не отправлять электронную почту, где поле message.when_to_send больше, чем текущее время?


python django email schedule django-mailer
person espenhogbakk    schedule 24.07.2009    source источник

Ответы (2)


arrow_upward
0
arrow_downward

Вы можете просто добавить еще одно предложение к условным выражениям в цикле обработки сообщений (вам также нужно будет импортировать дату и время вверху файла):

         for message in prioritize():
            if DontSendEntry.objects.has_address(message.to_address):
                logging.info("skipping email to %s as on don't send list " % message.to_address)
                MessageLog.objects.log(message, 2) # @@@ avoid using literal result code
                message.delete()
                dont_send += 1
            elif message.when_to_send > datetime.datetime.now():
                continue
            else:
                try:
                  ... the rest of your code ...
person shawnr    schedule 24.07.2009
comment
Я пробовал так, но в результате получается бесконечный цикл из функции priorityize(), а это, конечно, нехорошо. - person espenhogbakk; 25.07.2009

arrow_upward
4
arrow_downward

Вам необходимо реализовать задание cron для django-mailer:

* * * * * (cd $PINAX; /usr/local/bin/python2.5 manage.py send_mail >> $PINAX/cron_mail.log 2>&1)

А затем в строке 96 engine.py:

   # Get rid of "while True:"
   while not Message.objects.all():
        # Get rid of logging.debug("sleeping for %s seconds before checking queue again" % EMPTY_QUEUE_SLEEP)
        # Get rid of sleep
        send_all()
person Adam Nelson    schedule 02.12.2009