내보내기 작업 만들기

이 페이지에서는 작업을 만들어 push 큐에 추가하는 방법에 대해 설명합니다. 태스크를 처리하려면 새 태스크 객체를 만들어 큐에 추가해야 합니다. 태스크를 처리하는 서비스와 핸들러를 명시적으로 지정하고 필요에 따라 태스크별 데이터를 핸들러에 함께 전달할 수 있습니다. 태스크를 실행할 시간을 예약하거나 태스크가 실패할 경우 재시도할 횟수를 제한하는 등 태스크의 구성을 세부적으로 조정할 수도 있습니다.

새 태스크 만들기

태스크를 만들어 큐에 추가하려면 taskqueue.add() 함수를 호출합니다. 다음 코드는 worker라는 서비스를 타겟팅하는 태스크를 만들고 URL /update-counter를 설정하여 핸들러를 호출합니다.

class EnqueueTaskHandler(webapp2.RequestHandler):
    def post(self):
        amount = int(self.request.get('amount'))

        task = taskqueue.add(
            url='/update_counter',
            target='worker',
            params={'amount': amount})

        self.response.write(
            'Task {} enqueued, ETA {}.'.format(task.name, task.eta))

또는 Task 객체를 만들고 이 객체의 add() 메서드를 호출해도 됩니다.

작업자 서비스 지정

큐에서 태스크를 꺼내면 태스크 큐 서비스가 작업자 서비스로 해당 태스크를 전송합니다. 모든 태스크에는 최종적으로 태스크를 수행할 서비스와 핸들러를 결정하는 target과 url이 있습니다.

target

target은 태스크를 수행하기 위해 HTTP 요청을 수신할 서비스를 지정합니다. 서비스/버전/인스턴스를 표준 형식 중 하나로 지정하는 문자열로서 가장 일반적으로 사용되는 형식은 다음과 같습니다.

    service
    version.service
    instance.version.service

target 문자열은 앱의 도메인 이름 앞에 추가됩니다. 다음 세 가지 방법으로 태스크의 target을 설정할 수 있습니다.

  • 태스크를 생성할 때 target을 선언합니다. taskqueue.add() 함수의 target 매개변수를 사용하여 target을 명시적으로 설정할 수 있습니다. 위의 예를 참조하세요.

  • queue-blue의 정의에서처럼 queue.yaml에서 큐를 정의할 때 target 지시문을 포함합니다. target이 있는 큐에 추가되는 모든 태스크는 태스크 생성 시점에 다른 target이 할당되었더라도 큐의 target을 사용합니다.

  • 앞의 두 가지 방법 중 하나로 target을 지정하지 않으면 태스크를 큐에 추가한 서비스 버전이 태스크의 target이 됩니다. 기본 서비스와 버전에서 이 방식으로 태스크를 큐에 추가한 경우, 태스크가 실행되기 전에 기본 버전이 변경되면 새 기본 버전에서 태스크가 실행됩니다.

url

url은 target 서비스의 핸들러 중에서 태스크를 수행할 핸들러 하나를 선택합니다.

url은 target 서비스의 핸들러 URL 패턴 중 하나와 일치해야 합니다. 태스크에 지정된 메서드가 GET 또는 PULL인 경우 url에 쿼리 매개변수가 포함될 수 있습니다. url을 지정하지 않으면 기본 URL인 /_ah/queue/[QUEUE_NAME]이 사용되며, 여기서 [QUEUE_NAME]은 태스크의 큐 이름입니다.

핸들러에 데이터 전달

태스크에 지정된 메서드가 GET 또는 PULL인 경우에만 데이터를 태스크의 URL에 포함되는 쿼리 매개변수로 핸들러에 전달할 수 있습니다.

다음 필드 중 하나를 사용하여 데이터를 태스크에 추가할 수도 있습니다.

  • payload: HTTP 요청의 본문에 태스크 데이터를 전달합니다.
  • params

다음 세 가지 호출은 모두 동일합니다.

taskqueue.add(method=GET, url='/update-counter?key=blue', target='worker')
taskqueue.add(url='/update-counter', params={'key': 'blue'}, target='worker')
taskqueue.add(url='/update-counter', payload="{'key': 'blue'}", target='worker')

태스크 이름 지정

새 태스크를 만들면 기본적으로 App Engine이 태스크에 고유한 이름을 할당합니다. 그러나 name 매개변수를 사용하면 태스크 이름을 직접 할당할 수 있습니다. 태스크 이름을 직접 할당하면 명명된 태스크가 중복되지 않는다는 이점이 있습니다. 즉, 태스크 이름을 사용하면 한 태스크가 한 번만 추가됨을 보장할 수 있습니다. 중복 제거는 태스크 완료 또는 삭제 후 9일 동안 유지됩니다.

