阿帕奇梁在Python，誤差beam.io.TextFileSource

Question

我試圖運行GCP回購在數據科學的代碼，並不斷撞擊在梁代碼中的錯誤。

這是給出了一個錯誤行： beam.Read（beam.io.TextFileSource（ 'airports.csv.gz'）

這裏是我得到的錯誤： AttributeError的： '模塊'對象有沒有屬性「TextFileSource」

下面是完整的文件： https://github.com/GoogleCloudPlatform/data-science-on-gcp/blob/master/04_streaming/simulate/df01.py

有誰知道如何得到這個工作，或者說我缺少的是什麼

Answer 1

看來您使用的是舊版本的apache-beam/cloud-dataflow。

務必：

pip freeze | grep dataflow

當我這樣做，我得到：

google-cloud-dataflow==0.4.3

如果你的版本，你得到的是舊的，請嘗試：

pip install google-cloud-dataflow

a nd重複pip凍結命令。如果你一直得到的是舊版本，那麼你在Python庫地獄，我建議使用的virtualenv，以確保您使用的是最新版本的所有包...

Answer 2

谷歌的數據流被遷移到Apache光束標準，這意味着你應該使用apache_beam.io.textio.ReadFromText。該標準仍在不斷髮展，所以無論何時升級包裝，最好諮詢Release Notes。