質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

ただいまの
回答率

88.78%

Google Cloud Pub/Sub で Acknowledge レスポンスが出来ない

解決済

回答 1

投稿

  • 評価
  • クリップ 0
  • VIEW 494

ikki

score 17

前提・実現したいこと

前提
Google Cloud Pub/Sub でGmailのプッシュ通知を受け取り、Functions でメール返信をするBOTを作ろうとしています。今のところ動作自体は期待通り動いています。

問題点
プッシュ通知自体は受け取り出来ているのですがレスポンスを返していない為、未読状態のサブスクリプションが大量に溜まっている状態と思われます(以下参照)。ack_idがどこにあるかわからず、レスポンスを返せてません。
現在は受信待機を最大(600sec)にして、保持期限を最小(10min)にして強引に捨てています。
実際通信少ないので今のところ実害は無いのですが、ちゃんとしたいです。

参考にしたページ
GmailAPI公式ガイド
Cloud Pub/Sub ドキュメント
github Google Cloud Client Libraries for Python

環境・現況

Pub/Sub
サブスクリプション
・配信タイプ    - pull
・エンドポイント  - Functions

Funtions
・リージョン    - us-central1
割り当てられるメモリ - 512 MB
タイムアウト     - 60 秒
トリガー       - cloud Pub/Sub トピック同上

上記ファンクションのデプロイ以外はブラウザのコンソールで設定しました

発生している問題・試したこと

import os
from google.cloud.pubsub_v1 import SubscriberClient

os.environ["GOOGLE_APPLICATION_CREDENTIALS"]='pubsub_client_sennyou.json'

PROJECT_ID = '*****'
TOPIC_NAME = '*****'
SUBSCRIPTION_NAME = '*****'

sub_name = 'projects/{project_id}/subscriptions/{sub}'.format(
    project_id=PROJECT_ID,sub=SUBSCRIPTION_NAME)

def callback(message):
    print(message.data)
    message.ack()

subscriber = SubscriberClient()
future = subscriber.subscribe(sub_name,callback)
try:
    print(future.result())
except KeyboardInterrupt:
    future.cancel()


上記コードを実行すると、延々と下の結果を吐き続け忘れたころに固まります。。。。
(別件なのですが、histryIdの選別も希望とちょっと違う。。)

b'{"emailAddress":"*****@gmail.com","historyId":8861}'
b'{"emailAddress":"*****@gmail.com","historyId":8904}'
b'{"emailAddress":"*****@gmail.com","historyId":8974}'
b'{"emailAddress":"*****@gmail.com","historyId":8720}'
以下、延々と続く。。。

いろいろやってみましたが、どうしても解決できませんでした。
お詳しい方、なにとぞよろしくお願い致します。

  • 気になる質問をクリップする

    クリップした質問は、後からいつでもマイページで確認できます。

    またクリップした質問に回答があった際、通知やメールを受け取ることができます。

    クリップを取り消します

  • 良い質問の評価を上げる

    以下のような質問は評価を上げましょう

    • 質問内容が明確
    • 自分も答えを知りたい
    • 質問者以外のユーザにも役立つ

    評価が高い質問は、TOPページの「注目」タブのフィードに表示されやすくなります。

    質問の評価を上げたことを取り消します

  • 評価を下げられる数の上限に達しました

    評価を下げることができません

    • 1日5回まで評価を下げられます
    • 1日に1ユーザに対して2回まで評価を下げられます

    質問の評価を下げる

    teratailでは下記のような質問を「具体的に困っていることがない質問」、「サイトポリシーに違反する質問」と定義し、推奨していません。

    • プログラミングに関係のない質問
    • やってほしいことだけを記載した丸投げの質問
    • 問題・課題が含まれていない質問
    • 意図的に内容が抹消された質問
    • 過去に投稿した質問と同じ内容の質問
    • 広告と受け取られるような投稿

    評価が下がると、TOPページの「アクティブ」「注目」タブのフィードに表示されにくくなります。

    質問の評価を下げたことを取り消します

    この機能は開放されていません

    評価を下げる条件を満たしてません

    評価を下げる理由を選択してください

    詳細な説明はこちら

    上記に当てはまらず、質問内容が明確になっていない質問には「情報の追加・修正依頼」機能からコメントをしてください。

    質問の評価を下げる機能の利用条件

    この機能を利用するためには、以下の事項を行う必要があります。

回答 1

check解決した方法

0

自決しました 

環境の欄に下記のように書いていたのですが、よく調べるとpushで配信されていました。
GmailのAPIガイドにpull見て?みたいに書いてあったので完璧に勘違いしてました。
なので、Functions内のmain.py 実行関数で200を返してあげることで解決した気がします。

なにぶん素人なので、解決方法が違う、改善点がある等ご指摘有りましたら是非ご指導いただけるとありがたいです。
ご覧くださった方々、ありがとうございました。

問題個所

Pub/Sub
サブスクリプション
・配信タイプ    - pull  → pushでした
・エンドポイント  - Functions

解決法

main.py

def run_mailing(event, context):
    recieve = mail_check().EXE_check(content)
    for res in recieve:
        sendGmail().EXE_Gmail(res)

    return 'OK', 200

モロタ

投稿

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

15分調べてもわからないことは、teratailで質問しよう!

  • ただいまの回答率 88.78%
  • 質問をまとめることで、思考を整理して素早く解決
  • テンプレート機能で、簡単に質問をまとめられる

関連した質問

同じタグがついた質問を見る