如何在Go语言中为App Engine任务队列创建任务

import (
    "appengine"
    "appengine/taskqueue"
)

// 创建一个基本任务
func createBasicTask(c appengine.Context) *taskqueue.Task {
    // Path 字段指定了处理此任务的HTTP处理程序的URL路径。
    // 例如，当此任务被执行时，App Engine会向 /path/to/workertask 发送一个HTTP POST请求。
    t := &taskqueue.Task{
        Path: "/path/to/workertask",
    }
    return t
}

import (
    "appengine"
    "appengine/taskqueue"
    "log"
)

func addTaskToQueue(c appengine.Context) {
    task := &taskqueue.Task{
        Path: "/path/to/workertask",
    }

    // taskqueue.Add 将任务添加到队列。
    // 第一个参数是上下文（Context）。
    // 第二个参数是 Task 实例。
    // 第三个参数是队列名称。如果为空字符串，则添加到默认队列。
    _, err := taskqueue.Add(c, task, "") // 添加到默认队列
    if err != nil {
        log.Errorf(c, "Failed to add task: %v", err)
        return
    }
    log.Infof(c, "Task added successfully.")
}

import (
    "appengine"
    "appengine/datastore"
    "appengine/taskqueue"
    "log"
)

// 示例：在一个数据存储事务中创建并添加任务
func performTransactionWithTask(c appengine.Context) {
    err := datastore.RunInTransaction(c, func(txc appengine.Context) error {
        // 1. 在事务中执行数据存储操作
        // 例如，保存一个实体
        key := datastore.NewIncompleteKey(txc, "MyEntity", nil)
        _, err := datastore.Put(txc, key, &struct{ Value string }{"test"})
        if err != nil {
            log.Errorf(txc, "Datastore Put failed: %v", err)
            return err
        }

        // 2. 创建任务
        // 最重要的部分：如何创建任务实例
        t := &taskqueue.Task{Path: "/path/to/workertask"}

        // 3. 使用事务的上下文 (txc) 添加任务
        // 确保任务的添加与事务的提交绑定
        _, err = taskqueue.Add(txc, t, "") // 将任务添加到默认队列
        if err != nil {
            log.Errorf(txc, "Failed to add task within transaction: %v", err)
            return err // 如果任务添加失败，事务将回滚
        }

        log.Infof(txc, "Task prepared for addition within transaction.")
        return nil // 返回nil表示事务可以提交
    }, nil) // 事务选项，例如重试次数

    if err != nil {
        log.Errorf(c, "Transaction failed: %v", err)
    } else {
        log.Infof(c, "Transaction and task addition completed successfully.")
    }
}

import (
    "appengine"
    "appengine/taskqueue"
    "time"
    "encoding/json"
)

// 示例：创建一个带有负载和延迟的任务
func createAdvancedTask(c appengine.Context) (*taskqueue.Task, error) {
    data := map[string]string{
        "user_id": "12345",
        "action":  "process_order",
    }
    payload, err := json.Marshal(data)
    if err != nil {
        return nil, err
    }

    t := &taskqueue.Task{
        Path:    "/api/worker/processOrder",
        Method:  "POST",
        Payload: payload,
        Header:  map[string][]string{"Content-Type": {"application/json"}},
        Delay:   5 * time.Minute, // 延迟5分钟执行
        Name:    "order-processing-task-12345", // 唯一任务名称
        QueueName: "high-priority-queue", // 指定队列
    }
    return t, nil
}