Я пытаюсь использовать запись в pubsbub после чтения из csv и записи нескольких преобразований, однако, как только я дошел до того, что мне нужно начать работать с pubsub, я не могу импортировать.вот что я импортирую:
from __future__ import absolute_import
import apache_beam as beam
from datetime import datetime
from beam_utils.sources import CsvFileSource
from apache_beam.io import ReadFromText
from apache_beam.io import WriteToText
from apache_beam.io.gcp.pubsub import PubsubMessage
from apache_beam.io.gcp.pubsub import ReadFromPubSub
from apache_beam.io.gcp.pubsub import ReadStringsFromPubSub
from apache_beam.io.gcp.pubsub import WriteStringsToPubSub
from apache_beam.io.gcp.pubsub import WriteToPubSub
#from apache_beam.io.gcp.pubsub import WriteToPubSub
from apache_beam.io.gcp.pubsub import _PubSubSource
from apache_beam.metrics import Metrics
from apache_beam.options.pipeline_options import PipelineOptions
from apache_beam.options.pipeline_options import SetupOptions
from apache_beam.options.pipeline_options import GoogleCloudOptions
from apache_beam.options.pipeline_options import StandardOptions
До сих пор я полагал, что только WriteToPubSub и WriteToPubSub не работают.
Ошибка выглядит следующим образом:
from apache_beam.io.gcp.pubsub import WriteToPubSub
ImportError: cannot import name WriteToPubSub
я вижу, что модуль установлен:
py -2 -m pip show google-cloud-pubsub
Name: google-cloud-pubsub
Version: 0.26.0
Summary: Python Client for Google Cloud Pub/Sub
Home-page: https://github.com/GoogleCloudPlatform/google-cloud-python
Author: Google Cloud Platform
Author-email: jjg+google-cloud-python@google.com
License: Apache 2.0
Location: d:\python27\lib\site-packages
Requires: gapic-google-cloud-pubsub-v1, google-cloud-core, grpcio
Required-by:
обновил модуль:
Installing collected packages: google-cloud-pubsub
Found existing installation: google-cloud-pubsub 0.26.0
Uninstalling google-cloud-pubsub-0.26.0:
Successfully uninstalled google-cloud-pubsub-0.26.0
Successfully installed google-cloud-pubsub-0.37.2
все та же проблема
Очень хотелось бы понять, что я делаюне так с этим?Неправильная версия?