У меня есть две коллекции PCollections: одна извлекает информацию из Pub / Sub, а другая извлекает данные из файла CSV. После нескольких различных преобразований в каждом конвейере я хотел бы объединить эти два на общем ключе, который они оба имеют,...

Я создаю пользовательское задание Dataflow на Python для загрузки данных из PubSub в BigQuery. В таблице много вложенных полей. Где я могу установить Coder в этом конвейере? avail_schema = parse_table_schema_from_json(bg_out_schema) coder =...