faisceau flux de données nom python 'PipelineOptions' n'est pas défini

Question

) c'est ma première question et j'ai vraiment eu du mal à trouver des réponses. Je veux créer un pipeline très simple et déjà coincé au début. Ici vient mon code:

import apache_beam as beam 
options = PipelineOptions() 
google_cloud_options = options.view_as(GoogleCloudOptions) 
google_cloud_options.project = 'myproject' 
google_cloud_options.job_name = 'mypipe' 
google_cloud_options.staging_location = 'gs://mybucket/staging' 
google_cloud_options.temp_location = 'gs://mybucket/temp' 
options.view_as(StandardOptions).runner = 'DataflowRunner' 

produit l'erreur: NameError: nom 'PipelineOptions' est pas défini

Thx pour votre aide.

Answer 1

Vous aurez besoin d'ajouter quelques importations supplémentaires pour l'exemple au travail:

from apache_beam.io import ReadFromText 
from apache_beam.io import WriteToText 
from apache_beam.metrics import Metrics 
from apache_beam.utils.pipeline_options import PipelineOptions 
from apache_beam.utils.pipeline_options import SetupOptions 
from apache_beam.utils.pipeline_options import GoogleCloudOptions 
from apache_beam.utils.pipeline_options import StandardOptions