树莓派neo4j在noe4j中将csv文件添加节点

news2024/12/28 3:45:47

参考前序教程:Raspberry Pi上使用pip来安装py2neo,pip install py2neoerror: externally-managed-environment-CSDN博客

 再次进入时

  1. 激活虚拟环境: 进入您创建的虚拟环境目录:

    cd venv
    

    然后激活环境:

    source bin/activate
    

    激活后,您将看到命令提示符前面有一个(venv)前缀,这表示您现在正在虚拟环境中。

导入程序代码如下:csv需要多行多列, 

from py2neo import Node, Relationship, Graph, NodeMatcher
# 导入py2neo库中的相关类,用于操作Neo4j图数据库

uri = "bolt://localhost:7687"  
# Neo4j数据库的连接URI
username = "neo4j"  
# Neo4j数据库的用户名
password = "123456cys"
# Neo4j数据库的密码
graph = Graph(uri, auth=(username, password))
# 创建Graph对象,用于连接和操作Neo4j数据库

path = "/home/pi/python_neo4j/oil0813.csv"  
# 要读取的CSV文件路径
with open(path, 'r', encoding='utf-8') as file:  #如果不是utf-8编码,需要转换成utf-8编码,可使用notepad++
    lines = file.readlines()
# 打开并读取CSV文件内容到lines列表中

con = list()
# 初始化一个空列表,用于存储处理后的数据
zh=['ViolationID', 'Symbol', 'DisposalDate', 'DeclareDate', 'ShortName', 'CoFullName', 'Promulgator', 'FileName', 'DocumentNumber', 'Supervisor', 'ViolationType', 'ViolationTypeID', 'Law', 'ViolationYear', 'Activity', 'PunishmentMeasure', 'SumPenalty', 'IsViolated', 'PunishmentType', 'PunishmentTypeID', 'Penalty']
# 定义一个列表,包含CSV文件中各列的标题

for j in lines:
    try:
        a = j.replace("\t","").strip('\n').split(",")
        # 将每一行数据中的制表符替换为空格,去除换行符,然后按逗号分割成列表
        a = [i for i in a] # 保持数据为字符串类型
        # 将处理后的数据添加到con列表中
        con.append(a)
    except:
        continue
    # 如果处理过程中出现异常,则跳过当前循环

for j in con:
    try:
        selector = NodeMatcher(graph)
        # 创建NodeMatcher对象,用于匹配节点

        # 创建第一个节点(如果不存在)
        entity1 = selector.match(j[1], name = j[0])
        if len(list(entity1)) == 0:
            entity1_node = Node(j[1], name = j[0])
            graph.create(entity1_node)
        else:
            pass

        # 创建第二个节点(如果不存在)
        entity3 = selector.match(j[3], name = j[4])
        if len(list(entity3)) == 0:
            entity3_node = Node(j[3], name = j[4])
            graph.create(entity3_node)
        else:
            pass

        # 创建两个节点之间的关系
        e1_node = graph.nodes.match(j[1], name = j[0]).first()
        e2_node = graph.nodes.match(j[3], name = j[4]).first()
        e12 = Relationship(e1_node, j[2], e2_node)
        graph.create(e12)
    except:
        continue
    # 如果创建节点或关系过程中出现异常,则跳过当前循环

print("ok1")
# 打印"ok1",表示程序执行完成

 

快10万节点了 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/2036243.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

【学习笔记】Day 12

一、进度概述 1、《地震勘探原理》第五章 二、详情 个人感觉第五,六,八章的解释更倾向于地质学那边负责的,但是多了解相关原理,肯定是有利于 DL-FWI 的相关研究的,所以这里只是做一个粗略的归纳,相关内容详…

原来这就是KEEPALIVED(高可用集群大讲解)

keepalived可用来解决haproxy挂掉后集群无法使用的问题 一.高可用集群 1.1 集群类型 LB:Load Balance 负载均衡 (lvs和haproxy解决的) LVS/HAProxy/nginx(http/upstream, stream/upstream) HA:High Av…

LTspice 仿真电容阻抗频率特性曲线

一、仿真原理图如图所示,有一个电压源和10uf的电容C1。 二、信号源参数: 三、电容参数,其中包含了耐压值6.3V,ESR,ESL。 四、执行参数为 .ac dec 1000 1 1000Meg,扫频模式。 五、开始仿真,然后设置曲线为下…

【网盘源码】百度云盘手动cookie获取,添加到扫码系统管理平台v3.0版本。

大家好,今天来给大家介绍如何购买适合自己的网盘系统! 角色定位 技术小白 特点: 对技术了解有限,想快速搭建网盘平台。 目的: 单一卖自己的网盘业务,不想投入太多精力在技术维护上。 推荐: 租赁…

基于 Fluent 和深度学习算法驱动的流体力学计算与应用

在深度学习与流体力学融合的背景下,科研边界不断拓展,创新成果层出不穷。从物理模型融合到复杂流动模拟,从数据驱动研究到流场智能分析,深度学习正以前所未有的力量重塑流体力学领域。 目前在 Nature和Science杂志上发表的深度学…

【C++】多源BFS问题和拓扑排序

