gcloud の Pub/Sub を python3 で行う
参考にしたページ
Publishing Messages
Subscribing to Messages
プログラムを実行するには、
認証の JSON ファイルが必要です。
この 例では、my-project-sep-10-2017.json としました。
この JSON (サービス アカウント キー) は、google console で作成してダウンロードします。
トピックの作成
create_topic.py
#! /usr/bin/python
# -*- coding: utf-8 -*-
#
# create_topic.py
#
# Feb/08/2018
# ------------------------------------------------------------------
import sys
from google.cloud import pubsub
# ------------------------------------------------------------------
sys.stderr.write("*** 開始 ***\n")
#
publisher = pubsub.PublisherClient()
project_id = 'my-project-sep-10-2017'
topic_name = 'topic_1'
topic_path = publisher.topic_path(project_id,topic_name)
try:
topic = publisher.create_topic(topic_path)
print('Topic created: {}'.format(topic))
except Exception as ee:
sys.stderr.write("*** error *** in publisher.create_topic ***\n")
sys.stderr.write(str(ee) + "\n")
sys.stderr.write("*** 終了 ***\n")
# ------------------------------------------------------------------
実行スクリプト
export GOOGLE_APPLICATION_CREDENTIALS="./my-project-sep-10-2017.json"
./create_topic.py
サブスクリプションの作成
create_subscribe.py
#! /usr/bin/python
# -*- coding: utf-8 -*-
#
# create_subscribe.py
#
# Feb/08/2018
# ------------------------------------------------------------------
import sys
from google.cloud import pubsub
# ------------------------------------------------------------------
sys.stderr.write("*** 開始 ***\n")
#
subscriber = pubsub.SubscriberClient()
topic_name = 'projects/my-project-sep-10-2017/topics/topic_1'
sub_name = 'projects/my-project-sep-10-2017/subscriptions/subscription_1'
try:
subscriber.create_subscription(sub_name, topic_name)
except Exception as ee:
sys.stderr.write("*** error *** in subscriber.create_subscription ***\n")
sys.stderr.write(str(ee) + "\n")
#
sys.stderr.write("*** 終了 ***\n")
# ------------------------------------------------------------------
実行スクリプト
export GOOGLE_APPLICATION_CREDENTIALS="./my-project-sep-10-2017.json"
./create_subscribe.py
パブリッシュ
iot_publish.py
#! /usr/bin/python
# -*- coding: utf-8 -*-
#
# iot_publish.py
#
# Feb/08/2018
# ------------------------------------------------------------------
import sys
import datetime
from google.cloud import pubsub
# ------------------------------------------------------------------
sys.stderr.write("*** 開始 ***\n")
#
publisher = pubsub.PublisherClient()
project_id = 'my-project-sep-10-2017'
topic_name = 'topic_1'
topic_path = publisher.topic_path(project_id,topic_name)
dd = datetime.datetime.today()
message = 'This is my message. ' + dd.strftime("%Y-%m-%d %H:%M:%S")
sys.stderr.write(message + "\n")
message_bb = message.encode()
publish_client = pubsub.PublisherClient()
publish_client.publish(topic_path, message_bb)
sys.stderr.write("*** 終了 ***\n")
# ------------------------------------------------------------------
実行スクリプト
export GOOGLE_APPLICATION_CREDENTIALS="./my-project-sep-10-2017.json"
./iot_publish.py
サブスクライブ
iot_subscribe.py
#! /usr/bin/python
# -*- coding: utf-8 -*-
#
# iot_subscribe.py
#
# Feb/08/2018
# ------------------------------------------------------------------
import sys
from google.cloud import pubsub
# ------------------------------------------------------------------
def callback(message):
print(message) # Replace this with your actual logic.
message.ack()
#
# ------------------------------------------------------------------
sys.stderr.write("*** 開始 ***\n")
#
subscriber = pubsub.SubscriberClient()
sub_name = 'projects/my-project-sep-10-2017/subscriptions/subscription_1'
subscription = subscriber.subscribe(sub_name)
future = subscription.open(callback)
try:
try:
future.result()
except Exception as ex:
subscription.close()
sys.stderr.write(str(ex) + "\n")
except KeyboardInterrupt:
sys.stderr.write('*** interrupted! ***\n')
#
sys.stderr.write("*** 終了 ***\n")
# ------------------------------------------------------------------
実行スクリプト
export GOOGLE_APPLICATION_CREDENTIALS="./my-project-sep-10-2017.json"
./iot_subscribe.py
Author And Source
この問題について(gcloud の Pub/Sub を python3 で行う), 我々は、より多くの情報をここで見つけました https://qiita.com/ekzemplaro/items/09270045ff485c7e13f8著者帰属:元の著者の情報は、元のURLに含まれています。著作権は原作者に属する。
Content is automatically searched and collected through network algorithms . If there is a violation . Please contact us . We will adjust (correct author information ,or delete content ) as soon as possible .