问题标签 [highland.js]

我从 node.js 中获得了巨大的价值，并且喜欢流处理模型。我主要将它用于具有数据丰富和 ETL 之类的作业的流处理。

为了充实，我可能有这样的记录......

我想通过添加产品详细信息来丰富这一点

描述数据和价格数据都来自不同的流。在高地处理这种依赖关系的最佳方法是什么？

有什么想法吗？

在受到 NoFlo.js 的启发后，我正在学习 highland.js。我希望能够让流递归操作。在这个人为的示例中，我将提供一个乘以 2 的数字，我们过滤结果 <= 512。一旦将数字相乘，它就会反馈到系统中。我的代码有效，但如果我在管道中取出 doto 函数，它不会处理任何数字。我怀疑我将数据错误地发送回 returnPipe。有没有更好的方法将数据传输回系统？我错过了什么？

我想获取一个 url 数组并将其映射到每个 url 的 pageranks 数组。

我想用流来尝试它，但我不确定我是否理解我在做什么。

我已经尝试了几件事，这是我登陆的地方（不工作）：

应用程序.js

包.json

输出似乎是一个流数组，从 toArray() 和 google 的页面排名 9 出来似乎很奇怪。我不知道如何包装 getPageRank 以便它等待在回调中返回值。

我希望能够将调用限制为getPagerank()每秒一个。我尝试了各种方法，但无法正常工作。

我有以下示例

据我在文档（http://highlandjs.org/#destroy）中可以阅读，销毁流应该清理损坏的管道。相反，我收到以下错误：

有没有人了解为什么会发生这种情况，以及销毁流的正确方法是什么？

我正在尝试使用高地流来传回两个对象：另一个数据流和一个元数据对象。我创建流：

后来我使用这个：

问题是apply之前调用的函数hstream已经结束，看不到“元”对象。如何重新配置​​它，以便在 hstream 包含两个对象之前不调用 apply ？

我正在尝试将highland与heroku-client结合使用。但是在它使用的heroku客户端内部this，即使我尝试bind绑定它，该函数也会给出错误消息，因为this我无法让它工作。

不对，代码看起来像这样

因此，此代码段失败并显示以下错误消息：

由于在 SO 上要避免主观答案，我特地问：这三个功能/反应性库之间的功能和/或性能差异是什么，这将使我选择其中一个而不是其他库？我已经淘汰了 BaconJS，因为它依赖于 jQuery。我是 JS 流的新手，主要是想先在 NodeJS 中熟悉它们，然后再在 AngularJS 上下文中熟悉它们。如果您选择了其中之一而不是其他人，那么什么标准会导致选择？

我必须从输入文件中抽取行，转换它们并将它们放入输出文件中。

由于输入文件很大，我通过 HighlandJS 流式传输它。

转换步骤包括 MySQL DB 中的异步查询（通过 node-mysql），我不知道如何在流中管理异步查询。我的不同尝试给出了错误或没有。

我的最后一次尝试是：

关于如何做到这一点的任何提示？

谢谢。

我需要创建一个重复某些值的流。有了培根，我可以用重复原语做到这一点