Python-Beispielcode zum regelmäßigen Ändern der Datenbank_python

In diesem Artikel wird hauptsächlich der Beispielcode für die regelmäßige Änderung der Datenbank in Python vorgestellt. Der Herausgeber findet ihn recht gut, daher werde ich ihn jetzt mit Ihnen teilen und als Referenz verwenden. Folgen wir dem Editor und werfen wir einen Blick darauf.

Wenn wir die Datenbank regelmäßig ändern müssen, entscheiden wir uns normalerweise dafür, einen geplanten Prozess zum Ändern der Datenbank zu starten. Wenn diese Art von geplanten Aufgaben in das Unternehmen geschrieben und als Schnittstelle geschrieben wird, erscheint Ihnen der geplante Prozess etwas unangemessen? Wenn Sie die Datenbank regelmäßig 100 Mal ändern müssen, werden mit der herkömmlichen Methode 100 Prozesse gestartet. Obwohl dieser Prozess sehr einfach ist, fühlt er sich dennoch unangenehm an. Tatsächlich können wir threading.Timer verwenden, um entsprechende Threads zu erstellen, um Bibliotheksänderungsvorgänge durchzuführen, und die Idee ist relativ einfach.

1. Übergeben Sie update_time, die Zeit, zu der der Datenbankänderungsvorgang ausgeführt wird, und verwenden Sie die Subtraktionsmethode zwischen update_time und der aktuellen Zeit, um die time_delay bis zum Datenbankänderungsvorgang zu erhalten. Um den Zeitunterschied zwischen zwei Standardzeitformatzeichenfolgen zu ermitteln, können Sie die Zeit mit datetime.datetime.strptime() formatieren. Die formatierte Zeit kann direkt subtrahiert und das Ergebnis durch Ausführen von .seconds()

2. Kapseln Sie den Bibliotheksänderungsvorgang in die Methode update() und übergeben Sie dann die Aktualisierung und die Zeitdifferenz an den von threading.Timer erstellten Thread =[], kwargs={}) Thread-Instanz, Intervall ist die verzögerte Ausführungszeit, die Einheit ist Sekunden, und dann wird start() ausgeführt. Der Timer ist nicht blockierend und kann mehrere Threads erstellen, ohne sich gegenseitig zu beeinflussen.

Der Code lautet wie folgt

#!/usr/bin/env python3
# -*- coding: utf-8 -*-

from model import Table
from handler.base_handler import BaseHandler
from threading import Timer
import datetime


class TimeHandler(BaseHandler):
  def do_action(self):
    update_time = "2018-04-07 18:00:00"
    ads_id = "test_1"
    t_online = datetime.datetime.strptime(update_time, '%Y-%m-%d %H:%M:%S')
    now = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
    t_now = datetime.datetime.strptime(now, '%Y-%m-%d %H:%M:%S')
    time_delay = (t_online - t_now).seconds
    t1 = Timer(time_delay, self.update, (ads_id, ))
    t1.start()
    self.result = "success"
    return

  def update(self, ads_id):
    self.db.dsp.query(Table).filter(Table.ads_id == ads_id).update({Table.is_del: 0})
    self.db.dsp.commit()

Sie können update_time in den von der Front übergebenen Parameter ändern Ende, und dann können Sie es tun. Es ist Zeit, den Datenbankänderungsvorgang durchzuführen. Zu diesem Zeitpunkt stieß ich auf einen kleinen Fallstrick: Der Datenbankänderungsvorgang wurde nicht wirksam, da commit () in der letzten Zeile nicht hinzugefügt wurde. Ursprünglich wurde das Commit zum Ändern der Bibliothek in die Basisklasse BaseHandler geschrieben, um wirksam zu werden. Update () wird hier jedoch im Timer-Thread ausgeführt. Dabei handelt es sich um einen asynchronen Vorgang, der im Thread ausgeführt werden muss die Änderungen wirksam.

Diese Methode der Timing-Ausführung mithilfe des Timers ist leichter und einfacher als der herkömmliche Timing-Prozess, weist jedoch auch offensichtliche Mängel auf. Wenn der Dienst heruntergefahren wird, werden alle Timing-Threads zusammen mit dem Hauptprozess zerstört. Voraussetzung für die erfolgreiche Ausführung aller Threads ist, dass der Dienst stabil ist und nicht neu gestartet werden kann. Wenn Sie den Dienst neu starten möchten, müssen Sie eine Möglichkeit finden, die nicht abgeschlossenen Aufgaben auf die Festplatte zu schreiben (z. B. in die Datenbank zu schreiben), dann die zuvor nicht abgeschlossenen Aufgaben zu lesen und den Timing-Thread beim Starten des Dienstes neu zu erstellen.

Verwandte Empfehlungen:

Detaillierte Erklärung zum Lesen und Schreiben von Dateien in Python

Das obige ist der detaillierte Inhalt vonPython-Beispielcode zum regelmäßigen Ändern der Datenbank_python. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!