, о котором я думаю:
1.входящий файл raw.csv> 2. pub / sub> 3. облачное хранилище> 4. функция облака (для запуска потока данных)> 5. DataFlow (преобразовать)> 5. BigQuery