중복 제거 로직은 상당한 성능 오버헤드를 유발하며, 이에 따라 지연 시간이 증가하고 명명된 태스크와 관련하여 오류율이 상승할 수 있습니다. 태스크 이름이 타임스탬프처럼 순차적인 경우에는 이러한 비용이 대폭 증가할 수 있습니다. 따라서 이름을 직접 할당할 때는 태스크 이름에 콘텐츠의 해시와 같이 고르게 분산되는 프리픽스를 사용하는 것이 좋습니다.

태스크 이름을 직접 할당하는 경우 이름의 최대 길이는 500자이며 대문자, 소문자, 숫자, 밑줄, 하이픈을 포함할 수 있습니다.

taskqueue.add(url='/url/path', name='first-try')

비동기식으로 태스크 추가

기본적으로 큐에 태스크를 추가하는 호출은 동기식입니다. 대부분의 경우 동기 호출은 원활하게 작동합니다. 큐에 태스크를 추가하는 과정은 일반적으로 신속하게 이루어집니다. 태스크 추가에 매우 긴 시간이 드는 경우가 일부 있지만 태스크를 추가하는 데 걸리는 시간의 중앙값은 5ms 미만입니다.

여러 큐에 태스크를 추가하는 과정은 일괄 처리가 불가능하므로 Task Queue API는 이러한 태스크를 병렬로 추가하여 이 같은 지연 시간을 최소화하는 비동기 호출 기능도 제공합니다. 이 기능은 동시에 여러 대기열에 여러 개의 작업을 추가해야 하서 지연 시간에 극도로 민감한 애플리케이션을 구축할 경우에 유용합니다.

태스크 큐에 비동기 호출을 수행하려면 Queue 클래스와 RPC 객체에서 제공하는 비동기 메서드를 사용합니다. 그런 다음 반환된 RPC 객체에서 get_result()를 호출하여 요청을 강제로 완료합니다. 트랜잭션에 태스크를 비동기식으로 추가할 경우, 트랜잭션을 커밋하기 전에 RPC 객체에서 get_result()을 호출하여 요청이 완료되었는지 확인해야 합니다.

Cloud Datastore 트랜잭션에서 큐에 태스크 추가

Datastore 트랜잭션의 일부로 큐에 태스크를 추가하면 트랜잭션이 성공적으로 커밋되는 경우에만 큐에 태스크가 추가됩니다. 트랜잭션에 추가된 태스크는 트랜잭션의 일부로 간주되며 동일한 수준의 격리 및 일관성이 적용됩니다.

애플리케이션은 단일 트랜잭션 도중 태스크 큐에 트랜잭션 태스크를 5개를 초과하여 삽입할 수 없습니다. 트랜잭션 태스크의 이름은 사용자가 지정한 이름이 아니어야 합니다.

다음 코드 샘플에서는 Datastore 트랜잭션의 일부로 push 큐에 트랜잭션 태스크를 삽입하는 방법을 보여줍니다.

from google.appengine.api import taskqueue
from google.appengine.ext import ndb

@ndb.transactional
def do_something_in_transaction():
  taskqueue.add(url='/path/to/my/worker', transactional=True)
  #...

do_something_in_transaction()

작업자 서비스 대신 지연된 태스크 라이브러리 사용

앞 섹션에서 설명한 것처럼 개별 태스크마다 핸들러를 설정하거나 태스크의 복잡한 인수를 직렬화 및 역직렬화하기는 번거로울 수 있으며, 큐에서 종류가 다양한 소규모 태스크를 많이 실행하려는 경우에는 특히 그렇습니다. Python SDK에 포함된 라이브러리(google.appengine.ext.deferred)가 노출하는 간단한 함수를 사용하면 전용 태스크 핸들러를 설정하고 매개변수를 직렬화 및 역직렬화하는 모든 작업을 생략할 수 있습니다.

이 라이브러리를 사용하려면 기본 제공된 deferred를 app.yaml에 추가해야 합니다. 자세한 내용은 app.yaml 참조의 기본 제공 핸들러 섹션을 참조하세요.

deferred 라이브러리를 사용하려면 함수와 인수를 deferred.defer()에 전달하기만 하면 됩니다.

import logging

from google.appengine.ext import deferred

def do_something_expensive(a, b, c=None):
    logging.info("Doing something expensive!")
    # Do your work here

# Somewhere else
deferred.defer(do_something_expensive, "Hello, world!", 42, True)

deferred 라이브러리는 함수 호출과 인수를 패키징한 후 태스크 큐에 추가합니다. 태스크가 실행되면 deferred 라이브러리가 do_something_expensive("Hello, world!", 42, True)를 실행합니다.

멀티 테넌트 애플리케이션에서 태스크 처리

기본적으로 push 큐에서는 태스크 생성 시 네임스페이스 관리자에 설정된 현재 네임스페이스를 사용합니다. 애플리케이션에서 멀티테넌시 지원을 사용하는 경우에는 네임스페이스 Python 2 API를 참조하세요.

다음 단계