问题标签 [bolt]

我正在将 Neo4j 集成到我的 angular 和 nodejs 应用程序中。我必须使用螺栓 url 访问 Neo4j 数据库，因为 http 在我的情况下不起作用。

因为我在控制台中遇到错误 -

和

角代码 -

app.component.ts

所以我试图找到每个节点至少与另一个节点有一个公共节点。这是我用来执行此操作的请求：

但遗憾[source.unique_url, target.unique_url]的是总是重复的，比如一个节点与另一个节点有一个共同的邻居，我总是得到这样的结果：

我检查了数据库中的数据没有重复，所以请求正在复制它们，有人知道可能是什么原因造成的吗？非常感谢 ！

我在以前没有任何问题的机器上连接到 neo4j 时遇到问题。

我已经从机器上清除了以前的安装并执行了新的安装 - 尽管我注意到一旦激活它似乎有我以前的活动记录。

现在，当连接到桌面控制台时，一方面我收到相互冲突的消息， :server connect 返回

另一方面，我尝试输入的任何 Cypher 代码都会返回：

怎么可能两者兼而有之？

Neo4J 服务器配置允许设置服务器端策略来保护 HTTPS 和 BOLT 连接。

在我的安装中，我通过使用 PEM 公钥和私钥以及设置设置策略来保护 BOLT 连接：

该设置适用于浏览器客户端。当我通过 HTTPS 连接到服务器时，我可以使用 ":server connect" 命令登录并在我的服务器上使用 Neo4J 浏览器。

我不能做的是弄清楚其他客户端如何使用安全的 BOLT 协议连接到 Neo4J。具体来说，我尝试从 cypher-shell 和 Java 客户端进行连接（使用 Java Driver v 1.6）。当 TLS for BOLT 被禁用时，两者都可以顺利连接。启用 TLS 会导致两个客户端出现 bad_certificate 错误。

我尝试通过传递指向我的信任库和密钥库的 JVM 属性来启动 cypher-shell 和我的 Java 客户端

这些属性对任何一个 Neo4J 客户端都没有影响。我收到一个 bad_certificate 异常。

我尝试启用 SSL 调试 (-Djavax.net.debug=ssl,handshake)。使用 keystore 和 truststore 参数调用 Java 客户端或 cypher-shell 对 SSL 调试输出没有影响。

如何从 cypher-shell 或 Java 客户端启用 TLS for BOLT 连接到服务器？

谢谢你。

We have an application that moves csv files from HDFS to Hive. We are using Storm Topology for that process.

8 machines have been using. Each of them has 22 cores and 512 GB RAM. However, our code runs really slow. It takes 10 minutes to finish to transfer 6 million data.

10 MB of 60 files are transferring to HDFS in one second. We are trying to optimize our code, but it is obvious that we are doing something very wrong.

For Hive table, we have 64 buckets.

In our topology, we have 1 Spout and 2 Bolts. Basically our Spout gets the CSV file, emits lines to first Bolt which is responsible for parsing the data then the Bolt emits to second Bolt which is responsible for HDFS process.

HDFS Spout;

Mapper;

Hive Options;

Config;

Topology Builder;

We are not sure with the following Parameters;

in HDFS Spout; .setMaxOutstanding(50_000);

in Hive Spout Options; .withTxnsPerBatch(2) .withBatchSize(50_000) .withTickTupleInterval(1);

in Config; .setNumWorkers(6); .setNumAckers(6);

Parallelism in Spout and Bolt; We gave 8 for each.

What should be the values for those parameters? Thanks in advance.

Edit; Here is our test result for 10 mb of 100 csv files;

hdfsSpout Executors: 8 Complete Latency: 1834.209 ms

recordParserBolt Executors: 8 Complete Latency: 0.019 ms

hiveBolt Executors: 8 Complete Latency: 1092.624 ms

所以过去几天我一直在研究 Sphero 的 Python SDK。其中我发现的是Kulkaand SpheroPy，虽然我发现了另一个 5 岁并且从那时起就没有更新过。

Kulka或实现都SpheroPy不会连接到我的Sphero Bolt。它已成功与我的 Windows 10 PC 配对，并且具有唯一标识符“ c8:31:f5:7e:f4:30”。每次我告诉这些 APIS 中的任何一个连接到 时sphero，他们都会抛出一个traceback并告诉我他们无法连接，因为连接的一方没有响应。我已成功连接Sphero Bolt到Sphero Edu手机上的应用程序。

但是，我是盲人，并且该应用程序对屏幕阅读器不友好，因此我首选的控制方法是通过外部 API。尽管如此，它连接到Sphero Edu应用程序的事实+它与我的电脑配对的事实表明它的蓝牙功能是正常的。我环顾四周，也许是因为没有真正对其进行研究，没有人为此提供可行的解决方案，我自己也很困惑。

我正在尝试验证将接收 URL 的字段。我需要使用适当的正则表达式对其进行验证，但是我从 Firebase 文档本身获得的内容不起作用。编译器bolt既不编译，导致错误：

我是 apachestorm 的新手，我编写了包含 1 个 spout 和 2 个 bolt 的代码，当我在一个 worker 上运行这 3 个部分时，代码会正确生成输出，但是当我在 1 个 worker 执行的三个 worker 中运行代码时spout，另一个运行螺栓 1 和最后一个运行螺栓 2，将不会生成输出。具体情况：当我将螺栓1和2放在一个工人中时，产生了输出！

不得不说，发射成功了，发射变量没有问题。

详细说明：我在螺栓 1 的哈希图结构中创建了树，我想在螺栓 2 中挖掘这棵树。在螺栓 1 中插入树中的对象的 id 就像“MyTreeNode@e70014d5”，当我收到这个元组时（哈希图) 在螺栓 2 中，id 更改为类似“MyTreeNode@z5542r12”的内容。

主要问题是什么？

问题是因为更改了对象ID吗？如果是，请告诉我如何解决？

请告诉我如何正确地使用光子螺栓进行迁移。如果可能，请提供文档或分步说明

我需要验证“类别”属性的值是否等于类别节点上存在的键

我试过这个：

这产生了这个：

但我想要这个（我在没有使用螺栓的情况下进行了测试并且它有效）：

我如何得到预期的结果，但使用螺栓？