ONgDB-APOC自定义函数和过程
Here’s the table of contents:
定义说明
查看自定义函数和过程
查看构建自定义函数和过程的存储过程
注册一个自定义函数
注册一个自定义过程
输入输出参数支持的数据类型
查看函数和过程清单
删除函数
删除过程
使用案例一
使用案例二
使用案例三
使用案例四
自定义函数与过程存储位置
定义说明
APOC提供相关过程来创建用户自定义的函数和过程。这些函数和过程实际上是参数化的Cypher语言查询,类似宏(Macro)的概念。
查看自定义函数和过程
CALL dbms....
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...
基于check-point实现图数据构建任务
Here’s the table of contents:
ONgDB DAG TASK检查点记录表
关系的开始节点与结束节点标签相同【标签不同且分为两个任务时需要考虑check point的更新时机】
关系的开始节点与结束节点标签相同-数据分块-任务状态回滚【标签不同且分为两个任务时需要考虑check point的更新时机】
关系的开始节点与结束节点标签相同-数据分块-任务状态回滚【标签不同且分为两个任务时需要考虑check point的更新时机】
调度系统执行逻辑
异构图数据构建任务执行逻辑
同构图数据构建任务执行逻辑
ONgDB DAG TASK检查点记录表
CREATE TABLE `ONGDB_TASK...
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...
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请求,...
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文件夹
...
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...
公司与产品时序图数据建模
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...
122 post articles, 16 pages.