我正在嘗試將我的管道響應寫入Google存儲，但獲取已安裝在服務器上的模塊導入錯誤。 代碼： from __future__ import print_function, absolute_import
import apache_beam as beam
from apache_beam.io import ReadFromText
from apache_beam.io import W
我在存儲CSV文件，我想讀它，並將其寫入BigQuery資料表。這是我的CSV文件，其中第一行是標題： GroupName,Groupcode,GroupOwner,GroupCategoryID
System Administrators,sysadmin,13456,100
Independence High Teachers,HS Teachers,,101
John Glenn Mi
我試圖修改Apache Beam的MinimalWordCount python示例以從BigQuery表中讀取。我做了以下修改，我似乎有查詢工作，但例如。 原來的例子在這裏： with beam.Pipeline(options=pipeline_options) as p:
# Read the text file[pattern] into a PCollection.