读取图像作为Apache Beam管道的输入

Question

我想使用Apache Beam来制作机器学习管道，该管道从本地文件夹读取图像，然后对其进行预处理。我找到了一些如何将.txt或.csv文件作为管道输入的示例。喜欢：

lines = p | 'read' >> ReadFromText(known_args.input)

但是图像数据呢？假设我想读取图像，进行预处理，进行预测，然后将所需的输出写入本地文件夹。怎么做？

Answer 1

Beam没有自己的内置支持来处理图像。但是，它的确可以让您从用户定义的ParDo转换中调用任何Python图像处理库。