Я столкнулся с ошибкой при локальном тестировании потока данных на моем компьютере.Я намеревался использовать потоковый сервис из Dataflow и получил «NotImplementedError».Детали ошибки таковы: 
Я думал, что это может быть вызвано некоторыми версиями пакета.Ниже приведен список зависимостей в файле setup.py.
'google-api-core==1.4.1',
'google-auth==1.5.1',
'google-cloud-core==0.28.1',
'google-cloud-storage==1.10.0',
'google-resumable-media==0.3.1',
'googleapis-common-protos==1.5.3',
'librosa==0.6.2',
'wave==0.0.2',
'scipy==1.1.0',
'google-api-python-client==1.7.4',
'oauth2client==4.1.2',
'resampy==0.2.1',
'keen==0.5.1',
'google-cloud-bigquery==1.5.0',
'apache-beam[gcp]==2.5.0',
'google-cloud-dataflow==2.5.0',
'six==1.10.0',
'google-cloud-logging==1.7.0'
Может ли кто-нибудь помочь мне решить эту проблему?