非同期処理に使いたいので、調べてみました。
こちらを参考に
https://cloud.google.com/tasks/docs/creating-appengine-tasks?hl=ja
インストール
$ pip install google-cloud-tasks
まず、タスクを作ってキューに入れます。
--
@app.route('/task_send')
def task_send():
from google.cloud import tasks_v2
PROJECT = <プロジェクトID>
LOCATION = <リージョン>
QUEUE = "default"
client = tasks_v2.CloudTasksClient()
parent = client.queue_path(PROJECT, LOCATION, QUEUE)
app_route = "/task_run"
data = {
'a': "abc",
}
payload = json.dumps(data)
task = {
'app_engine_http_request': {
'http_method': 'POST',
'relative_uri': app_route,
'headers': {
'Content-Type': "application/json"
},
'body': payload.encode(),
}
}
response = client.create_task(parent, task)
--
説明
・LOCATION: GAEの実行場所(リージョン)です。
"us-central"の場合、"us-central1" とします。(1を追記)
・app_route: タスクを実行する場所(PATH)です。
・data: データをJSON形式で送りたいので、一旦dictに入れて、jsonに変換します。
・headers: Content-Typeを jsonにします。
※デフォルトは、"application/octet-stream"
次に、タスクを受け取ります。
--
@app.route('/task_run', methods=["POST"])
def task_run():
data = request.json
....
--
説明
・data: dictデータです。
あとは、お好きに。
