taskqueues-backup-images

Back up images using a Task Queue Function (v2)

This quickstart demonstrates how to setup a Task Queue Function using the Firebase SDK for Cloud Functions (v2).

Introduction

Task queue functions make it easy to manage the execution, dispatch, and delivery of a large number of distributed tasks.

We leverage its power here to set up a service that backs up all images from NASA's Astronomy Picture of the Day.

Task queue functions are powered by Google Cloud Tasks. Learn more about task queue functions.

Functions

The sample code consists of 2 functions:

1. backupapod

A task queue function responsible for processing the logic for backing up the Astronomy Picture of the Day ("apod") for the given date. This function will be triggered for every task enqueued on the corresponding queue created in Cloud Tasks.

Task queue functions come with a powerful set of configuration to precisely control rate limits and retry behavior of a task queue. See the documentation to learn more about configuring task queue functions.

Our sample make use of following configurations:

1. retryConfig.maxAttempts=5 - Each task in our task queue will be automatically retried upto 5 times. This helps us mitigate transient errors like network errors or temporary service disruption of a dependent, external service.
2. retryConfig.minBackoffSeconds=60 - Each task will be retried at least 60 seconds apart from each attempt. This gives us a large buffer between each attempt so we don't rush to exhaust our 5 retry attempts too quickly.
3. rateLimits.maxConcurrentDispatch - At most 6 tasks will be dispatched at a given time. At most 6 tasks will be dispatched at a given time. This helps ensure a steady stream of requests to the underlying function and helps reduce the number of active instances and cold starts.

You can further configure this function with following environment variables:

• BACKUP_BUCKET: Name of the bucket to back up "apod" images. Defaults to default Cloud Storage bucket.

2. enqueuebackuptasks

An HTTP function responsible for enqueuing tasks to our task queue. The function uses the Firebase Admin SDK to create and enqueue a task for each day we want to backup an "apod" image.

Note that we explicitly query for and specify the uri of the task queue function when enqueueing task.

We are required to do this because v2 task queue functions doesn't come with a deterministic url.

You can configure this function with following environment variables:

• BACKUP_COUNT: Number of days to back up Astronomy Picture of the Day, starting from 1995-06-17 (the first day of publication). Defaults to 100.

• HOURLY_BATCH_SIZE: Number of tasks to enqueue at each hour. Note that NASA API imposes a limit of 1000 reqs/hour. Defaults to 500.

Setup and Deploy

NASA Open API Key

The sample uses NASA Open APIs to retrieve Astronomy Picture of the Day images. You need to register for an account to get your API Key and hook it up the task queue function by creating a secret:

$ firebase functions:secrets:set NASA_API_KEY
? Enter a value for NASA_API_KEY [input is hidden]
✔  Created a new secret version projects/XXX/secrets/NASA_API_KEY/versions/1

Deploy

Deploy functions using Firebase CLI:

$ firebase deploy

IAM Policy

You may see PERMISSION DENIED errors when enqueueing tasks or when Cloud Task tries to invoke your task queue functions. Ensure that your project has following IAM bindings:

• Identity used to enqueue tasks to Cloud Tasks needs cloudtasks.tasks.create IAM permission
  • In our sample, this is the Compute Engine default service account.

gcloud projects add-iam-policy-binding $PROJECT_ID \
  --member=serviceAccount:${PROJECT_NUMBER}[email protected] \
  --role=roles/cloudtasks.enqueuer

• Identity used to enqueue tasks to Cloud Task needs permission to use the service account associated with a task in Cloud Tasks.
  • In our sample, this is the Compute Engine default service account.

Please follow Google Cloud IAM documentation to add App Engine default service account as user of App Engine default service account.

• Identity used to trigger the Task Queue function needs cloudfunctions.functions.invoke permission.
  • In our sample, this is the Compute Engine default service account.

gcloud functions add-iam-policy-binding backupapod \
  --region=us-central1 \
  --member=serviceAccount:${PROJECT_NUMBER}[email protected] \
  --role=roles/cloudfunctions.invoker