Ich habe eine Feuerbasisfunktion, die versucht, eine Aufgabe mit einigen Daten zu übernehmen. Jedes Mal, wenn ich es nenne, erhalte ich die folgenden zwei Fehler aus den Cloud -Laufprotokollen: < /p>
requests.exceptions.httperror: 400 Client -Fehler: Schlechte Anfrage für URL:
https://cloudtasks.googleapis.com/v2/pr ... name/tasks
@scheduler_fn.on_schedule(schedule="every day 00:00", timeout_sec=540, secrets=[APIFY_API_KEY])
def update_brooklyn_listings(event: scheduler_fn.ScheduledEvent) -> None:
asyncio.run(update_brooklyn_listings_async())
async def update_brooklyn_listings_async():
result = await SOME_ASYNC_TASK
data = json.loads(result.get_bytes(format="json"))
body = {"data": data}
task_queue = functions.task_queue("functionname")
task_queue.enqueue(body)
Basierend auf dem Parameter Enqueue Dokumentation Es wird kein Optionsparameter benötigt, und der in die in übertragene Daten kann von einem beliebigen ausgeben. Irgendeine Idee, was ich hier fehlen könnte?
Ich habe eine Feuerbasisfunktion, die versucht, eine Aufgabe mit einigen Daten zu übernehmen. Jedes Mal, wenn ich es nenne, erhalte ich die folgenden zwei Fehler aus den Cloud -Laufprotokollen: < /p>
requests.exceptions.httperror: 400 Client -Fehler: Schlechte Anfrage für URL: https://cloudtasks.googleapis.com/v2/projects/project_id/locations/us-central1/queueues/task_function_name/tasks
@scheduler_fn.on_schedule(schedule="every day 00:00", timeout_sec=540, secrets=[APIFY_API_KEY])
def update_brooklyn_listings(event: scheduler_fn.ScheduledEvent) -> None:
asyncio.run(update_brooklyn_listings_async())
async def update_brooklyn_listings_async():
result = await SOME_ASYNC_TASK
data = json.loads(result.get_bytes(format="json"))
body = {"data": data}
task_queue = functions.task_queue("functionname")
task_queue.enqueue(body)
Basierend auf dem Parameter Enqueue Dokumentation Es wird kein Optionsparameter benötigt, und der in die in übertragene Daten kann von einem beliebigen ausgeben. Irgendeine Idee, was ich hier fehlen könnte?
Mobile version