Mysql
 sql >> база данни >  >> RDS >> Mysql

MySQL цели в работния процес на Luigi

Съществуващият MySqlTarget в luigi използва отделна таблица с маркери, за да посочи кога задачата е завършена. Ето грубия подход, който бих възприел... но въпросът ви е много абстрактен, така че вероятно ще бъде по-сложен в действителност.

import luigi
from datetime import datetime
from luigi.contrib.mysqldb import MySqlTarget


class TaskA(luigi.Task):
    rundate = luigi.DateParameter(default=datetime.now().date())
    target_table = "table_to_update"
    host = "localhost:3306"
    db = "db_to_use"
    user = "user_to_use"
    pw = "pw_to_use"

    def get_target(self):
        return MySqlTarget(host=self.host, database=self.db, user=self.user, password=self.pw, table=self.target_table,
                           update_id=str(self.rundate))

    def requires(self):
        return []

    def output(self):
        return self.get_target()

    def run(self):
        #update table
        self.get_target().touch()


class TaskB(luigi.Task):
    def requires(self):
        return [TaskA()]

    def run(self):
        # reading from target_table



  1. Database
  2.   
  3. Mysql
  4.   
  5. Oracle
  6.   
  7. Sqlserver
  8.   
  9. PostgreSQL
  10.   
  11. Access
  12.   
  13. SQLite
  14.   
  15. MariaDB
  1. MySQL:Вмъкнете дата и час в друго поле за дата и час

  2. Не може да се разреши името на таблицата близо до

  3. Изглежда не мога да свържа моята PHP страница с моя SQL тестов сървър и база данни

  4. Тествайте за NULL в множество колони в MySQL

  5. ГРЕШКА:SQLSTATE[HY000] [2002] Не може да се осъществи връзка, защото целевата машина активно я отказа