MySQLとGo言語を用いてシンプルなタスクスケジューリングシステムを構築する方法

2年 ago
綾乃, 一希
2 minutes

以下は、MySQL と Go 言語を使用してタスクスケジューリングシステムを開発する方法を示す、簡単なサンプルです。

  1. MySQLデータベースとGo言語開発環境をインストールする。
  2. タスクとスケジュール情報を格納する MySQL データベースを作成します。task_scheduler という名前のデータベースを作成するには、次のコマンドを使用できます。
CREATE DATABASE task_scheduler;
  1. タスク
CREATE TABLE tasks (
id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(255) NOT NULL,
description TEXT,
schedule_time DATETIME NOT NULL,
status ENUM('pending', 'running', 'completed') DEFAULT 'pending',
created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP
);
  1. Go言語でプロジェクトを作成し、MySQLデータベースドライバをインポートする。
  2. タスク情報を格納する Task 構造体を作成する。この構造体は、以下のコードを使用して作成できます。
type Task struct {
ID            int
Name          string
Description   string
ScheduleTime  time.Time
Status        string
CreatedAt     time.Time
UpdatedAt     time.Time
}
  1. タスク スケジューラ
type TaskScheduler struct {
DB *sql.DB
}
  1. タスクを追加する
func (ts *TaskScheduler) AddTask(task *Task) error {
stmt, err := ts.DB.Prepare("INSERT INTO tasks(name, description, schedule_time) VALUES(?, ?, ?)")
if err != nil {
return err
}
defer stmt.Close()
_, err = stmt.Exec(task.Name, task.Description, task.ScheduleTime)
if err != nil {
return err
}
return nil
}
  1. 保留タスクの取得
func (ts *TaskScheduler) GetPendingTasks() ([]*Task, error) {
tasks := []*Task{}
rows, err := ts.DB.Query("SELECT id, name, description, schedule_time, status, created_at, updated_at FROM tasks WHERE status = 'pending'")
if err != nil {
return nil, err
}
defer rows.Close()
for rows.Next() {
task := &Task{}
err = rows.Scan(&task.ID, &task.Name, &task.Description, &task.ScheduleTime, &task.Status, &task.CreatedAt, &task.UpdatedAt)
if err != nil {
return nil, err
}
tasks = append(tasks, task)
}
return tasks, nil
}
  1. Task ステータスの更新
func (ts *TaskScheduler) UpdateTaskStatus(task *Task, status string) error {
stmt, err := ts.DB.Prepare("UPDATE tasks SET status = ? WHERE id = ?")
if err != nil {
return err
}
defer stmt.Close()
_, err = stmt.Exec(status, task.ID)
if err != nil {
return err
}
return nil
}
  1. 生まれながらの英語話者は外国語を学ぶ際に、母国語の習慣に引きずられやすい。
func main() {
db, err := sql.Open("mysql", "user:password@tcp(localhost:3306)/task_scheduler")
if err != nil {
log.Fatal(err)
}
defer db.Close()
scheduler := &TaskScheduler{DB: db}
for {
tasks, err := scheduler.GetPendingTasks()
if err != nil {
log.Println(err)
continue
}
for _, task := range tasks {
// 执行任务
log.Println("Running task:", task.Name)
// 更新任务状态为运行中
err = scheduler.UpdateTaskStatus(task, "running")
if err != nil {
log.Println(err)
continue
}
// 模拟任务执行
time.Sleep(5 * time.Second)
// 更新任务状态为已完成
bannerAds