Apache Beam Error AsList对象不是iterab

Question

在 我试图用python从apachebeam中的pcollection进行一个侧面输入。

这是我的代码：

from apache_beam.pvalue import AsList

locations_dim = p | beam.io.Read(beam.io.BigQuerySource(
query='SELECT a, b, c, d FROM test.testing_table')) | 
beam.Map(format_apply)

AsList(locations_dim) | WriteToText(known_args.output)

（我应用writeToText以便调试） 但它引发了以下错误：

^{pr2}$

有什么帮助吗？