Ошибки публикации и подписки GCPPython

Программы на Python
Ответить
Anonymous
 Ошибки публикации и подписки GCP

Сообщение Anonymous »

Я создаю простое веб-приложение, которое принимает HTTP POST и должно запускать событие Cloud Pub-Sub. Без pub-sub приложение развертывается нормально, и я могу достичь конечной точки.
Я создал примеры функций. Я сделал это через функции Cloud Run (console.cloud.google.com/functions/). Здесь показано, что развернуто как «Функции запуска в облаке» и через Cloud Run (т. е. console.cloud.google.com/run). В качестве моей учетной записи отображается «Развернуто». Результаты одинаковые.
Для первоначального примера предварительно упакованного приложения hello world оба развертываются без проблем.
Теперь давайте добавим возможность публикации-подписки. Добавьте google-cloud-pubsub в файл требований. Добавьте клиент pub-sub в приложение. Создайте тему Pub-Sub (что я делаю через пользовательский интерфейс).
Теперь это выглядит так...
import json
import os
import functions_framework
from google.cloud import pubsub_v1

PROJECT_ID = "my project"
publisher = pubsub_v1.PublisherClient()

@functions_framework.http
def hello_http(request):
"""HTTP Cloud Function.
Args:
request (flask.Request): The request object.

Returns:
The response text, or any set of values that can be turned into a
Response object using `make_response`
.
"""
request_json = request.get_json(silent=True)
request_args = request.args

topic_name = 'projects/{project_id}/topics/{topic}'.format(
project_id=PROJECT_ID,
topic='test-topic',
)
message = {
'key': 'value',
'info': 'This is a test message'
}
future = publisher.publish(topic_name, json.dumps(message).encode("utf-8"))
future.result()

if request_json and 'name' in request_json:
name = request_json['name']
elif request_args and 'name' in request_args:
name = request_args['name']
else:
name = 'World'
return 'Hello {}!'.format(name)


Я обязательно получу эти предупреждения в консоли. Что они означают?
WARNING: All log messages before absl::InitializeLog() is called are written to STDERR
E0000 00:00:1734272617.454893 1 init.cc:229] grpc_wait_for_shutdown_with_timeout() timed out.

Кроме того, я получаю странные ошибки в консоли тестирования Google Cloud Platform Run, которые выглядят связанными со сборкой (например, /bin/sh: 2c3d685a15e9). Иногда возникают ошибки, иногда нет.
[9:47:15 PM] - Preparing function sources ...
[9:47:15 PM] - Loading new function sources ...
[9:47:22 PM] - Starting function...
[9:47:22 PM] - WARNING: All log messages before absl::InitializeLog() is called are written to STDERR
E0000 00:00:1734144439.303879 20 init.cc:229] grpc_wait_for_shutdown_with_timeout() timed out.
WARNING: All log messages before absl::InitializeLog() is called are written to STDERR
E0000 00:00:1734144441.495104 7 init.cc:229] grpc_wait_for_shutdown_with_timeout() timed out.
/bin/sh: 2c3d685a15e9: not found
/bin/sh: 2c3d685a15e9: not found


Подробнее здесь: https://stackoverflow.com/questions/792 ... sub-errors
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «Python»