2
respostas

exemplo da atividade 2 não funcionou para mim

ativei um virtual env com python 3.9 e depois com 3.8, instalei o apache beam e executei o proposto do main, mas parece que não conseguiu ler o arquivo, pois não printou o resultado da linha.

import apache_beam as beam
from apache_beam.io import ReadFromText
from apache_beam.options.pipeline_options import PipelineOptions

pipeline_options = PipelineOptions(argv=None)
pipeline = beam.Pipeline(options=pipeline_options)

dengue = (
    pipeline
    | "Leitura do dataset de dengue" >> ReadFromText('casos_dengue.txt', skip_header_lines=1)
    | "Mostrar resultados" >> beam.Map(print)
)
print(dengue)

podem me ajudar?

2 respostas

Olá, como vai?

O print(dengue) não deve mostrar realmente os dados que foram lidos. Porém, no seu caso faltou ao final o comando pipeline.run().

O comando vai rodar a pipeline e imprimir os valores no terminal.

Espero que ajude!

Até logo e bom curso!

Muito Obrigado. tinha mesmo esquecido do método run.