2016-06-18 43 views

回答

0

对于我创建DOFN与Redis的客户Redis的。 如果你需要批量书写,可以做一些技巧。例如: link

+0

谢谢,我现在也切换到redis。我不是批量写作,但这个链接很有见地。 –

1

是的,Dataflow工作人员可以与您需要的任何外部服务进行通信;他们只是没有特别限制或权限的虚拟机。

如果你只是写出数据到内存缓存,该Sink API将可能是有用的

+0

谢谢,但你可以更具体。你能给我一个示例接收器调用,也显示我如何验证? –

+0

如果你可以进一步了解你的用例,我可以举一个如何使用Sink API来实现它的例子。 关于身份验证,为了与任何Google提供的服务进行通信,您可以使用options.getGcpCredential() – danielm

+0

中的凭据从数据流自定义接收器页面,它表示您只能写入有界数据,但我需要从数据流管道“。您可以使用可扩展API创建自定义源,以读取有界(批量)或无界(流)数据,并创建只写入有界数据的接收器。” –