Go SDK hatalarını işleyin ve kesintiye uğrayan görevleri kurtarın

Go 1.22 veya üzerini resmi solvethree.com/sdk modülünün v0.1.0 sürümüyle kullanın. Kurulum için Go entegrasyon yönergelerine bakın.

Sunucu tarafındaki SOLVETHREE_API_KEY ve SOLVETHREE_PROXY ortam değişkenlerini ayarlayın. Örnekteki Site ve Action değerlerini hedef ana makine adınız ve eyleminizle değiştirin. Site için çalışma alanınızda etkin bir profil bulunmalıdır; ana makine adını göndermek profil oluşturmaz. Bu reCAPTCHA isteği tek bir proxy kullanır ve Type veya URL gerektirmez.

package main

import (
    "context"
    "fmt"
    "errors"
    "log"
    "os"
    "time"
    solvethree "solvethree.com/sdk"
)

func main() {
    client, err := solvethree.NewClient(os.Getenv("SOLVETHREE_API_KEY"), nil)
    if err != nil { log.Fatal(err) }
    ctx, cancel := context.WithTimeout(context.Background(), 180*time.Second)
    defer cancel()
    input := solvethree.TaskRequest{Site: "accounts.example.com", Action: "login", Proxy: os.Getenv("SOLVETHREE_PROXY")}
    result, err := client.Solve(ctx, input, solvethree.SolveOptions{})
    if err != nil {
        var failed *solvethree.TaskFailedError
        var api *solvethree.APIError
        var recovery *solvethree.Error
        switch {
        case errors.As(err, &failed):
            log.Printf("Failed task %s: %s", failed.TaskID, failed.ErrorCode)
        case errors.As(err, &recovery):
            log.Printf("Recovery request=%s task=%s", recovery.RequestID, recovery.TaskID)
            if errors.As(err, &api) { log.Printf("HTTP %d; retry delay %s", api.StatusCode, api.RetryAfter) }
            // Save input plus recovery.RequestID. Resume GetTask for a known TaskID;
            // otherwise replay CreateTask with identical inputs and that RequestID.
        }
        return
    }
    fmt.Println("Ready task:", result.ID)
    // Submit result.Solution.Token with its browser identity and original proxy.
}

Örnek, bağlam için 180 saniyelik bir son süre belirler ve bir SDK hatası kurtarma kimliklerini sağladığında bunları günlüğe kaydeder. Günlüğe kaydetmek kalıcı kurtarma sağlamaz: hatayı gözden çıkarmadan önce özgün input değerini, döndürülen RequestID değerini ve varsa TaskID değerini kaydedin.

“Hazır görev”, hedefin çözümü kabul ettiği değil, bir çözümün mevcut olduğu anlamına gelir. SDK bunu sizin yerinize göndermez. Solution.Token değerini döndürülen tarayıcı kimliğiyle ve bu tek proxy'li örnekte özgün proxy'yle gönderin.

Sarmalanmış hataları errors.As, iptali ise errors.Is ile inceleyin. Bu kontroller farklı soruları yanıtlar: tek bir hata kurtarma kimlikleri içerebilir, bir HTTP hatasını sarmalayabilir ve yine de kesintiye uğramış bir işlem olarak ele alınması gerekebilir.

Örnek, kurtarma dalında iç içe bir APIError olup olmadığını kontrol eder. Uygulamanızın son sürenin dolmasıyla açık bir iptali ayırt etmesi gerekiyorsa iptali ayrıca errors.Is ile kontrol edin.

Solve, görevi bir kez oluşturur. Yalnızca HTTP 429, 502, 503 veya 504 içeren geçici sorgulama yanıtlarını yeniden dener ve bağlamın son süresi içinde Retry-After değerine uyar. CreateTask, POST isteğini hiçbir zaman otomatik olarak yeniden denemez.

1. 1.

   Özgün isteği olduğu gibi saklayın

   Proxy veya aday listesi dahil tüm görev girdilerini istek kimliğiyle birlikte kaydedin. İstek kimliğini belirtmediğinizde CreateTask bir kimlik üretir; kurtarma hatasının sunduğu üretilmiş değeri kaydedin. İsteği daha sonra değişmiş olabilecek yapılandırmadan yeniden oluşturmayın.

2. 2.

   Görev kimliğini biliyorsanız GetTask kullanın

   Eski bağlamın süresi dolduysa veya iptal edildiyse yeni bir bağlam oluşturun, ardından kayıtlı TaskID değerini kullanarak GetTask ile görevi alın. Durum pending veya solving ise beklemeye devam edin, çözümü yalnızca ready durumunda kullanın ve failed durumunda durun.

3. 3.

   Oluşturma işlemini yalnızca görev kimliğini bilmiyorsanız tekrarlayın

   Kaydedilmiş özgün TaskRequest üzerindeki RequestID değerini kurtarılan istek kimliğine ayarlayın, ardından aynı girdilerle CreateTask çağrısı yapın. Aynı kimliği ve isteği yeniden kullanmak mevcut görevi döndürür. Bu kimliği yeniden kullanırken girdileri değiştirmek çakışmaya neden olur.

Yalnızca bağlantı zaman aşımına uğradığı için yeni bir istek kimliği kullanmayın. Bu, sonucu belirsiz görevi kurtarmak yerine yeni bir mantıksal görev başlatır. Önce özgün göreve ne olduğunu belirleyin; başarısız olduysa düzeltilmiş bir isteğin gerekip gerekmediğine karar vermeden önce hatasını inceleyin.