如何在java中使用mocks测试doFn？

Question

是否可以将模拟与 doFn 一起使用？我在 doFn 中有一个从 gcs 存储桶读取的处理方法，我想测试一下。

我尝试使用LocalStorageHelper，但它不支持存储桶获取操作。我也尝试过使用 Mockito 模拟，但似乎该行为没有通过 doFn 传递。

Answer 1

如果您使用 Beam FileSystems API 连接到 GCS（这是推荐的方法），您可以通过提供本地路径来测试包含

DoFn

的管道。您的函数应该简单地写入本地文件而不是 GCS，这将允许您测试您的逻辑。