系统集成实战：seafile

2024-01-23 02:44
文章标签 实战 seafile 系统集成

本文主要是介绍系统集成实战：seafile，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

前言

        Seafile是一款强大优秀的云同步软件，拥有跨平台文件同步、移动端文件访问、挂载盘、文件共享和权限控制、文件锁定、文件版本管理和资料库镜像、在线编辑和协同编辑、审计日志等功能。

        为了进一步扩展它的可用业务，并将其集成到其他业务系统中。本文将给出一个python demo，其目的在于使用本地部署的seafile系统接口，将seafile功能通过api调用的形式拉出来单独进行操作。

demo

        这里集成了seafile api2及api/v2.1两款系统接口，为第三方系统+seafile的融合开发提供帮助。

        该代码仅用于学习分享目的，请勿滥用！

import os
import requests# 你的seafile信息
# 用户名、密码、项目地址根目录
username = 'xxx@qq.com'
password = 'xxxxxxx'
begin_url = 'http://127.0.0.1:1111/'class SeafileControl:def __init__(self):self.token = self.get_token()# 设置请求requests session保持对象self.session = requests.session()# token获取def get_token(self):headers = {'Content-Type': 'application/json'}datas = {'username': username, 'password': password}token = ''try:r = self.session.post(begin_url + 'api2/auth-token/', json=datas, headers=headers)print(r.json())token = r.json()['token']except Exception as e:print(e)finally:return token# 列出所有帐户def account_all(self):a = 'Token ' + self.tokenheaders = {'Content-Type': 'application/json', 'Authorization': a}  r = self.session.get(begin_url + 'api2/accounts/', headers=headers)return r.json()# 获得账户信息def account_msg(self, account):a = 'Token ' + self.tokenheaders = {'Content-Type': 'application/json','Authorization': a}  r = self.session.get(begin_url + 'api2/accounts/' + account, headers=headers)return r.json()# 创建用户def accout_create(self, AccountName):a = 'Token ' + self.tokenheaders = {'Content-Type': 'application/json', 'Authorization': a}# 给予默认密码xxxxdatas = {'password': 'xxxx'}response = self.session.put(begin_url + 'api2/accounts/' + AccountName + '/', json=datas, headers=headers)return response.text# 更新账户def account_update(self, AccountName):a = 'Token ' + self.tokenheaders = {'Content-Type': 'application/json', 'Authorization': a}  datas = {'password': '5999996', 'is_staff': 'true', 'storage': '1073741824'}response = self.session.put(begin_url + 'api2/accounts/' + AccountName + '/', json=datas, headers=headers)return response.text# 删除账户def account_delete(self, AccountName):a = 'Token ' + self.tokenheaders = {'Content-Type': 'application/json', 'Authorization': a}  response = self.session.delete(begin_url + 'api2/accounts/' + AccountName + '/', headers=headers)return response.textdef link_get(self):a = 'Token ' + self.tokenheaders = {'Content-Type': 'application/json', 'Authorization': a}  response = self.session.get(begin_url + 'api2/shared-links', headers=headers)return response.text# 查询所有库def repos_all(self):a = 'Token ' + self.tokenheaders = {'Authorization': a}  response = self.session.get(begin_url + 'api/v2.1/repos/', headers=headers)repos = {}for r in response.json()['repos']:repos.update({r['repo_name']: r['repo_id']})return repos# 增加库def repos_Insert(self, repos_name):a = 'Token ' + self.tokenheaders = {"Authorization": a, "Accept": "application/json; indent=4","content-type": "application/x-www-form-urlencoded"}  datas = {'name': repos_name, 'desc': 'new library'}response = self.session.post(begin_url + 'api2/repos/', headers=headers, data=datas)key = response.textreturn key.replace('"', '')# 删除库def repos_Delete(self, repos_id):a = 'Token ' + self.tokenheaders = {"Authorization": a, "Accept": "application/json; indent=4","content-type": "application/x-www-form-urlencoded"}  response = self.session.delete(begin_url + 'api2/repos/' + repos_id + '/', headers=headers)return response.text# 查询库/目录下的文件def file_all(self, repos_id, root_url):a = 'Token ' + self.tokenheaders = {'Content-Type': 'application/json', 'Authorization': a}  response = self.session.get(begin_url + 'api/v2.1/repos/' + repos_id + '/dir/?p=/{}&with_thumbnail=true'.format(root_url),headers=headers)repos = {}for r in response.json()['dirent_list']:repos_type = r['type']if repos_type not in repos:repos.update({repos_type: []})repos[repos_type].append(r['name'])return repos# 上传文件def file_Insert(self, repos_id, file_name, loca_file_url):a = 'Token ' + self.tokenheaders = {'Content-Type': 'application/json', 'Authorization': a}  r = self.session.get(begin_url + 'api2/repos/' + repos_id + '/upload-link/', headers=headers)key = r.text.replace('"', '')headers = {"Authorization": a}  file = {'file': (file_name, open(loca_file_url, 'rb')), 'parent_dir': '/'}response = self.session.post(key, files=file, headers=headers)return response.text# 上传目录def root_Insert(self, repos_id, root_name):a = 'Token ' + self.tokenheaders = {'Authorization': a}  data = {'operation': 'mkdir'}r = self.session.post(begin_url + 'api2/repos/' + repos_id + '/dir/?p=/{}'.format(root_name), data=data, headers=headers)return r.text# 文件更新def file_Update(self, repos_id, file_name, loca_file_url):a = 'Token ' + self.tokenheaders = {'Content-Type': 'application/json', 'Authorization': a}  r = self.session.get(begin_url + 'api2/repos/' + repos_id + '/update-link/?p=' + '/', headers=headers)key = r.text.replace('"', '')headers = {"Authorization": a}  file = {'file': (file_name, open(loca_file_url, 'rb')), 'parent_dir': '/', 'replace': 1,'target_file': '/' + file_name}response = self.session.post(key + '?ret-json=1', files=file, headers=headers)return response.text# 文件下载def file_DownLoad(self, repos_id, file_name):a = 'Token ' + self.tokenheaders = {"Authorization": a}  r = self.session.get(begin_url + 'api2/repos/' + repos_id + '/file/?p=/' + file_name, headers=headers)ret = Falsetry:# 分解目录路径和文件名dir_path = os.path.dirname(file_name)if not os.path.exists(dir_path):os.mkdir(dir_path)url = r.text.replace('"', '')target = self.session.get(url)f = open('DownLoad\\' + file_name, 'wb')# 将下载到的图片数据写入文件f.write(target.content)f.close()ret = Trueexcept Exception as e:print(e)finally:return ret, r.text# 文件重命名def root_Rename(self, repos_id, old_name, new_name):a = 'Token ' + self.tokenheaders = {"Authorization": a}  datas = {'operation': 'rename', 'newname': new_name}r = self.session.post(begin_url + 'api/v2.1/repos/' + repos_id + '/dir/?p=/' + old_name, headers=headers, data=datas)return r.text# 文件重命名def file_Rename(self, repos_id, old_name, new_name):a = 'Token ' + self.tokenheaders = {"Authorization": a}  datas = {'operation': 'rename', 'newname': new_name}r = self.session.post(begin_url + 'api/v2.1/repos/' + repos_id + '/file/?p=/' + old_name, headers=headers, data=datas)return r.text# 文件移动def file_Move(self, repos_id, file_url, file_name, target_repos_id, target_url):a = 'Token ' + self.tokenheaders = {"Authorization": a}  data = {"src_repo_id": repos_id, "src_parent_dir": file_url, "src_dirents": file_name,"dst_repo_id": target_repos_id,"dst_parent_dir": target_url}r = self.session.post(begin_url + 'api/v2.1/repos/sync-batch-move-item/', headers=headers, data=data)return r.text# 文件复制def file_Copy(self, repos_id, file_url, file_name, target_repos_id, target_url):a = 'Token ' + self.tokenheaders = {"Authorization": a}  data = {"src_repo_id": repos_id, "src_parent_dir": file_url, "src_dirents": file_name,"dst_repo_id": target_repos_id,"dst_parent_dir": target_url}r = self.session.post(begin_url + 'api/v2.1/repos/sync-batch-copy-item/', headers=headers, data=data)return r.json()# 文件删除def file_Delete(self, repos_id, file_url):a = 'Token ' + self.tokenheaders = {"Authorization": a, "Accept": "application/json; indent=4","content-type": "application/x-www-form-urlencoded"}  r = self.session.delete(begin_url + 'api2/repos/' + repos_id + '/file/?p=' + file_url, headers=headers)return r.text# 文件创建def file_Create(self, repos_id, file_url):a = 'Token ' + self.tokenheaders = {"Authorization": a, "Accept": "application/json; indent=4","content-type": "application/x-www-form-urlencoded"}  datas = {'operation': 'create'}r = self.session.post(begin_url + 'api2/repos/' + repos_id + '/file/?p=' + file_url, headers=headers, data=datas)return r.text# 文件历史查询def file_History(self, repos_id, file_url):a = 'Token ' + self.tokenheaders = {"Authorization": a, "Accept": "application/json; indent=4","content-type": "application/x-www-form-urlencoded"}  r = self.session.get(begin_url + 'api2/repos/' + repos_id + '/file/history/?p=' + file_url, headers=headers)return r.textif __name__ == '__main__':# token获得seafile = SeafileControl()print('token持续时长24小时，当前值为：', seafile.token)# 账户操作# accounts = seafile.account_all()# print(accounts)## for account in accounts:#     AccountMsg = seafile.account_msg(account['email'])#     print(AccountMsg)# links = seafile.link_get()# print(links)while True:repos_list = seafile.repos_all()print(repos_list)print('请选择您操作的方向：1为库操作，2为文件操作')menue = input()if menue == '1':print('请选择您要进行的操作：1为创建库、2为删除库')ch = input()if ch == '1':repos_name = input('新库名称：')back = seafile.repos_Insert(repos_name)print(back)elif ch == '2':repos_name = input('要删除的库名称：')repos_id = repos_list[repos_name]back = seafile.repos_Delete(repos_id)print(back)if menue == '2':print('需要对哪个库进行操作？')repos_name = input()repos_id = repos_list[repos_name]file_list = seafile.file_all(repos_id, '')print(file_list)while True:print('请选择您要进行的操作：0为创建空目录、1为上传文件、2为更新文件、3为下载文件、4为重命名文件、5为移动文件、6为拷贝文件、7为删除文件、8为创建文件(为空)、9为获取文件历史、10为查找目录文件、11为重命名目录')check = input()if check == '0':root_name = input('文件夹名：')back = seafile.root_Insert(repos_id, root_name)print(back)elif check == '1':file_name = input('文件名：')loca_file_url = input('文件地址：')back = seafile.file_Insert(repos_id, file_name, loca_file_url)print(back)elif check == '2':file_name = input('文件名：')loca_file_url = input('文件地址：')back = seafile.file_Update(repos_id, file_name, loca_file_url)print(back)elif check == '3':file_url = input('需要下载的文件名：')ret, back = seafile.file_DownLoad(repos_id, file_url)print(back)elif check == '4':old_name = input('旧文件名：')new_name = input('新文件名：')back = seafile.file_Rename(repos_id, old_name, new_name)print(back)elif check == '5':target_repos = input('目标库：')file_url = input('目标文件所在地址')file_name = input('目标文件').split('|')target_repos_id = repos_list[target_repos]target_url = input('目标目录：')back = seafile.file_Move(repos_id, file_url, file_name, target_repos_id, target_url)print(back)elif check == '6':target_repos = input('目标库：')file_url = input('目标文件所在地址')file_name = input('目标文件').split('|')target_repos_id = repos_list[target_repos]target_url = input('目标目录：')back = seafile.file_Copy(repos_id, file_url, file_name, target_repos_id, target_url)print(back)elif check == '7':file_url = input('需要删除的文件名：')back = seafile.file_Delete(repos_id, file_url)print(back)elif check == '8':file_url = input('需要创建的文件名(注意文件内容将为空)：')back = seafile.file_Create(repos_id, file_url)print(back)elif check == '9':file_url = input('需要查看的文件名：')back = seafile.file_History(repos_id, file_url)print(back)elif check == '10':root_url = input('查看目录：')back = seafile.file_all(repos_id, root_url)print(back)elif check == '11':old_name = input('旧目录名：')new_name = input('新目录名：')back = seafile.root_Rename(repos_id, old_name, new_name)print(back)else:breakprint('----------------- 操作分割线 -----------------')

