Объединение пучки плоской карты pvalue.asdict и pvalue.aslist ⇐ Python

[Anonymous]

У меня есть ситуация, когда я хочу иметь функцию вызова в конвейере луча с побочными входами, которые будут списками с некоторыми ключами, и все это должно решить до списка возврата. Я начал так: < /p>

Код: Выделить всё

transformed_output = (
parsed_input_data
| "Merge Data"
>> beam.FlatMap(
process_records,
beam.pvalue.AsList(auxiliary_data),
beam.pvalue.AsDict(
{
"lookup_table_1": beam.pvalue.AsList(lookup_table_data_1),
"lookup_table_2": beam.pvalue.AsList(lookup_table_data_2),
}
),
)
)

и здесь lookup_table_data является результатом предыдущего трубопровода. Я получаю такую ​​ошибку: < /p>

self._window_mapping_fn = sideInputs.default_window_mapping_fn (
pcoll.windowing.windowfn) E attrubuteerr: 'Dict' Objem возможный? Я хочу иметь в качестве ввода что -нибудь, что будет хранить как список, так и ключи, потому что мне нужно использовать этот ключ позже. Кроме того>

Подробнее здесь: https://stackoverflow.com/questions/794 ... lue-aslist