基礎(chǔ)環(huán)境

# +++++ 阿里云oss開發(fā)指南里都有詳細的步驟，在這里整理了一下自己需要的東西

# 確定開發(fā)環(huán)境，centos默認安裝了python2.7

# python -v

# 安裝python開發(fā)包

# yum install -y python-devel

# 安裝oss的sdk

# yum install -y python-pip

# pip2.7 install oss2

# 驗證oss2是否安裝正確

'''

>>> import oss2

>>> oss2.__version__

'2.6.0'

'''

# 驗證oss擴展庫crcmod是否安裝

'''

在python環(huán)境中，輸入一下內(nèi)容，如果有錯誤信息，則說明擴展庫安裝不成功，默認安裝oss2的時候會安裝擴展庫

>>> import crcmod._crcfunext

如果出現(xiàn)安裝不成功，則按一下步驟安裝：

1、執(zhí)行以下命令卸載crcmod

# pip uninstall crcmod

2、安裝python-devel

3、執(zhí)行以下命令重新安裝crcmod

# pip install crcmod

'''

小文件上傳

#!/usr/bin/env python

# -*- coding: utf-8 -*-

import oss2

# 阿里云主賬號accesskey擁有所有api的訪問權(quán)限，風險很高。強烈建議您創(chuàng)建并使用ram賬號進行api訪問或日常運維，請登錄 https://ram.console.aliyun.com 創(chuàng)建ram賬號。

auth = oss2.auth('', '')

# endpoint以杭州為例，其它region請按實際情況填寫。

bucket = oss2.bucket(auth, 'http://oss-cn-hangzhou.aliyuncs.com', '')

# 必須以二進制的方式打開文件，因為需要知道文件包含的字節(jié)數(shù)。

with open('', 'rb') as fileobj:

# seek方法用于指定從第1000個字節(jié)位置開始讀寫。上傳時會從您指定的第1000個字節(jié)位置開始上傳，直到文件結(jié)束。

fileobj.seek(1000, os.seek_set)

# tell方法用于返回當前位置。

current = fileobj.tell()

bucket.put_object('', fileobj)

分片上傳

# -*- coding: utf-8 -*-import os

from oss2 import sizedfileadapter, determine_part_size

from oss2.models import partinfo

import oss2

# 阿里云主賬號accesskey擁有所有api的訪問權(quán)限，風險很高。強烈建議您創(chuàng)建并使用ram賬號進行api訪問或日常運維，請登錄 https://ram.console.aliyun.com 創(chuàng)建ram賬號。

auth = oss2.auth('', '')

# endpoint以杭州為例，其它region請按實際情況填寫。

bucket = oss2.bucket(auth, 'http://oss-cn-hangzhou.aliyuncs.com', '')

key = ''

filename = ''

total_size = os.path.getsize(filename)

# determine_part_size方法用來確定分片大小。

part_size = determine_part_size(total_size, preferred_size=100 * 1024)

# 初始化分片。

upload_id = bucket.init_multipart_upload(key).upload_id

parts = []

# 逐個上傳分片。

with open(filename, 'rb') as fileobj:

part_number = 1

offset = 0

while offset < total_size:

num_to_upload = min(part_size, total_size - offset)

# sizedfileadapter(fileobj, size)方法會生成一個新的文件對象，重新計算起始追加位置。

result = bucket.upload_part(key, upload_id, part_number,

sizedfileadapter(fileobj, num_to_upload))

parts.append(partinfo(part_number, result.etag))

offset += num_to_upload

part_number += 1

# 完成分片上傳。

bucket.complete_multipart_upload(key, upload_id, parts)

# 驗證分片上傳。

with open(filename, 'rb') as fileobj:

assert bucket.get_object(key).read() == fileobj.read()

以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持萬仟網(wǎng)。

如您對本文有疑問或者有任何想說的，請點擊進行留言回復，萬千網(wǎng)友為您解惑！

總結(jié)

以上是生活随笔為你收集整理的python 上传文件到网络设备_基于python实现上传文件到OSS代码实例的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。