📬 ポエムブログの超頑丈な翻訳パイプライン
接続確認中...
Gemini AI & Cloud Pub/Sub Pipeline Dashboard
パイプラインの稼働状況
稼働中
一時停止
💡
検証モード解説:
開発環境(ローカルエミュレータ)では、本物のAPIを叩かず「モック翻訳」で動作します。左のボタンで
一時停止
させると、メッセージを翻訳せずキューにわざと滞留させて、非同期の復旧テスト(耐障害性検証)を行えます。本番環境(Cloud Run)では、Vertex AI API を通じて本物の Gemini 3.5 Flash による翻訳が実行されます。
Step 0
トリガー:翻訳元のメッセージを生成する (Publisher / 差出人 📨)
[A] テンプレートから選択して生成
ランダムな英文を生成する
[B] 自分で言葉を自由に入力して送信
直接送信
Step 1 (UI)
コメント送信者 (プロデューサー処理)
Publisher (差出人) 📨
※ブログにコメントが投稿され、メッセージ送信(パブリッシュ)が行われる状態です。
ここに生成されたカードが表示されます。
クリックするとキューへ送信されます。
Step 2 (Queue)
Cloud Pub/Sub 物理キュー (滞留中)
Topic & Sub (ポストと配達) 📮
0 件
※手動送信やカウントダウン終了したメッセージが並列で到達します。
現在キューに滞留しているメッセージはありません。
Step 3 (Worker)
翻訳ワーカー (コンシューマー処理中)
Subscriber (受取人) 👤
※Pub/Subからメッセージを引き抜き、Gemini AIで翻訳している状態です。
現在処理中のメッセージはありません。
💡
ローカル検証時の注意点(キューにカードが溜まらない理由):
開発環境では翻訳処理が
モック(瞬時)
で終わることと、ワーカーがキューを
リアルタイム検知
して即座に引き抜くため、通常時はメッセージが一瞬で通り過ぎてしまいます。Pub/Subの物理キューにメッセージが滞留する様子を視覚的に観察したい場合は、最上部の
一時停止
ボタンを押してからメッセージを送信してください。
処理済みメッセージ数
0 件
サブスクリプション購読キュー
-
追加の処理遅延【スロットリング】
3秒
Step 4
翻訳履歴 (処理完了ログ)
処理されたメッセージはまだありません。上のシミュレーターでメッセージを生成してみてください。