Apache Beam не может получить доступ к fileio - PullRequest
Новая
       22

Apache Beam не может получить доступ к fileio

0 голосов
/ 14 февраля 2020

Я пытаюсь получить доступ к классу WriteToFiles в fileio, и хотя файл существует в моей версии 2.19, я не могу его загрузить: 

AttributeError: module 'apache_beam.io' has no attribute 'fileio'

Должно быть что-то маленькое, что я ' м отсутствует. Я пытаюсь выполнить: 

my_pcollection | beam.io.fileio.WriteToFiles(
  path='/my/file/path',
  destination=lambda record: 'avro' if record['type'] == 'A' else 'csv',
  sink=lambda dest: AvroSink() if dest == 'avro' else CsvSink(),
  file_naming=beam.io.fileio.destination_prefix_naming())

Вот документация: https://beam.apache.org/releases/pydoc/2.19.0/apache_beam.io.fileio.html#dynamic -destination

Когда я добавляю WriteToFiles в переменную __all__, я могу по крайней мере импортировать его правильно, но тогда все остальные операции импорта завершатся неудачно.

Как я могу выполнить WriteToFiles без настройки исходного кода?

...