懂Python的大佬帮看下如何改造天翼云盘 CLI Python项目

ddane

项目：https://github.com/Aruelius/cloud189

这个你们熟悉吧，想改造如下造福MJJ

场景：
本地文件夹：D:\mjj,下有1.txt、2.txt两个文件


执行命令：python main.py upload -f D:\mjj（上传D:\mjj文件夹）
希望实现：
上传 D:\mjj\1.txt 完成
删除 D:\mjj\1.txt 完成
上传 D:\mjj\2.txt 完成
删除 D:\mjj\2.txt 完成

如此一来就可以实现小鸡搬运百度网盘资源到天翼网盘了。

求助：始终找不到单文件（ D:\mjj\1.txt）的上传指令在哪个位置，他好像是上传完整个文件夹才结束，我加删除命令直接删除整个本地文件夹了，不能实现实时上传单文件，实时删除单文件。

老少爷们们出出主意呗。删除命令应该加哪里，MJJ需要这个啊

文件夹上传代码段：

1.     def upload_dir(self, folder_path, parrent_fid=-11, force=False, mkdir=True, callback=None,
   
2.                    failed_callback=None, up_handler= None):
   
3.         """文件夹上传接口
   
4.         :param str file_path: 待上传文件路径
   
5.         :param int folder_id: 上传目录 id
   
6.         :param bool force: 强制上传已经存在的文件(文件名、大小一致的文件)
   
7.         :param bool mkdir: 是否在 parrent_fid 创建父文件夹
   
8.         :param func callback: 上传进度回调
   
9.         :param func failed_callback: 错误回调
   
10.         :param func up_handler: 上传文件数回调
    
11.         :return: UpCode list  or  Cloud189 error code(mkdir error)
    
12.         """
    
13.         if not os.path.isdir(folder_path):
    
14.             logger.error(f"Upload dir: [{folder_path}] is not a file")
    
15.             return UpCode(Cloud189.PATH_ERROR)
    
16. 
    
17.         dir_dict = {}
    
18.         logger.debug(f'Upload dir: start parsing {folder_path=} structure...')
    
19.         upload_files = []
    
20.         folder_name = get_file_name(folder_path)
    
21.         if mkdir:
    
22.             result = self.mkdir(parrent_fid, folder_name)
    
23.             if result.code != Cloud189.SUCCESS:
    
24.                 return result  # MkCode
    
25. 
    
26.             dir_dict[folder_name] = result.id
    
27.         else:
    
28.             dir_dict[folder_name] = parrent_fid
    
29. 
    
30.         for home, dirs, files in os.walk(folder_path):
    
31.             for _file in files:
    
32.                 f_path = home + os.sep + _file
    
33.                 f_rfolder = get_relative_folder(f_path, folder_path)
    
34.                 logger.debug(f"Upload dir: {f_rfolder=}, {f_path=}, {folder_path=}")
    
35.                 if f_rfolder not in dir_dict:
    
36.                     dir_dict[f_rfolder] = ''
    
37.                 upload_files.append((f_path, dir_dict[f_rfolder]))
    
38.             for _dir in dirs:
    
39.                 p_rfolder = get_relative_folder(
    
40.                     home, folder_path, is_file=False)
    
41.                 logger.debug(f"Upload dir: {p_rfolder=}, {home=}, {folder_path=}")
    
42.                 dir_rname = p_rfolder + os.sep + _dir  # 文件夹相对路径
    
43. 
    
44.                 result = self.mkdir(dir_dict[p_rfolder], _dir)
    
45.                 if result.code != Cloud189.SUCCESS:
    
46.                     logger.error(
    
47.                         f"Upload dir: create a folder in the upload sub folder{dir_rname=} failed! {folder_name=}, {dir_dict[p_rfolder]=}")
    
48.                     return result  # MkCode
    
49.                 logger.debug(
    
50.                     f"Upload dir: folder successfully created {folder_name=}, {dir_dict[p_rfolder]=}, {dir_rname=}, {result.id}")
    
51.                 dir_dict[dir_rname] = result.id
    
52.         up_codes = []
    
53.         total_files = len(upload_files)
    
54.         for index, upload_file in enumerate(upload_files, start=1):
    
55.             if up_handler:
    
56.                 up_handler(index, total_files)
    
57.             logger.debug(f"Upload dir: file [{upload_file[0]}] enter upload process...")
    
58.             up_code = self.upload_file(upload_file[0], upload_file[1], force=force, callback=callback)
    
59.             if failed_callback and up_code.code != Cloud189.SUCCESS:
    
60.                 failed_callback(up_code.code, up_code.path)
    
61.                 logger.debug(f"Up Dir Code: {up_code.code=}, {up_code.path=}")
    
62.             up_codes.append(up_code)
    
63.             logger.debug(f"Dir: {index=}, {total_files=}")
    
64.         return up_codes

复制代码

似毛非毛

“def upload_dir” 上面一段函数。不就是

"""单个文件上传接口

https://github.com/Aruelius/cloud189/blob/a6765d1dbae47106f522f7af024716603229c50f/cloud189/api/core.py#L651

惜为伊人醉

天翼云盘挂载本地WebDAV 能上传吗

ddane

似毛非毛 发表于 2020-12-27 17:05
“def upload_dir” 上面一段函数。不就是

"""单个文件上传接口

单个文件上传接口我知道，这个就意味着执行上传命令的时候有100个文件就需要执行100次命令了，其实上传文件夹的时候也是一个一个文件的上传，在单文件结束时候加入删除命令就可以了，这样只需要执行一个命令

ddane

惜为伊人醉 发表于 2020-12-27 17:09
天翼云盘挂载本地WebDAV 能上传吗

这个没有试过啊

似毛非毛

ddane 发表于 2020-12-27 17:17
单个文件上传接口我知道，这个就意味着执行上传命令的时候有100个文件就需要执行100次命令了，其实上传文 ...

他这好像分客户端模式。和网页模式。你要改哪个模式

ddane

似毛非毛 发表于 2020-12-27 17:33
他这好像分客户端模式。和网页模式。你要改哪个模式

我是在win下登录账号方式使用，应该是客户端模式吧

FrozenAngels

ddane 发表于 2020-12-27 17:17
单个文件上传接口我知道，这个就意味着执行上传命令的时候有100个文件就需要执行100次命令了，其实上传文 ...

几个循环的事情啊，而且你这上传也是去循环的upload_file函数。
要不你改改创个upload_dir_and_delete()?

似毛非毛

https://github.com/Aruelius/cloud189/blob/a6765d1dbae47106f522f7af024716603229c50f/cloud189/api/core.py#L550

550行后面回车加个：
os.remove(up_info.path)

试试？

ddane

似毛非毛 发表于 2020-12-27 17:43
https://github.com/Aruelius/cloud189/blob/a6765d1dbae47106f522f7af024716603229c50f/cloud189/api/core ...

完美

感谢大佬