这篇关于系统集成实战：seafile的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/635000。

相关文章

从原理到实战深入理解Java 断言assert

从原理到实战深入理解Java 断言assert

《从原理到实战深入理解Java断言assert》本文深入解析Java断言机制,涵盖语法、工作原理、启用方式及与异常的区别,推荐用于开发阶段的条件检查与状态验证,并强调生产环境应使用参数验证工具类替代... 目录深入理解 Java 断言（assert）：从原理到实战引言：为什么需要断言？一、断言基础1.1 语
阅读更多...
Java MQTT实战应用

Java MQTT实战应用

《JavaMQTT实战应用》本文详解MQTT协议,涵盖其发布/订阅机制、低功耗高效特性、三种服务质量等级（QoS0/1/2）,以及客户端、代理、主题的核心概念,最后提供Linux部署教程、Sprin... 目录一、MQTT协议二、MQTT优点三、三种服务质量等级四、客户端、代理、主题1. 客户端（Clien
阅读更多...
在Spring Boot中集成RabbitMQ的实战记录

在Spring Boot中集成RabbitMQ的实战记录

《在SpringBoot中集成RabbitMQ的实战记录》本文介绍SpringBoot集成RabbitMQ的步骤,涵盖配置连接、消息发送与接收,并对比两种定义Exchange与队列的方式:手动声明(... 目录前言准备工作1. 安装 RabbitMQ2. 消息发送者（Producer）配置1. 创建 Spr
阅读更多...
深度解析Spring Boot拦截器Interceptor与过滤器Filter的区别与实战指南

深度解析Spring Boot拦截器Interceptor与过滤器Filter的区别与实战指南

《深度解析SpringBoot拦截器Interceptor与过滤器Filter的区别与实战指南》本文深度解析SpringBoot中拦截器与过滤器的区别,涵盖执行顺序、依赖关系、异常处理等核心差异,并... 目录Spring Boot拦截器（Interceptor）与过滤器（Filter）深度解析：区别、实现
阅读更多...
深度解析Spring AOP @Aspect 原理、实战与最佳实践教程

深度解析Spring AOP @Aspect 原理、实战与最佳实践教程

《深度解析SpringAOP@Aspect原理、实战与最佳实践教程》文章系统讲解了SpringAOP核心概念、实现方式及原理,涵盖横切关注点分离、代理机制（JDK/CGLIB）、切入点类型、性能... 目录1. @ASPect 核心概念1.1 AOP 编程范式1.2 @Aspect 关键特性2. 完整代码实
阅读更多...
MySQL中的索引结构和分类实战案例详解

MySQL中的索引结构和分类实战案例详解

《MySQL中的索引结构和分类实战案例详解》本文详解MySQL索引结构与分类,涵盖B树、B+树、哈希及全文索引,分析其原理与优劣势,并结合实战案例探讨创建、管理及优化技巧,助力提升查询性能,感兴趣的朋... 目录一、索引概述1.1 索引的定义与作用1.2 索引的基本原理二、索引结构详解2.1 B树索引2.2
阅读更多...
从入门到精通MySQL 数据库索引(实战案例)

从入门到精通MySQL 数据库索引(实战案例)

《从入门到精通MySQL数据库索引(实战案例)》索引是数据库的目录,提升查询速度,主要类型包括BTree、Hash、全文、空间索引,需根据场景选择,建议用于高频查询、关联字段、排序等,避免重复率高或... 目录一、索引是什么？能干嘛？核心作用：二、索引的 4 种主要类型（附通俗例子）1. BTree 索引（
阅读更多...
Java Web实现类似Excel表格锁定功能实战教程

Java Web实现类似Excel表格锁定功能实战教程

《JavaWeb实现类似Excel表格锁定功能实战教程》本文将详细介绍通过创建特定div元素并利用CSS布局和JavaScript事件监听来实现类似Excel的锁定行和列效果的方法,感兴趣的朋友跟随... 目录1. 模拟Excel表格锁定功能2. 创建3个div元素实现表格锁定2.1 div元素布局设计2.
阅读更多...
Redis 配置文件使用建议redis.conf 从入门到实战

Redis 配置文件使用建议redis.conf 从入门到实战

《Redis配置文件使用建议redis.conf从入门到实战》Redis配置方式包括配置文件、命令行参数、运行时CONFIG命令,支持动态修改参数及持久化,常用项涉及端口、绑定、内存策略等,版本8... 目录一、Redis.conf 是什么？二、命令行方式传参（适用于测试）三、运行时动态修改配置（不重启服务
阅读更多...
Python并行处理实战之如何使用ProcessPoolExecutor加速计算

Python并行处理实战之如何使用ProcessPoolExecutor加速计算

《Python并行处理实战之如何使用ProcessPoolExecutor加速计算》Python提供了多种并行处理的方式,其中concurrent.futures模块的ProcessPoolExecu... 目录简介完整代码示例代码解释1. 导入必要的模块2. 定义处理函数3. 主函数4. 生成数字列表5.
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2