目录 多源BFS介绍 单源BFS和多源BFS的区别 SO如何解决多源BFS问题 多源之核心 矩阵 算法思路 代码实现 飞地的数量 算法思路 代码实现 地图中的最高点 算法思路 代码实现 地图分析 算法思路 代码实现 拓扑排序介绍 有向无环图 ​编辑 如何解决这类问题 课…

【基础解读】神奇宝贝多分类——Logistic Classification

Classification的三步走 交叉熵损失函数 逻辑回归与线性回归的三步走对比 CE和SE对比 Discriminative与Generative对比 多分类问题 逻辑回顾的限制 特征转换

OneAPI配置自己的令牌并实现python调用

1、登录OneAPI账户(初始账户密码为 账号:root 密码:123456) 2、第一次登录会提示修改密码 3、点击网页渠道 可以配置自己大模型的渠道 4、OneAPI支持多家厂商进行渠道配置,选择不同厂商就可以调用对应大模型 5、渠…

基于Linux对 【进程地址空间】的详细讲解

研究背景: ● kernel 2.6.32 ● 32位平台 –❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀-正文开始-❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀–❀– 在学习操作系统中想必大家肯定都见过下面这…

如何防止员工私自拷贝公司内部文件?安企神帮你解决泄密之忧

在企业运营中,保护公司的机密信息至关重要。员工私自拷贝公司内部文件不仅可能导致商业秘密泄露,还可能损害公司的声誉和经济利益。下面我们将介绍一些有效的方法来防止这种情况的发生,并以“安企神”软件为例进行详细说明。 1. 明确规章制度…

怎么调试python脚本

打开pycharm community 2019.1软件,创建一个项目。 创建一个py后缀的文件作为示范,文件名自己定义。 编写代码,然后右键点击进行运行,查看一下是否有问题。 点击右上角的虫子图标,然后下面会有控制面板出来&#xff0c…

财务会计与管理会计(四)

文章目录 月度数据统计分析OFFSET函数在图表分析中的应用 多种费用组合分析图SUMPRODUCT函数 省公司全年数据分析模板INDIRECT、OFFSET函数 多公司分季度数据筛选VLOOKUP、IFERROR函数的应用 淘宝后台数据分析OFFSET函数在跨表取数中的应用 燃气消耗台账数据统计分析图SUMPRODU…

进程的结束

回顾上节: 父子进程的关系 子进程是父进程的副本 子进程获得父进程的数据段,堆,栈,正文段共享 在fork之后,一般情况下那个会先运行是不确定的,取决于操作系统 练习: 用进程实现文件拷贝 …

某家用智能路由权限绕过

You can’t improve your past, but you can improve your future. 你无法改变过去,但你可以让未来变得更美好。 漏洞描述 某家用智能路由存在权限绕过,通过Drop特定的请求包访问未授权的管理员页面 漏洞实战 访问漏洞url http://x.x.x/index.html…

数据结构 AVL树

概述 AVL树的主要特点是在插入或者删除节点后,树会自动保持其平衡性,从而保证了最坏情况下,查找、插入和删除的时间复杂度都是O(log n)。注意AVL树是符合二叉搜索树的规则,即左子树小于根节点数值&#xf…

为什么说视频监控平台必须要有转码能力?视频汇聚平台EasyCVR视频转码能力解析

在当今数字化时代,视频监控技术已成为社会安全、城市管理、企业运营等多个领域不可或缺的一部分。随着监控系统的广泛应用和技术的不断进步,视频数据的处理与传输需求日益复杂多样,这使得视频监控平台必须具备强大的转码能力显得尤为重要。以…

Python模拟退火算法

目录 模拟退火算法简介模拟退火算法的步骤模拟退火算法的Python实现场景:函数优化问题 代码解释总结 模拟退火算法简介 模拟退火算法(Simulated Annealing, SA)是一种基于物理退火过程的随机搜索算法,用于寻找全局最优解。其灵感…

如何用OceanBase实现HBase架构升级

随着数据量的爆炸性增长,特别是半结构化和非结构化数据的涌现,传统关系型数据库如 MySQL 遭遇了前所未有的挑战。这一背景下,为非结构化数据管理而生的 NoSQL 数据库,以及旨在解决海量数据存储难题的分布式技术应运而生&#xff0…

Day08-K8S安全框架RBAC

Day08-K8S安全框架RBAC 0、昨日内容回顾:1、K8S安全框架1.1 K8S的安全架构流程图解1.2 RBAC1.3 基于用户的权限管理实战1.4 RBAC基于组的方式认证:1.5 serviceaccount 2、持久卷与动态存储2.1 传统基于存储卷的方式挂载的缺点2.2 引入PV和PVC实现后端存储解耦2.3 引入动态存储类…

鸿蒙(API 12 Beta3版)【播控特性简介】分布式媒体会话

使用媒体播控,可以简单高效地将音视频投放到其他HarmonyOS设备上播放,如在手机上播放的音视频,可以投到2in1设备上继续播放。 HarmonyOS提供了统一的应用内音视频投播功能设计,通过使用系统提供的投播组件和接口,应用…