Cloud Tasks ile işlevleri sıraya alma


Görev sırası işlevleri, Google Cloud Görevleri Uygulamanızın zaman alan, kaynak yoğun veya bant genişliği sınırlı olarak çalıştırılmasına yardımcı olmak için ana uygulama akışınızın dışında eşzamansız olarak yapabilirsiniz.

Örneğin, geniş bir resim kümesinin yedeklerini oluşturmak istediğinizi Şu anda hız sınırı olan bir API'de barındırılan dosyalar. Bir insanın sorumlu tüketicisiyseniz, oran sınırlarına uymanız gerekir. Ayrıca, bu tür uzun süreli işler, zaman aşımları ve anlamına gelir.

Bu karmaşıklığı azaltmak için, Arkadaş Bitkiler projenizde kullanılabilecek temel scheduleTime ve dispatchDeadline gibi görev seçeneklerini ayarlayabilir, Cloud Tasks'ta bir sıraya göndermesini sağlar. Bulut Görevleri verimli bir şekilde tıkanıklık kontrolünü sağlamak ve yeniden deneme politikalarında bulunmayı unutmayın.

Cloud Functions for Firebase v3.20.1 ve üzeri sürümler için Firebase SDK'sı birlikte çalışır Firebase Admin SDK v10.2.0 ve sonraki sürümleri ile görev sırası işlevlerini desteklemek için.

Görev sırası işlevlerinin Firebase ile kullanılması, Cloud Tasks işleniyor. Görüntüleyin Cloud Tasks fiyatlandırması konulu videomuzu izleyin.

Görev sırası işlevleri oluşturma

Görev sırası işlevlerini kullanmak için şu iş akışını izleyin:

  1. Cloud Functions için Firebase SDK'sını kullanarak görev sırası işlevi yazın.
  2. İşlevinizi bir HTTP isteği ile tetikleyerek test edin.
  3. İşlevinizi Firebase CLI ile dağıtın. Görevinizi dağıtırken ilk kez kullanıyorsanız CLI, yeni bir Cloud Tasks'ta görev sırası seçenekleri (hız sınırlama ve yeniden deneme) kullanarak oluşturun.
  4. Yeni oluşturulan görev sırasına, ayarlamak için parametreleri ileterek görevleri ekleyin bir yürütme planı olabilir. Bunu, kodu yazarak Yönetici SDK'sını kullanıp Cloud Functions for Firebase'e dağıtabilirsiniz.

Görev sırası işlevlerini yazma

onDispatch kullanın görev sırası işlevleri yazmaya başlayın. Önemli bir görev sırası işlevi yazmanın bir parçası da sıra başına yeniden deneme ve hızı ayarlamaktır. sınırlayıcı yapılandırma. Bu sayfadaki kod örnekleri, NASA'nın kendi evindeki tüm görüntüleri yedekleyen bir hizmeti Günün Astronomi Resmi:

Görev sırası işlevlerini yapılandırma

Görev sırası işlevleri, güçlü bir yapılandırma ayarı grubuyla birlikte gelir 'i kullanarak bir görev sırasının hız sınırlarını ve yeniden deneme davranışını hassas bir şekilde kontrol edebilirsiniz:

