我正在Bonobo中使用非常简单的ETL管道,但是我需要计算列。
我需要等到所有项目都加载到数据库中,然后计算一些列(UPDATE table set column1=...
)
我正在阅读文档,但Bonobo似乎很适合逐行处理,但不适用于大规模更新。
Bo黑猩猩有什么办法做到这一点,还是我应该考虑其他方式?
我也可以考虑逐行计算场,但我认为它会比较慢。 反对的另一点是,UPDATE必须是数据库存储的函数,而不是Python。
谢谢。
我正在Bonobo中使用非常简单的ETL管道,但是我需要计算列。
我需要等到所有项目都加载到数据库中,然后计算一些列(UPDATE table set column1=...
)
我正在阅读文档,但Bonobo似乎很适合逐行处理,但不适用于大规模更新。
Bo黑猩猩有什么办法做到这一点,还是我应该考虑其他方式?
我也可以考虑逐行计算场,但我认为它会比较慢。 反对的另一点是,UPDATE必须是数据库存储的函数,而不是Python。
谢谢。