На SSH -терминале Training-VM перейдите в каталог этой лабораторной работы:

CODE...

Убедитесь, что служба Pub/Sub доступна и работает с помощью команды gcloud.

Создайте свою тему и опубликуйте прост

CODE...

• gcloud: это инструмент командной строки Google Cloud SDK, предоставляющий доступ к ресурсам Google Cloud.

• pubsub: это подкоманда, связанная с Google Cloud Pub/Sub, службой обмена сообщениями.

• topics: указывает, что мы выполняем операцию связанную с темами.

• create: это действие, которое указывает на создание новой темы.

• sandiego: это имя темы, которую вы создаете. В данном случае, тема будет названа "sandiego".

Таким образом, команда создает новую тему с именем "sandiego" в Google Cloud Pub/Sub, которую вы можете использовать для отправки и получения сообщений в системе обмена сообщениями Pub/Sub.

Опубликуйте простое сообщение:

CODE...

Команда gcloud pubsub topics publish sandiego --message "hello" используется для публикации со

Разберем каждую часть команды:

• gcloud: это инструмент командной строки Google Cloud SDK.

• pubsub: это подкоманда, связанная с Google Cloud Pub/Sub.

• topics: указывает, что мы выполняем операцию связанную с темами.

• publish: это действие, которое указывает на публикацию сообщения в тему.

• sandiego: это имя темы, в которую мы отправляем сообщение.

• --message "hello": это флаг, который определяет текстовое сообщение, которое мы отправляем в тему. В данном случае, сообщение "hello".

Таким образом, команда отправляет сообщение "hello" в тему "sandiego" в Google Cloud Pub/Sub.

Создайте подписку на тему:

CODE...

• gcloud: инструмент командной строки Google Cloud SDK.

• pubsub: подкоманда, связанн

• subscriptions: указывает, что мы выполняем операцию связанную с подписками.

• create: это действие, которое указывает на создание новой подписки.

• --topic sandiego: флаг, который указывает на тему, для которой создается подписка. В данном случае, тема "sandiego".

• mySub1: это имя новой подписки. В данном случае, подписка будет названа "mySub1".

Таким образом, команда создает новую подписку с именем "mySub1" для темы "sandiego" в Google Cloud Pub/Sub. Эта подписка "mySub1" может быть использована для получения сообщений, опубликованных в теме "sandiego".

Извлеките первое сообщение, опубликованное в вашей теме:

CODE...

• gcloud: инструмент командной строки Google Cloud S

• pubsub: подкоманда, связанная с Google Cloud Pub/Sub.

• subscriptions: указывает, что мы выполняем операцию связанную с подписками.

• pull: это действие, которое указывает на запрос (пул) сообщений из подписки.

• --auto-ack: флаг, который указывает, что сообщения должны автоматически подтверждаться после их успешного получения. В этом случае, сообщения будут автоматически подтверждены (acknowledged), что означает, что они будут удалены из очереди и больше не будут отправлены этой подписке.

• mySub1: это имя подписки, из которой мы запрашиваем сообщения. В данном случае, подписка "mySub1".

Таким образом, команда выполняет операцию получения сообщений из подписки "mySub1" в Pub/Sub, и эти сообщения будут автоматически подтверждены после успешного получения.

Попробуйте опубликовать еще одно сообщение, а затем вытащить его с помощью подписки:

CODE...

Эта команда отпр

Эта команда пытается получить (пуллить) сообщения из подписки (subscription) "mySub1". Если в "mySub1" есть доступные сообщения из темы "sandiego", то одно из них будет получено. Флаг --auto-ack указывает на автоматическое подтверждение полученных сообщений.

В SSH-терминале Training-VM отмените подписку:

CODE...

• gcloud: инструмент командной строки Google Cloud SDK.

• pubsub: подко

• subscriptions: указывает, что мы выполняем операцию связанную с подписками.

• delete: это действие, которое указывает на удаление подписки.

• mySub1: это имя подписки, которую мы удаляем. В данном случае, подписка "mySub1".

Таким образом, команда удалит подписку "mySub1" из Google Cloud Pub/Sub. Пожалуйста, убедитесь, что вы хотите удалить подписку, поскольку удаленная подписка не может быть восстановлена, и все сообщения, связанные с ней, будут потеряны.

Изучите скрипт Python для моделирования данных датчиков дорожного движения в Сан-Диего. Не вносите никаких изм/p>

CODE...

Посмотрите на функцию моделирования. Это позволяет сценарию вести себя так, как если бы датчики трафика отправляли данные в режиме реального времени в Pub/Sub. Параметр SpeedFactor определяет, насколько быстро будет проходить симуляция. Выйдите из файла, нажав Ctrl+X .

Загрузите набор данных моделирования дорожного движения:

CODE...

Имитировать потоковые данные датчика

Запустите send_sensor_data.py :

CODE...

Эта команда имитирует данные датчика,