#!/usr/bin/env python
# -*- coding: utf-8 -*-
# Created on 2018-09-01 19:02
import requests
from qiniu import Auth, put_file, etag
import qiniu.config
import config
# 网站上的access_key和secret_key，保密
q = Auth(config.ACCESS_KEY, config.SECRET_KEY)
# 在七牛云网站上创建的存储空间名称
bucket_name = config.BUCKET_NAME
bucket = qiniu.BucketManager(q)
def upload_file():
"""
上传文件
"""
# 上传到云空间时的文件名称
# 该名称不能重复，如果重复了话，后面的不会覆盖前面的，也是直接消失了，但还是会返回200
# 可以上传文件
# 之前一直疑惑，为什么上传后没有返回文件的访问链接，看了下七牛云的外链后发现格式组成是
# url + filename
# url可以自己绑定域名，如果没有，那么就是默认的"http://ped06svnz.bkt.clouddn.com/"
# 例如上传的是aa.txt文件，那么访问就是 http://ped06svnz.bkt.clouddn.com/aa.txt方式
file_name = 'bi.jpg'
# 本地路径
localfile = '../../image/bi.jpg'
# 生成上传的token，可以指定过期时间
token = q.upload_token(bucket_name, file_name, 3600)
print('token =', token)
# 上传文件
ret, info = put_file(token, file_name, localfile)
print('info =', info)
print('ret =', ret)
def state():
"""
获取文件信息
"""
file_name = 'logo.jpg'
ret, info = bucket.stat(bucket_name, file_name)
print(ret)
print(info)
def filelist():
"""
获取文件列表
"""
# 文件名的前缀，默认为None，即全部
prefix = None
# 文件数量限制
limit = 2
# 指定目录分隔符
delimiter = None
# 列举标识符
# 没懂这两个什么意思
marker = None
# info是ResponseInfo对象
# ret是一个dict，里面的每项数据主要包括:
# {'key': 'aa.txt', 'hash': 'FkX3SBTMZBMQwzjoflXoVYNRqzTf', 'fsize': 2895,
# 'mimeType': 'text/plain', 'putTime': 15358025593369914, 'type': 0, 'status': 0}
ret, eof, info = bucket.list(bucket_name, prefix, marker, limit, delimiter)
class FileItem(object):
def __init__(self, item):
# 文件名
self.key = item['key']
self.hash = item['hash']
# 文件大小
self.fsize = item['fsize']
self.mimeType = item['mimeType']
self.putTime = item['putTime']
self.type = item['type']
self.status = item['status']
def __str__(self):
return self.key
__repr__ = __str__
items = ret['items']
fileitems = []
for item in items:
fileitems.append(FileItem(item))
print(fileitems)
def download_file():
"""
私有空间下载
"""
filename = 'logo.jpg'
# 下载的话，也是需要知道文件名
base_url = '{0}/{1}'.format(config.BUCKET_DOMAIN, filename)
private_url = q.private_download_url(base_url, 3600)
# 直接使用base_url也是可行的
# private_url = base_url
print('private_url =', private_url)
r = requests.get(private_url)
with open(filename, 'wb') as fp:
fp.write(r.content)
def fetch_file():
"""
从网络抓取资源到云存储中
"""
# 网络资源的url
file_url = 'http://img.qikula.com/file/image/pic/2a1514549676n434241896c27.jpg'
# 截取文件名称
file_name = file_url.split('/')[-1]
# 上传
ret, info = bucket.fetch(file_url, bucket_name, file_name)
print(ret)
print(info)
def move_file():
"""
移动文件\重命名文件
如果传入的两个bucket_name是同一个名字，那么就相当于重命名了
你可以在云存储上创建多个bucket，然后将文件从一个移动到另一个
"""
bucket_name2 = config.BUCKET_NAME
filename = 'logo.jpg'
filename2 = 'logo2.jpg'
# 前面两个参数是src
# 后面是dest
ret, info = bucket.move(bucket_name, filename, bucket_name2, filename2)
# copy函数，传参一样，复制一个文件
print(ret)
print(info)
def delete_file():
"""
删除文件
如果文件不存在，则会返回 status_code:612, text_body:{"error":"no such file or directory"}
"""
filename = 'logo2.jpg'
ret, info = bucket.delete(bucket_name, filename)
print(ret)
print(info)
def update_deleted_days():
"""
更新文件被删除的时间
"""
filename = 'bi.jpg'
days = '1'
# 更新后，在网站上没有看到特殊标识
ret, info = bucket.delete_after_days(bucket_name, filename, days)
print(ret)
print(info)
# 批量操作
def batch():
"""
七牛提供的批量操作
"""
# 1.重命名
# 如果文件不存在，返回612（key）
# 如果文件已经存在，返回298（value）
keys = {'logo1.jpg': 'logo.jpg', 'aa.txt': 'bb.txt'}
ops = qiniu.build_batch_rename(bucket_name, keys)
ret, info = bucket.batch(ops) # ret的值为None info是ResponseInfo对象
# 2.批量查询
keys = ['logo.jpg', 'bb.txt', 'dd.png']
ops = qiniu.build_batch_stat(bucket_name, keys)
# 返回的info数据中，包含了下列值
# {"code":200,"data":{"fsize":2895,"hash":"FkX3SBTMZBMQwzjoflXoVYNRqzTf","md5":"noJ5jsvEamFj2xQ3+YxyFg==",
# "mimeType":"text/plain","putTime":15358109983825052,"type":0}}
ret, info = bucket.batch(ops)
# 3.批量移动
# force的意思是，如果target_bucket中有同名的文件，是否强制覆盖
# qiniu.build_batch_move(source_bucket,keys,target_bucket,force=True)
# 4.批量删除
qiniu.build_batch_delete(bucket_name, keys)
# 5.批量复制
# force的意思是，如果target_bucket中有同名的文件，是否强制覆盖
# qiniu.build_batch_copy(source_bucket,keys,target_bucket,force=True)
pass
if __name__ == '__main__':
# upload_file()
# state()
filelist()
# download_file()
# fetch_file()
# move_file()
# delete_file()
# update_deleted_days()
# batch()
pass
ResponseInfo类的主要数据:
class ResponseInfo(object):
"""七牛HTTP请求返回信息类
该类主要是用于获取和解析对七牛发起各种请求后的响应包的header和body。
Attributes:
status_code: 整数变量，响应状态码
text_body: 字符串变量，响应的body
req_id: 字符串变量，七牛HTTP扩展字段，参考 http://developer.qiniu.com/docs/v6/api/reference/extended-headers.html
x_log: 字符串变量，七牛HTTP扩展字段，参考 http://developer.qiniu.com/docs/v6/api/reference/extended-headers.html
error: 字符串变量，响应的错误内容
"""
参考
https://developer.qiniu.com/kodo/sdk/1242/python
https://developer.qiniu.com/dora