Вопросы по теме 'google-cloud-pubsub'
Каков максимальный предел значения атрибутов Google Pub / Sub?
Я пытаюсь использовать Google Pub / Sub в своем проекте. И я получил ошибку, потому что он превышает предел значения атрибутов.
Сообщение: Ошибка клиента: POST https://pubsub.googleapis.com/v1/projects/<project>/topics/<topic>:publish...
1704 просмотров
schedule
21.12.2022
Авторизация Google Cloud API
Я хочу использовать облачный паб Google для реализации уведомлений Facebook в приложении блога, которое имеет следующую архитектуру.
У меня есть как веб-устройство, так и устройство Android в качестве клиента для остальных сервисов. Эти остальные...
167 просмотров
schedule
21.04.2024
Отложить обработку сообщения и удалить перед обработкой
Мне нужна эта возможность отправлять push-уведомления для действия в мобильном приложении, но ждать, пока пользователь отменит действие, пока, скажем, 10 секунд.
Можно ли отложить обработку сообщения, опубликованного в теме, на 10 секунд? А затем...
9296 просмотров
schedule
16.08.2022
Получение незакодированных данных из Google Cloud Pub / Sub вместо base64
Я пытаюсь использовать библиотеку Python для Pub / Sub, но продолжаю получать эту ошибку: TypeError: Incorrect padding . Быстрый поиск в Google выявил эту проблему: https://github.com/GoogleCloudPlatform/google-cloud-python/pull/2527
Однако это...
1366 просмотров
schedule
17.05.2022
Google Dataflow с исходным кодом PubSubIO постоянно доступен?
Предположим, что у нас есть некоторые данные, поступающие через тему Google PubSub, и структура ее трафика по своей природе резкая, с потенциально долгим периодом молчания, прежде чем пачка данных будет поступать с большой скоростью в течение...
95 просмотров
schedule
25.11.2022
Прочтите сообщения с помощью pub / sub и загрузите их в Datastax в Google Cloud.
Я развернул кластер из 9 узлов Datastax в облаке Google.
Теперь мне дали требование прочитать данные из QUEUE и загрузить их в Datastax в облаке Google (продолжение потоковой передачи).
Я знаю, что pub / sub может читать данные из QUEUE, но...
675 просмотров
schedule
19.02.2022
Работает ли эмулятор Google PubSub с клиентской библиотекой Google Cloud Pub / Sub API?
Наше приложение Java работает на Google App Engine. Он использует PubSub Google для публикации и использования сообщений.
Для Google PubSub есть два клиента Java. Рекомендуется использовать клиент gRPC, но, как указано внизу этой страницы,...
1618 просмотров
schedule
28.12.2021
Создайте конвейер Apache Beam для чтения из Google Pub / Sub
Я пытаюсь создать потоковый конвейер с использованием apache-beam, который читает предложения из google pub / sub и записывает слова в таблицу Bigquery.
Я использую 0.6.0 версию apache-beam.
Следуя примерам, я сделал это:
public class...
2060 просмотров
schedule
21.10.2022
Как я могу использовать службу обмена сообщениями в режиме реального времени Google Cloud Pub/Sub в Android
Я хочу разработать игру в угадайку , в которой пользователи могут общаться друг с другом, например, в группе/один на один, и она должна быть кросс-платформенной как для Android, так и для iOS.
Итак, я ищу в Интернете и нашел это...
603 просмотров
schedule
21.08.2022
Каковы плюсы и минусы между потоковой передачей данных в Bigquery и загрузкой данных в PubSub, а затем использованием потока данных для вставки данных в BigQuery?
Насколько я знаю, потоковая передача данных в BigQuery может привести к дублированию строк, как упоминается здесь https://cloud.google.com/bigquery/streaming-data-into-bigquery#real-time_dashboards_and_queries
С другой стороны, загрузка данных в...
926 просмотров
schedule
28.02.2022
Ошибка pubsub INVALID_ARGUMENT при создании подписки на конечную точку URL
Создал тестовую тему на GC pubsub и может без проблем создавать подписки по запросу, но как только я пытаюсь создать подписку на конечную точку URL, я получаю «ошибку pubsub INVALID_ARGUMENT»
Имя подписки Params: testingsub URL-адрес конечной...
7816 просмотров
schedule
22.02.2022
Триггер окна Cloud Dataflow перезаписывает значение из закрытого окна
Я пишу поток данных (Beam SDK 2.0.0), который читает из Pub/Sub, подсчитывает элементы в окне, а затем сохраняет подсчеты в BigTable в виде временных рядов. Окна фиксируются на длительности в 1 минуту.
Мое намерение состояло в том, чтобы обновлять...
170 просмотров
schedule
06.06.2024
Apache Beam - тест интеграции с неограниченной коллекцией PCollection
Мы создаем интеграционный тест для конвейера Apache Beam и сталкиваемся с некоторыми проблемами. См. Контекст ниже ...
Подробная информация о нашем трубопроводе:
Мы используем PubsubIO в качестве источника данных (неограниченный...
1530 просмотров
schedule
19.05.2024
Google Cloud PubSub: ранее действующая подписка внезапно стала неавторизованной
У меня проблемы с API Google Cloud PubSub. Недавно я начал использовать Cloud PubSub для постановки сообщений в очередь для чат-сервера, над которым я работаю. Сообщения, поступающие из подписки PubSub, пересылаются пользователям с помощью...
396 просмотров
schedule
04.11.2023
PubSubException: io.grpc.StatusRuntimeException: НЕДОСТУПНО
ребята, я получаю следующее сообщение об ошибке, используя Pubsub:
Исключение в потоке "main" com.google.cloud.pubsub.PubSubException: io.grpc.StatusRuntimeException: UNAVAILABLE: код ошибки HTTP/2: NO_ERROR Received Goaway max_age .......
4688 просмотров
schedule
21.05.2024
Луч Apache: чтение из нескольких подписок
Я хочу создать поток данных, который прослушивает несколько подписок и записывает в BigQuery. Согласно документации Google, я могу читать несколько PCollection объектов и объединять их вместе.
Однако, глядя на PubsubIO.Read javadoc здесь ,...
601 просмотров
schedule
21.03.2023
Как изменить имя хоста MQTT для Google Iot Core
Я работаю над IoT-устройством, используя google-cloud-iot-core, но я хотел бы разрешить стороннюю поддержку, поэтому я хочу изменить имя хоста mqtt, как это можно сделать?
заранее спасибо
240 просмотров
schedule
15.09.2023
Ошибка при попытке запустить эмулятор PubSub локально
Я хочу провести локальное тестирование pubsub, поэтому я выполнил «gcloud components install pubsub-emulator».
Теперь, когда я пытаюсь выполнить "запуск pubsub бета-эмуляторов gcloud", я получаю следующую ошибку:
ERROR:...
1063 просмотров
schedule
19.07.2022
Google Cloud Pub/Sub Pull PERMISSION_DENIED
У меня есть Google Cloud SDK на моей локальной машине, и когда я запускаю команду:
gcloud beta pubsub subscriptions pull --auto-ack MY_SUBSCRIPTION_NAME
Он работает просто отлично, и я могу видеть сообщения.
Но если я сделаю то же самое на...
3494 просмотров
schedule
17.06.2022
Поток данных Google: как анализировать большой файл с допустимым массивом JSON из FileIO.ReadableFile
В моем конвейере преобразование FileIO.readMatches() считывает большой файл JSON (около 300-400 МБ) с допустимым массивом JSON и возвращает объект FileIO.ReadableFile для следующего преобразования. Моя задача — прочитать каждый объект JSON из...
663 просмотров
schedule
07.02.2023
