3

我有一个从 noflo运行的简单 noflo 示例。但是我没有弄清楚 noflo 应该如何与节点和其他代码一起工作。

起初我有这个 fbp 文件：

# In the graph we first need to define the nodes and the connections between them
Read(filesystem/ReadFile) OUT -> IN Display(core/Output)

# Start off the graph by sending a filename to the file reader
#'package.json' -> IN Read

我试过：noflo.loadFile(filepath, nodedir, function(graph)

这有效并打印到控制台。但是，如果我省略了 fbp 中提供package.json参数的最后一行，我发现无法运行图表。

是否有关于如何从 nodejs 代码而不是命令行使用 noflo 的指南？

4

1 回答 1

5

通常 NoFlo 组件在接收到一些输入之前不做任何事情，在这种情况下是要读取的文件路径。来自NoFlo 组件文档：

NoFlo 网络中组件的运行实例称为进程。在进程接收到数据之前，它应该是惰性的，只监听它的输入端口。当网络启动时需要开始做某事的进程应该通过向它们发送一个初始信息包来触发它们。

.fbp 图形定义中的最后一行是将字符串发送package.json到 ReadFile 组件。

您也可以在将文件加载到 NoFlo 网络后以编程方式执行此操作：

noflo.loadFile(filepath, process.cwd(), function (network) {
  // Now we have access to the NoFlo network instance

  // Add Initial Information Packet programatically
  network.graph.addInitial(someFileToRead, 'Read', 'in');

  // Tell NoFlo to send the new IIPs
  network.sendInitials();
});

导出的端口和子图

现在，还有一种更优雅的方法可以做到这一点，通过.fbp在 NoFlo 的 ComponentLoader 中将文件显示为图形，然后在与任何其他组件交互时与之交互。

要使您感兴趣的端口从外部可用，您需要将它们导出。在这种情况下，至少是图中的 ReadFile IN 端口。这会将您的网络定义更改为：

# Export the filename port so it can be accessed from outside
INPORT=Read.IN:FILENAME

# The rest of the graph definition follows
Read(filesystem/ReadFile) OUT -> IN Display(core/Output)

（碰巧，这正是我在.fbp 语言定义中的导出端口上使用的示例）

要使您的图表可用作组件，您需要将其保存到您的 Node.js 项目中（约定是graphs/子目录）并将其注册到package.json文件中：

{
  "noflo": {
    "graphs": {
      "MyGraph": "graphs/MyGraph.fbp"
    }
  }
}

现在您可以将其视为任何其他组件。例如：

var loader = new noflo.ComponentLoader(__dirname);
loader.load('MyGraph', function (instance) {
  // The instance is a running NoFlo subgraph with your graph definition

  // Create a socket and attach it to the exported port
  var filename = noflo.internalSocket.createSocket();
  instance.inPorts.filename.attach(filename);

  filename.send(someFileToRead);
  filename.disconnect();
});

这是首选方法的一个原因是，您不仅可以使用它来发送 IIP，还可以将套接字附加到导出的输出端口并在其上侦听事件。通过这种方式，您可以轻松地将任何 NoFlo 图用作 JavaScript 应用程序中的异步函数。

于 2014-06-10T14:00:18.217 回答