commands/management/commands/qiniuuncompressed.py

@@ -0,0 +1,38 @@

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

                +
              

                +import os
              

                +
              

                +from django_six import CompatibilityBaseCommand
              

                +
              

                +from utils.qiniucdn import upload_file_path
              

                +
              

                +
              

                +class Command(CompatibilityBaseCommand):
              

                +    def handle(self, *args, **options):
              

                +
              

                +        dirs = ['media/user/member_activity/7YmTP98A9qBdtTg5VdxTv5/contribution/edbFSK5', 'media/qn/test']
              

                +
              

                +        for dir in dirs:
              

                +            try:
              

                +                files = os.listdir(dir)
              

                +            except Exception as e:
              

                +                print(e)
              

                +                continue
              

                +
              

                +            for file in files:
              

                +                print(file)
              

                +                ext = file.split('.')[-1]
              

                +                if not ext:
              

                +                    continue
              

                +                if ext.lower() not in ['jpg', 'jpeg', 'png', 'heic']:
              

                +                    continue
              

                +                try:
              

                +                    file_path = '{}/{}'.format(dir, file)
              

                +                    if os.path.exists(file_path):
              

                +                        qiniu_key = 'uncompressed/{}'.format(file_path)
              

                +                        # print(file_path)
              

                +                        # print(qiniu_key)
              

                +                        upload_file_path(file_path, key=qiniu_key, bucket='tamron', compress=False)
              

                +                        os.remove(file_path)
              

                +                except Exception:
              

                +                    pass