# 上传用户文件
class UPfile(APIView):
permission_classes = (IsAuthenticated,)
def post(self, request):
global name
upload_file = request.FILES.get('file_name', None)
up_file_name = upload_file.name
user_obj = request.user
file_path = os.path.join(settings.MEDIA_ROOT, str(user_obj.id) + up_file_name)
# engine = create_engine('mysql+pymysql://root:root@172.17.0.100:3306/data_{0}?charset=utf8'.format(user_obj.id))
engine = create_engine('mysql+pymysql://root:Datahoop&&21374****dksi@10.0.1.12:3306/data_{0}?charset=utf8'.format(user_obj.id))
with open(file_path, 'wb') as f:
for chunk in upload_file.chunks():
f.write(chunk)
if upload_file is None:
os.remove(file_path)
return Response({'msg': '数据格式不正确请检查数据', 'status': False})
# 以下为检查用户上传的数据是否超过所拥有的上传数据大小
# 上传文件的大小
filesize = round((upload_file.size) / 1024, 2)
if filesize > UPLOAD_FILE_SIZE:
return Response({'msg': '上传数据超出10Mb限制,无法上传!', 'status': False})
# 获取该用户所有文件的大小
mydata_id = DataSource.objects.filter(user_id=user_obj.id)
myData_size = 0
for i in mydata_id:
try:
x = i.fileSize.replace("KB", '')
myData_size += float(x)
except:
continue
myData_size = round(myData_size, 2) # 单位KB
# 该用户即将上传文件加本身有的大小
now_userDataSize = filesize + myData_size
# 查找用户所限制文件上传容量的大小
lelvel_id = UsersToLevels.objects.get(user_id=user_obj.id).level_id
size = RightsLevels.objects.filter(level_id=lelvel_id, right_id=8)[0].restrict # 100数据库
# size = RightsLevels.objects.filter(level_id=lelvel_id, right_id=2)[0].restrict # 线上数据库
if size[-1] == 'G':
size = int(size[:-1]) * 1024
else:
size = int(size[:-1])
try:
mystorage = MyStorage.objects.get(user=user_obj.id)
if mystorage:
# user_
数据库name字段设置的太小了,然而你的数据太长了超过了限制,修改数据表name的类型为text就可以了