Home

ONgDB-APOC自定义函数和过程

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

Read more

ONgDB服务进程监控

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...

Read more

基于check-point实现图数据构建任务

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

Read more

ONgDB集成Kafka组件

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...

Read more

curl请求测试服务连通性

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请求,...

Read more

Spark作为图数据计算组件的集成案例

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文件夹 ...

Read more

ONgDB集群如何应对写入节点发生自动切换

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...

Read more

公司与产品时序图数据建模

Here’s the table of contents: 整体数据模型的设计 函数与过程功能介绍 完整实现 - 构架公司与产品时序图数据 查询案例-分析’消费品商贸’产业2020Q2季度总营收 整体数据模型的设计 行业、产品、公司相关的产业链数据建模全景图,包含产品层级图谱、行业分层图谱、产业链上下游图谱、公司与产品图谱等。如下主要是公司与产品营收的时序图数据建模实现方案。 函数与过程功能介绍 HTTP请求 RETURN olab.http.post('api-address','input') 重置MAP-移除传入的KEY RETURN olab.reset.map({map},{keys}) AS valu...

Read more