exports.backupApod = functions
    .runWith( {secrets: ["NASA_API_KEY"]})
    .tasks.taskQueue({
      retryConfig: {
        maxAttempts: 5,
        minBackoffSeconds: 60,
      },
      rateLimits: {
        maxConcurrentDispatches: 6,
      },
    }).onDispatch(async (data) => {
index.js
  • retryConfig.maxAttempts=5: Görev sırasındaki her görev otomatik olarak en fazla 5 kez yeniden denendi. Bu, ağ gibi geçici hataları azaltmaya yardımcı olur bağımlı, harici bir hizmette hatalar veya geçici hizmet aksamaları olabilir.
  • retryConfig.minBackoffSeconds=60: Her görev en az 60 saniye sonra yeniden denenir hariç tutmanızı sağlar. Bu, her deneme arasında büyük bir tampon sağlar Dolayısıyla, 5 yeniden deneme hakkını çok hızlı bir şekilde bitirmek için acele etmeyiz.
  • rateLimits.maxConcurrentDispatch=6: En fazla 6 görev tek seferde dağıtılır yardımcı olabilir. Bu sayede, temel alınan kaynağa istikrarlı bir talep akışı sağlanabilir işlevi görebilir ve etkin örneklerin ve baştan başlatmaların sayısını azaltmaya yardımcı olur.

Görev sırası işlevlerini test etme

Firebase Local Emulator Suite'teki görev sırası işlevleri basit olarak gösterildi HTTP işlevleri. HTTP POST isteği göndererek emüle edilmiş bir görev işlevini test edebilirsiniz. bir json veri yüküyle istek:

 # start the Firebase Emulators
 firebase emulators:start

 # trigger the emulated task queue function
 curl \
  -X POST                                            # An HTTP POST request...
  -H "content-type: application/json" \              # ... with a JSON body
  http://localhost:$PORT/$PROJECT_ID/$REGION/$NAME \ # ... to function url
  -d '{"data": { ... some data .... }}'              # ... with JSON encoded data

Görev sırası işlevlerini dağıtma

Görev sırası işlevini Firebase CLI kullanarak dağıtın:

$ firebase deploy --only functions:backupApod

Bir görev sırası işlevini ilk kez dağıtırken CLI, bir görev sırası işlevi Cloud Tasks'ta şu seçeneklere sahip görev sırası (hız sınırlama ve yeniden dene) kaynak kodunuzda belirtilir.

İşlevleri dağıtırken izin hatalarıyla karşılaşırsanız uygun IAM rollerini komutu, dağıtım komutlarını çalıştıran kullanıcıya atanır.

Görev sırası işlevlerini sıraya koyma

Görev sırası işlevleri, güvenilir bir kullanıcıdan Cloud Tasks'ta sıraya alınabilir Firebase Admin SDK'nın kullanıldığı Cloud Functions for Firebase gibi bir sunucu ortamı Node.js'yi tıklayın. Yönetici SDK'larını kullanmaya yeni başladıysanız bkz. Başlamak için Firebase'i bir sunucuya ekleyin.

Tipik bir akışta Admin SDK yeni bir görev oluşturur ve bu görevi ve görev için yapılandırmayı belirler:

exports.enqueueBackupTasks = functions.https.onRequest(
async (_request, response) => {
  const queue = getFunctions().taskQueue("backupApod");
  const enqueues = [];
  for (let i = 0; i <= 10; i += 1) {
    // Enqueue each task with i*60 seconds delay. Our task queue function
    // should process ~1 task/min.
    const scheduleDelaySeconds = i * 60 
    enqueues.push(
        queue.enqueue(
          { id: `task-${i}` },
          {
            scheduleDelaySeconds,
            dispatchDeadlineSeconds: 60 * 5 // 5 minutes
          },
        ),
    );
  }
  await Promise.all(enqueues);
  response.sendStatus(200);

});
  • scheduleDelaySeconds: Örnek kod, ve N’inci görev için N’inci dakika gecikmesini ilişkilendirerek görevleri tamamlayın. Bu Yaklaşık 1 görev/dakika tetikleme anlamına gelir. Şunu da deneyebilirsiniz: Cloud Tasks'ın tetiklenmesini istiyorsanız scheduleTime görev zaman çizelgesidir.
  • dispatchDeadlineSeconds: Maksimum süre Cloud Tasks bekleyecek tamamlanması gereken aktiviteleri ifade eder. Cloud Tasks yeniden denenecek yeniden denemenin ardından görev konfigürasyonunu kullanabilirsiniz. Örnekte, sıra, görevi en fazla 5 kez yeniden deneyecek şekilde yapılandırılmıştır ancak görev İşlemin tamamı (yeniden deneme denemeleri dahil) durumunda otomatik olarak iptal edilir 5 dakikadan fazla sürer.

Sorun giderme

Cloud Tasks günlük kaydını etkinleştir

Cloud Tasks günlükleri, şunun gibi yararlı teşhis bilgileri içerir: bir görevle ilişkili isteğin durumudur. Varsayılan olarak, Cloud Tasks, yüksek miktarda günlük kaydı olması nedeniyle devre dışı bırakıldı üzerinde etkisi olur. Hata ayıklama günlüklerini etkinleştirmenizi öneririz ve hata ayıklama işlemleri yürütürken sizi aktif olarak kilitleyin. Görüntüleyin Açılıyor günlük kaydı.

IAM İzinleri

Görevleri sıraya koyarken veyaPERMISSION DENIED Cloud Tasks, görev sırası işlevlerinizi çağırmaya çalışır. Araç açılış sayfalarınızla ilgili projede şu IAM bağlamaları bulunur:

gcloud projects add-iam-policy-binding $PROJECT_ID \
  --member=serviceAccount:${PROJECT_ID}@appspot.gserviceaccount.com \
  --role=roles/cloudtasks.enqueuer

  • Görevleri Cloud Tasks'ta sıraya almak için kullanılan kimliğin izin alması gerekir Cloud Tasks'te bir görevle ilişkili hizmet hesabını kullanma

    Örnekte bu App Engine varsayılan hizmet hesabıdır.

Google Cloud IAM belgelerini inceleyin App Engine varsayılan hizmet hesabını ekleme talimatları için App Engine'in varsayılan hizmet hesabının kullanıcısı olarak ayarlandı.

gcloud functions add-iam-policy-binding $FUNCTION_NAME \
  --region=us-central1 \
  --member=serviceAccount:${PROJECT_ID}@appspot.gserviceaccount.com \
  --role=roles/cloudfunctions.invoker