IoTプラットフォームからの大量のテレメトリデータを収集し、リアルタイムでの異常検知と、長期保存による分析の両方を行いたい（ラムダアーキテクチャ）。推奨されるデータフローはどれか。

Google Cloudの組織ポリシーにおいて、タグ（Tags）を使用して条件付きでポリシーを適用したい。例えば、「開発用」タグが付いたプロジェクトのみ、特定の制約を緩和するなどは可能か。