Home

Here’s the table of contents: 变量冲突调整 BUILD-TASK脚本命名规范 异构图 同构图 异构图过程设计 异构图-TASK脚本生成 生成custom.task.build.graph.*过程 节点CYPHER-TASK生成 关系CYPHER-TASK自动生成 同构图过程设计 同构图-TASK脚本生成 节点CYPHER-TASK生成 关系CYPHER-TASK自动生成 变量冲突调整 文本中下列变量在使用时去掉双下划线`--`【因为与GitHubIO.blo...

Here’s the table of contents: 定义说明 查看自定义函数和过程 查看构建自定义函数和过程的存储过程 注册一个自定义函数 注册一个自定义过程 输入输出参数支持的数据类型 查看函数和过程清单 删除函数 删除过程 使用案例一 使用案例二 使用案例三 使用案例四 自定义函数与过程存储位置 定义说明 APOC提供相关过程来创建用户自定义的函数和过程。这些函数和过程实际上是参数化的Cypher语言查询，类似宏（Macro）的概念。 查看自定义函数和过程 CALL dbms....

Here’s the table of contents: 服务监控脚本DEMO 服务重启脚本 monitor.sh server-monitor.sh 服务监控脚本DEMO #!/bin/bash PRG="$0" currentpath=`dirname $(readlink -f $0)` echo $currentpath echo $(dirname $currentpath) frontdir=$(dirname $currentpath) javapid=$(ps -ef|grep java|grep -w $currentpath|awk '{print $2}') echo $javapid if [ -n "$javapid" ] then b...

Here’s the table of contents: ONgDB DAG TASK检查点记录表 关系的开始节点与结束节点标签相同【标签不同且分为两个任务时需要考虑check point的更新时机】 关系的开始节点与结束节点标签相同-数据分块-任务状态回滚【标签不同且分为两个任务时需要考虑check point的更新时机】 关系的开始节点与结束节点标签相同-数据分块-任务状态回滚【标签不同且分为两个任务时需要考虑check point的更新时机】 调度系统执行逻辑 异构图数据构建任务执行逻辑 同构图数据构建任务执行逻辑 ONgDB DAG TASK检查点记录表 CREATE TABLE `ONGDB_TASK...

Here’s the table of contents: 下载Kafka 解压 启动 测试Kafka 下载neo4j-streams组件包 配置neo4j.conf 监听TestTopic并运行指定CYPHER操作 通过生产者发送CYPHER操作给CypherTopic【从消息队列获取CYPHER后执行】 下载Kafka wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.7.0/kafka_2.12-2.7.0.tgz 解压 tar -zxvf kafka_2.12-2.7.0.tgz 启动 ./zookeeper-server-start.sh ../config/zook...

Here’s the table of contents: 查询数据并返回HTTP标头 参数向服务器发出HEAD请求，然后将服务器返回的HTTP标头打印出来 查询数据并返回HTTP标头 curl -i -u ongdb:testlab%pro -d '{"statements": [{"statement": "MATCH (n) RETURN n LIMIT 1","resultDataContents": ["row","graph"]}]}' -H 'Content-Type: application/json' -X POST http://10.20.13.200:7474/db/data/transaction/commit 参数向服务器发出HEAD请求，...

Here’s the table of contents: 在Spark集群安装neo4j-spark插件 基础组件依赖信息 创建测试数据 备注 报错 报错一 @TOC 如果需要在ONgDB集群集成Spark作图计算相关的任务，可以参考这个ongdb-spark-java-scala-example项目，避免踩坑:) 在Spark集群安装neo4j-spark插件 下载组件 https://github.com/ongdb-contrib/neo4j-spark-connector/releases/tag/2.4.1-M1 下载组件放在spark安装目录的jars文件夹 ...

Here’s the table of contents: 请求无法自动切换 请求可以自动切换 bolt+routing自动路由机制 请求无法自动切换 bin/cypher-shell -a bolt://ip:port -u username -p password 请求可以自动切换 bin/cypher-shell -a bolt+routing://ip:port -u username -p password bolt+routing自动路由机制 命令行执行cql echo 'MATCH (n) RETURN n LIMIT 10;' | /home/ongdb/ongdb-enterprise-3.5.22/bin/cypher-she...