在neo4j中使用apoc.periodic.commit插入无限的json流
，可以通过以下步骤完成：
- 首先，确保已经安装了Neo4j数据库，并且已经安装了apoc插件。可以在Neo4j的官方网站上找到安装指南。
- 在Neo4j的配置文件中启用apoc插件。打开neo4j.conf文件，找到
dbms.security.procedures.unrestricted配置项，并将其值设置为apoc.*。保存并重启Neo4j数据库。 - 创建一个新的Cypher查询，使用apoc.periodic.commit函数来插入无限的json流。该函数可以在指定的时间间隔内执行一个Cypher查询。
- 例如，以下是一个示例的Cypher查询：
- 例如，以下是一个示例的Cypher查询：
- 在这个示例中，我们使用UNWIND语句将传入的jsonList参数展开为单个的json对象。然后，我们使用MERGE语句将每个json对象中的id属性与数据库中的节点进行匹配，如果节点不存在则创建一个新节点。最后，我们使用SET语句将json对象中的properties属性设置到节点上。
- 注意：在这个示例中，$jsonList是一个参数，你可以将其替换为你自己的json数据。
- 执行上述Cypher查询，将无限的json流插入到Neo4j数据库中。该查询将会在指定的时间间隔内不断执行，直到所有的json对象都被插入到数据库中。
- 你可以根据实际需求调整apoc.periodic.commit函数的时间间隔，以及Cypher查询中的逻辑。
总结： 在Neo4j中使用apoc.periodic.commit插入无限的json流，可以通过启用apoc插件并编写适当的Cypher查询来实现。这种方法可以用于将大量的json数据导入到Neo4j数据库中，并且可以根据实际需求进行调整。对于更多关于Neo4j和apoc插件的信息，你可以参考腾讯云的Neo4j产品介绍页面：Neo4j产品介绍。
相关·内容
1回答
我使用这个密码查询在Neo4j中创建两个节点之间的关系
MATCH (first:FIRSTNODE)
with first
MATCH (second:SECONDNODE)
WHERE first.ID = second.ID
CREATE (first)-[:RELATION]->(second)
第一有100.000个节点，第二有1.10万个节点。
我导入了csv文件，然后创建了这两个表的索引；但是当我尝试使用关系运行查询时，neo4j被卡住并停止工作。我注意到，当这种情况发生时，cpu的使用率是100%。
我使用的cpu是8x4.0Ghz和10 an的ram和一个SSD。
你知
浏览 7提问于2017-07-04得票数 1
回答已采纳
我用以下代码在Neo4j中创建了节点，
from py2neo import Graph, Node, Relationship
g = Graph(password='neo4j')
tx = g.begin()
node1 = Node('Node', name='Node-1')
node2 = Node('Node', name='Node-2')
node3 = Node('Node', name='Node-3')
node4 = Node('Node'
浏览 1提问于2020-07-25得票数 3
回答已采纳
我正在尝试使用一些Spring过程，主要是在Neo4j Data Neo4j存储库中使用@Query注释的apoc.periodic.commit和apoc.periodic.iterate。以下查询将作为示例： @Query("CALL apoc.periodic.commit(\"MATCH (n:SomeNodeLabel)-[*]->(x) WHERE ID(n) = {id} DETACH DELETE x RETURN COUNT(x) LIMIT {limit}\", {limit:10000});")
public void delete
浏览 34提问于2020-04-22得票数 0
我有1.3亿个标签为Snp的节点。我希望将所有节点的属性position从string转换为int。我使用的是apoc版本为3.0.4.1的neo4j 3.0.4。
由于有大量的节点，这必须分批完成。为此，我尝试了apoc.periodic.rock_n_roll()过程
CALL apoc.periodic.rock_n_roll(
'MATCH (n:Snp) WITH n RETURN id(n) AS id_n',
'MATCH (n:Snp) where id(n)={id_n} SET n.position = toInt(n.positi
浏览 0提问于2016-08-25得票数 3
回答已采纳
我试图在一个Docker容器中(通过)在OSX (El Capitan)上运行一个Neo4j 3.1实例。一切都很好，除非我试图在缺省的512 to以上增加Neo可以使用的最大堆空间。
根据，这可以通过添加环境变量NEO4J_dbms_memory_heap_maxSize来实现，这将导致服务器包装脚本相应地更新neo4j.conf文件。我已经检查过了，它正在如人们所预料的那样被更新。
问题是，当我运行docker-compose up来拆分容器时，Neo4j实例会以137状态代码崩溃。一项小小的研究告诉我，这是一个基于堆大小最大限制的。
$ docker-compose up
Startin
浏览 3提问于2017-02-22得票数 9
回答已采纳
我是NEO4J新手，正在尝试将JSON流中的数据插入到数据库中。JSON流的根元素是一个数组，数组中的每个元素都是一个包含键/值的对象和一个数组。 JSON流示例： [
{
"access_point":4864834,
"objects": [
{"class_id":10, "name":"iphone", "snr":0.557461},
{"class_id":7, "name":"android", "snr
浏览 41提问于2020-01-07得票数 0
回答已采纳
我在Neo4j中创建了一个大图，并有一个空节点，该节点通过图中的1100万个关系连接，我需要删除这些关系。我知道，如果我只是删除节点，我将留下所有挂起的关系，但我在试图删除它们的尝试中失败了。我已经尝试过以下CYPHER命令，但它们挂起，但未能完成：
MATCH (n:Label {uid: ''}) DETACH DELETE n;
和
MATCH (n:Label {uid: ''})-[r]-() DELETE r;
我假设没有足够的资源来加载内存中的1100万关系子图，以便分离和删除节点。是否有任何方法循环这些关系以降低所需的系统资源？
浏览 0提问于2018-03-09得票数 2
回答已采纳
在Neo4j中有两个查询，如下所示：
MERGE (temp:Temp)
SET temp = {tid: 'blabla', title_ids: [], pid: 'blabla'}
首先，我正在创建一个具有上述查询的节点。然后，我将运行以下查询代码，
CALL apoc.periodic.commit(
"
MATCH(temp:Temp)
WITH temp
MATCH (t1:Title)-[r:TO]->(t2:Title)
WHERE t1.tid = temp.tid
AND NOT
浏览 3提问于2020-09-22得票数 1
回答已采纳
下面的查询可以工作，我希望只要查询有结果，就重复运行该查询。最后，由于我在每次迭代中都将b:MAINS_CS上的processed属性设置为1，因此查询将返回零条记录。我对所有查询返回的所有记录感兴趣。
我尝试过使用可变长度的关系，但是查询似乎运行得非常慢。
有没有办法在cypher中做到这一点，而不必每次都手动执行查询？我正在尝试在Neo4j浏览器中实现这一点。
MATCH (a:MAINS_CS)-[:Connects]-(joint:MAINS_JOINT)-[:Connects]-(b:MAINS_CS {cs_source_way_id:a.cs_source_way_id})
WH
浏览 1提问于2018-11-04得票数 0
我有一个neo4j数据库，包含~260000 (编辑:以前按数量级不正确，缺失0)的基因节点，大致如下：
example_nodes：sourceId，targetId
在sourceId和targetId上都有索引
我试图在所有节点之间建立关系，但经常遇到OOM问题。我已经在一个拥有16G内存的系统上将我的JVM堆大小增加到了-Xmx4096m和dbms.memory.pagecache.size=16g。
我假设我需要优化我的查询，因为它根本无法以当前的任何形式完成。不过，我尝试了以下三项，但均徒劳无功：
MATCH (start:example_nodes),(end:e
浏览 4提问于2017-06-01得票数 1
1回答
我有一个巨大的json文件(1 gb)的数据，我想把它插入到谷歌云平台的Neo4j数据库中。我已经在/var/lib/ne4j/import目录中上传了我的json文件，并尝试使用以下密码代码在neo4j中创建节点。不幸的是，我收到以下错误。 call apoc.load.json('file:///nov.json') yield value
unwind value as val
merge(a:Article{title:val.title, text:val.text, url:val.url }) 以下错误 Failed to invoke procedure
浏览 160提问于2020-12-27得票数 0
我正在使用新4j- java -驱动程序(螺栓端口)将我的java应用程序与neo4j DB连接。我想要运行一个负载CSV查询，这个查询应该在一批500中运行，所以我想对它使用定期提交。所以首先，我用：
USING PERIODIC COMMIT 500 ...
在这种情况下，我得到了错误：
Caused by: org.neo4j.driver.exceptions.ClientException: Executing queries that use periodic commit in an open transaction is not possible.
我在这里找到了一些关于它的答
浏览 3提问于2021-02-17得票数 0
回答已采纳
由于目前还不可能通过..graphml文件将数据从Neo4j传输到地理信息，所以我尝试流数据。因此，Gephi的图形流插件存在。
按照指令并插入Cypher代码：
match path = (:p)-[:r]->(:m)
WITH path LIMIT 1000
with collect(path) as paths
call apoc.gephi.add(null,'workspace0', paths) yield nodes, relationships, time
return nodes, relationships, time
我收到：
Can't r
浏览 5提问于2017-08-22得票数 3
您好，我正在尝试使用pyspark和kafka创建一个neo4j接收器，但由于某些原因，此接收器在neo4j中创建了重复项，我不确定为什么会发生这种情况。我希望只得到一个节点，但看起来它正在创建4个节点。如果有人有想法，请让我知道。
Kafka生产者代码：
from kafka import KafkaProducer
import json
producer = KafkaProducer(bootstrap_servers='10.0.0.38:9092')
message = {
'test_1': 'test_1',
&
浏览 0提问于2020-03-20得票数 1
我已经编写了一个带有遍历的非托管扩展，并且由于遍历的结果，我有一个Iterable，我需要以cypher rest输出的相同json格式进行转换。通过这种方式，我可以将非托管扩展与我正在使用的neo4j php库链接起来。在neo4j服务器社区版本中实现这一点的代码在哪里，或者我需要使用什么类/方法？
浏览 2提问于2014-08-07得票数 0
回答已采纳
是否可以在没有任何持久数据库/文件存储的情况下仅在内存中运行Neo4j？
数据来自多个xml/json文件，我们必须使用ConcurrentHashmap将它们加载到jvm堆内存中。由于数据对象具有依赖关系(父-子，子对象可以链接回父对象)，因此我们希望维护一个对象图。在这种情况下有没有使用Neo4J的方法；或者你能推荐任何支持维护这种对象图的框架吗？
谢谢你。
浏览 1提问于2014-01-29得票数 10
1回答
我尝试在cypher中实现perfect match算法，以在加权双峰网络中查找约束集(对)。 例如，有员工和他们可以执行的一组任务。一名员工可以完成多项任务。每个任务都有一个优先级，在这种情况下是一个边权重。考虑到优先级，我希望获得最优的任务-员工匹配。我想我应该遍历按degree x priority值排序的两个节点集，但我不知道如何迭代。 我已经浏览了目前Neo4j中包含的算法列表，但找不到任何类似的算法。我想知道是否有任何算法的实现或任何接近它的东西？我认为在Neo有一个可能是有用的。
浏览 40提问于2019-02-16得票数 1
我正在学习Spring webflux和Reactive Streams，并尝试了一个从mongoDB流传输信息的服务。问题是，当没有任何东西可以从MongoDB发送时，Spring就会关闭请求。所以我真正想做的是:在我的mongodb中有一个Angular表，显示SPRING检索的数据，并且每次进行更新/插入时，让新数据自动到达Angular。 我发现的唯一方法是每隔XXXX毫秒调用我的angular服务。 有没有其他方法可以做到这一点？下面是我的Spring here服务代码： @GetMapping(path="/stream/organisation",produce
浏览 39提问于2019-03-14得票数 2
回答已采纳
我在为大量节点和关系创建三进闭包时遇到了问题。我过去找了好几个小时的答案，但没有什么能与我的问题相匹配。
数据集：
带有标签PERSON的322276个节点(在属性名称上有索引)
具有标签生产的987052个节点
6417928与标签播放的关系
14314487与标签作品的关系
这些节点按以下方式连接：
(：人)-：戏剧->(：制作)
(人)->(：生产)
我想在all persons之间创建三进闭包，这意味着将在同一产品中工作/播放的两个人与label :WORKED_IN连接在一起。为此，我编写了以下查询：
MATCH (p1:PER
浏览 5提问于2017-06-01得票数 2
回答已采纳
我希望通过Spring Neo4j 4.0.0将实时日志数据插入到Neo4j 2.2.1中。测井数据非常大，可能达数十万条记录。如何实现这种功能的最佳方式？在所有节点实体对象创建的末尾使用.save(Iterable)方法安全吗？在Spring Neo4j 4.0.0中是否存在类似批处理插入机制？提前感谢！
浏览 5提问于2015-05-27得票数 2
回答已采纳
我有cad地形图文件(.dwg)，我想把它们转换成JSON格式，插入到数据库中。我正在考虑MySQL或neo4j将每个房间的坐标插入到数据库中。
经过一段时间的搜索之后，我找到了一个名为autodesk ()的工具，它可能很有用，但如果我要将.dwg转换为json，就无法找到在线遵循的步骤。有人能帮我解决这个问题吗？
浏览 6提问于2018-02-15得票数 1
2回答
我在mysql中有一个包含60000项的数据集，我正在尝试将其插入到neo4j中。插入正在进行，但需要很长时间(大约每3秒10-15 )。有没有什么办法可以加快速度呢？还有，我有没有办法在neo4j中给出一些东西，比如唯一键，这样复制索引就不会被索引了？我是neo4j的新手。
我使用的是带有neo4j Everyman驱动程序的PHP1.8。
浏览 0提问于2012-12-03得票数 1
1回答
我有一个mysql数据库作为主数据的基本数据存储。对于类似于“朋友之友”类型的复杂多级查询，我有一个图形数据存储neo4j。我面临的问题是在维护事务时，我必须在mysql中插入用户记录，在neo4j中插入用户节点。现在我希望他们俩都能成功。我所做的是，如果neo4j插入成功，那么我就插入一个mysql用户记录。但是，如果插入mysql用户记录失败，我有一个不一致的状态。如果我先插入mysql，然后插入neo4j，可能会发生类似的情况。有什么办法可以跨mysql和neo4j完成事务吗？需要维护一些失败的事务日志并在以后执行它们吗？
谢谢!我知道许多人不同意neo4j和mysql的组合方法，但如果
浏览 2提问于2014-03-29得票数 3
回答已采纳
1回答
neo4j图中循环对性能的影响？
、、、、
图中的圈以各种形式出现。它们可以是短的，也可以是长的。例如:彼得，->，比尔，->，汤姆，->，彼得，彼得，->，彼得。有时，循环的存在是令人不满的，但有时有必要以这种方式表示您的数据。
我想知道在Neo4j中运行查询时，循环在图形(我的数据)中的存在会产生什么影响。
假设我对我的数据有一个特定模式的查询。有些情况下我有一个循环，有些情况下我的数据中没有循环。由于循环本质上是一个无限循环(例如，如果我运行一个DFS算法，如果我不采取预防措施，它将无限循环)，因此我假设Neo4j数据库管理系统具有检测和突破这些循环的开销。
因此，我相信在这些情况下会有显著的性能差异，也就
浏览 2提问于2019-04-14得票数 1
回答已采纳
1回答
我是Neo4j的新手，手头有以下问题。我正在尝试开发一个社交网站，我想在其中存储两个用户之间的关系属性交换的消息。为此，我尝试将他们的所有消息以数组/列表的形式存储在关系属性中。你能建议一下Neo4j是否提供这种类型的操作吗？
我还想知道是否可以在此关系属性上插入消息，并更新数组/列表(即在下一个索引上添加新消息)
对于ex：
User1 -> User2 : Hi, whats up
User2 -> User1 : Hi, I am in college
So the relationship property stores the message in the form
浏览 0提问于2013-09-25得票数 8
回答已采纳
1回答
我的基本要求是创建一个从BigQuery表读取的管道，然后将其转换为JSON并将其传递到PubSub主题.
一开始，我从Big中读取，并尝试将其写入Pub主题，但得到了一个exception error saying "Pub Sub" is not supported for batch pipelines。所以我尝试了一些解决办法
我能在python里做些工作
读取BigQuery-> ConvertTo JSON字符串->在云存储中保存为文本文件(束管道)
p = beam.Pipeline(options=options)
json_stri
浏览 4提问于2021-10-13得票数 0
回答已采纳
1回答
我需要通过REST的批处理端点(大约5k记录/s)将大量具有它们之间关系的节点插入到Neo4j中(还在增加)。
这将是连续插入24x7。每个记录可能只需要创建一个节点，而另一个则可能需要创建两个节点和一个关系。
我是否可以通过更改我的过程或修改Neo4j的设置来提高插入的性能？
我迄今取得的进展：
1.我已经用Neo4j进行了一段时间的测试，但是我无法获得所需的性能。
测试服务器盒: 24核+32 24
Neo4j 2.0.0-M06作为独立服务安装。
在同一台服务器上运行我的Java应用程序。(Neo4j和Java应用程序将来需要在自己的服务器上运行，因此不能使用嵌入式模式)
REST端点:
浏览 0提问于2013-11-07得票数 4
回答已采纳
1回答
我在我的项目中使用了spring boot和neo4j。SDN(spring data neo4j)作为数据访问层。最近我遇到了一个问题，我需要跨商店持久化，我需要更新neo4j和oracle数据库中的数据。因此，执行此操作的标准方法是XA分布式事务。我在集成neo4j和JTA上查找的任何资源都是旧的，最近我在SDN参考页面上发现了这一点："Neo4j正在放弃对XA的支持，因此SDN没有提供任何跨存储持久性的功能。“ 链接：https://docs.spring.io/spring-data/neo4j/docs/5.1.10.RELEASE/reference/html/ 我的问题
浏览 28提问于2019-09-11得票数 4
回答已采纳
我试图在neo4j中插入唯一的节点和关系。
我用的是:-
运行在AmazonEC2上的Neo4j社区版
Neo4j Java绑定[ ]
数据大小和类型:
TSV文件多重。每一行包含超过800万行，每一行代表一个节点或一个relationship.There，是超过10个文件的nodes.=，200万个节点和另外200万个关系。
我使用UniqueNodeFactory插入节点。并且按顺序插入，无法找到任何方法将其插入到保留唯一节点的批处理中。
问题是，插入数据需要花费大量时间。例如，插入30万个唯一节点几乎需要一天的时间。有什么办法可以固定插口吗？
浏览 1提问于2014-06-24得票数 1
1回答
我的问题很普遍，而且是关于架构的。
我不断地收到大量数据(JSON)。这可能会达到每秒30个json。
我需要将每个查询插入到数据库中，并使用许多不同的查询来分派信息。这个数据库可以是任何东西，但我更喜欢Neo4j。
如果我看到，如果我一收到就插入，那么插入就会越来越晚，我的意思是我得到了500个json文件，其中有200个被插入(即使在db中有索引)。
因此，我认为我应该将作业分开:一个脚本接收数据，另一个脚本或单独的线程插入数据库。
那么，根据你的经验，对于这种情况，最好的方法是什么？磁盘上的临时json文件是否等待处理？
浏览 1提问于2017-05-17得票数 0
3回答
我只是想对2k个节点做一个简单的批量插入测试，这就是超时。我确信这不是内存问题，因为我正在使用ec2 xLarge实例进行测试，并且我更改了neo4j java堆和数据存储内存参数。会出什么问题呢？
浏览 4提问于2013-04-10得票数 0
回答已采纳
2回答
我在和Neo4j玩。我有一个大约有40万个节点的数据库。我想从CSV文件中插入关系。大约有140万的人际关系。
目前我正在使用REST。其余的请求如下所示：
POST http://localhost:7474/db/data/cypher
Accept: application/json; charset=UTF-8
Content-Type: application/json
{"query": "MATCH (a { ConceptId: '280844000' }), (b { ConceptId: '71737002' }) C
浏览 5提问于2014-07-21得票数 3
回答已采纳
我在Neo4j中插入大量JSON数据时遇到了问题
如果我在Neo4j中插入更多的数据，这意味着运行它需要更多的时间，并且使我的性能非常慢，我必须等待10-15分钟才能完成插入过程。
是否有关于如何插入大容量数据的解决方案或建议？我在插入JSON数据时使用了merge查询，并且没有唯一的值，所以我选择了一些组合来在merge查询中创建对象模型。
dir_port sym_dev ini_tiator_group_name host_lun sym_metrix_id
(在这个查询中没有唯一的约束来获取对象模型，我们使用了我前面提到的值的组合)
这是我的疑问：
CALL apoc.load.jso
浏览 0提问于2018-07-04得票数 0
1回答
我有一个相当长且复杂的分页查询。我在努力优化它。在最坏的情况下--首先，我必须在一个对Neo4j的调用中执行数据查询，然后我必须对计数执行几乎相同的查询。当然，我每件事都是在一个交易中完成的。无论如何，我不喜欢整个执行时间，所以我提取了最常见的部分--数据和计数查询，并在第一次调用时执行它。这个常见的查询返回节点的ID，然后作为参数传递给其余的数据和计数查询。现在，一切都运行得更快了。我不喜欢的一件事是，一个普通的查询有时会返回相当大的一组ID。它可以是20k..50k Long it。
因此，我的问题是--因为我是在一个事务中这样做--是否有一种方法可以在普通查询和数据/计数查询调用之间在N
浏览 4提问于2022-08-30得票数 0
我正在使用Python2.7.6和Neo4j (1.6.4)更新Py2Neo服务器上的数据。我的负载功能是：
from py2neo import neo4j,node, rel, cypher
session = cypher.Session('http://my_neo4j_server.com.mine:7474')
def load_data():
tx = session.create_transaction()
for row in dataframe.iterrows(): #dataframe is a pandas dataframe
浏览 0提问于2014-08-11得票数 1
回答已采纳
使用Neo4j版本1.8.1，我尝试使用"cypher“REST入口点来插入许多关系(查询必须插入关系，并且只有在必要时才插入目的节点)。我通过博客发现了这种可能性。
如果我只创建一个关系，它工作得很好，但当我尝试几个关系时，它就失败了。
JSON用于调用一个正在运行的关系：
{"query":"START n=node:node_auto_index(UserId='21000001') CREATE UNIQUE n-[:KNOWS{Label:'Friend'}]-(m{Users})", "params&#
浏览 2提问于2013-03-24得票数 3
回答已采纳
请告诉我在ASP.NET MVC中返回max Json结果的最好方法。
目前我使用的是：
return Json(jsonData,JsonRequestBehavior.AllowGet);
在这种情况下，如果方法返回max size of Json，那么Ajax就会抛出错误。对于这个错误，我使用这个解决方案。
var jsonResult = Json(jsonData, JsonRequestBehavior.AllowGet);
jsonResult.maxJsonLength = int.MaxValue;
return jsonResult;
但是我对这个解决方案有一个问题。如果我
浏览 14提问于2018-02-12得票数 0
我的import.csv创建了许多节点，合并创建了一个巨大的笛卡尔产品，并在transaction timeout中运行，因为数据已经增长了很多。我目前已经将事务超时设置为1秒，因为其他每个查询都非常快速，并且应该不会花费超过1秒的时间来完成。
是否有一种方法可以以较小的块分割或执行此特定查询，以防止超时？
在transaction timeout中提升或禁用neo4j.conf不是一个选项，因为neo4j服务需要重新启动配置中的每一个更改。
从导入脚本中命中超时的查询：
MATCH (l:NameLabel)
MATCH (m:Movie {id: l.id,somevalue: l.s
浏览 9提问于2017-09-18得票数 1
回答已采纳
为了加快插入节点的速度，我用Neo4j开发了一个自己的插件。主要是因为我只需要插入以前不存在的节点和关系，使用REST API可能会太慢。
如果我尝试调用我的插件100次，每次插入大约100个节点和100个关系，那么每次调用大约需要350ms。每次调用都会插入不同的节点，以排除锁定原因。
然而，如果我并行我的调用(2，3，4...在时间)上，响应时间随着并行度的增加而相应下降。当我一次做2次调用时，插入200个对象需要750毫秒，当我做3次调用时，需要1000毫秒，等等。
我使用HttpWebRequest从.NET MVC控制器调用我的插件。我将maxConnection设置为10000，可
浏览 0提问于2013-07-19得票数 0
回答已采纳
当我在neo4j中插入大量数据时，Neo4j出现内存问题。在每一次大的治疗之后，添加一个session.clear()后，情况都要好一些。
我计划为每一个插入做不同的线程。我必须用session.clear()结束所有线程吗？后果是什么？
浏览 2提问于2017-04-09得票数 2
回答已采纳
有一个Country类：
public class Country {
public int id;
public String name;
public String locale;
}
我必须插入neo4j。
我所做的是：
public void insert(Country country) {
engine.query("create (n:Country {name:'"+country.name+"',id:"+country.id+",locale:'"+coun
浏览 4提问于2015-03-03得票数 1
回答已采纳
1回答
我对neo4j真的很陌生。我有我希望它们成为我的节点e.t.c的java对象。有没有办法将它们提取到xml，json，simpe txt中，然后将它们插入到图形数据库中(从提取的文件)。
提前感谢
浏览 0提问于2013-07-23得票数 0
回答已采纳
1回答
假设我有一个相当大的JSON对象。此对象可以以多种方式嵌套，并包含数组。该对象给出了用户及其与类型的奇异对象和类型的多个(数组)对象的关系。
我的目标是尽可能快、高效地将其插入Neo4j中。
在一个查询中，这是一个通过迭代JSON结构创建的连接字符串，它是否建议这样做？(解析对象并将其抽象为多个节点和关系)
还有一个让我很难处理这个过程的常见问题:对于我正在迭代的数组，当我连接合并语句时，Neo4J中的节点会被复制，合并似乎无法工作。
//Person to interests
_.each(interests, function(itr){
ingestQuery += 'M
浏览 0提问于2016-03-27得票数 0
回答已采纳
我是neo4j和python的新手，我的程序将获得节点和关系作为参数，我想将它们插入到neo4j中，我能够插入静态数据，如下所示 create(p:Person {name:"Hemanth"}) 这里的"Person“也会动态更新
浏览 23提问于2020-11-20得票数 0
第一次使用neo4j在浏览器上运行neo4j，因为我的neo4j桌面版本不起作用
试图将JSON加载到IT中，但IT说Failed to invoke procedure `apoc.load.json`: Caused by: java.lang.RuntimeException: Import from files not enabled, please set apoc.import.file.enabled=true in your apoc.conf
我的命令
call apoc.load.json("///apoc.json") yield value
我无法在浏览
浏览 4提问于2021-03-26得票数 1
1回答
我试图将json文档加载到Neo4j中，但如果可能的话，我不想使用文件，因为在我的例子中，这是浪费时间。
我现在做的是：
Python查询到Elasticsearch数据库从Neo4j Python库将数据推送到.json文件，运行
我想做的是：
对DatabaseFrom Neo4j 库的查询，运行
有什么语法可以帮我吗？谢谢
浏览 8提问于2022-02-11得票数 -2
回答已采纳
我想使用Neo4j在py2neo中插入一些数据。到数据文件。我是Neo4j的新手。有人能告诉我如何在Neo4j.Actually中插入大量数据吗?我想对Neo4j进行性能测试……
我试过了，但这只是为了小数据集.
from pprint import pprint
from py2neo import neo4j,node, rel
graph_db = neo4j.GraphDatabaseService()
def insert_data():
die_hard = graph_db.create(
node(name="Bruce Willis"
浏览 5提问于2013-09-21得票数 3
回答已采纳
我试图通过电子邮件在本地数据库中搜索用户，但当我试图通过导入从不同的js文件中引用执行此操作的函数时，我得到了未定义的结果。我在Stack上搜索了一下我遇到的这个问题，听说有回调，这是我需要实现的东西吗？如果是这样，你能给我举个例子吗？
提前感谢！
下面是我导出的代码(db.js文件)：
var neo4j = require('neo4j-driver').v1;
var driver = neo4j.driver("bolt://localhost:7687", neo4j.auth.basic("neo4j", "neo4j"
浏览 1提问于2017-03-12得票数 0
回答已采纳
1回答
我使用Neo4j API批量插入数百万条记录，如果单独执行，通常要花费更长的时间。导入完成的速度要快得多，但我没有看到我插入的数百万条记录。Neo4j是否为批处理插入保留某种形式的队列并随时间进行插入？
如果是的话，我怎样才能看到这个队列的进展？我正在做一个统计，我注意到记录在增加，但速度非常缓慢。
我使用的是Neography创业板的批处理插入()，进行批处理插入的代码如下：
User.find_in_batches(batch_size: 500) do |group|
$neo4j.batch(*group.map { |user| ["create_unique_node
浏览 4提问于2014-07-27得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
