- add clouds

- bug fixes and other minor improvements

Author: aminyazdanpanah

.appveyor.yml

@@ -8,14 +8,9 @@ clone_folder: c:\projects\project-code
 cache:
   - c:\ProgramData\chocolatey\bin -> .appveyor.yml
   - c:\ProgramData\chocolatey\lib -> .appveyor.yml
-  - c:\ProgramData\ComposerSetup -> .appveyor.yml
-  - c:\tools\php -> .appveyor.yml
 
 environment:
   global:
-    COMPOSER_NO_INTERACTION: 1
-    ANSICON: 121x90 (121x90) # Console colors
-
   ffmpeg_download: https://ffmpeg.zeranoe.com/builds/win64/static/ffmpeg-20190225-f948082-win64-static.zip
 
   matrix:

.github/lock.yml

@@ -0,0 +1,36 @@
+
+# Configuration for Lock Threads - https://github.com/dessant/lock-threads
+
+# Number of days of inactivity before a closed issue or pull request is locked
+daysUntilLock: 30
+
+# Skip issues and pull requests created before a given timestamp. Timestamp must
+# follow ISO 8601 (`YYYY-MM-DD`). Set to `false` to disable
+skipCreatedBefore: false
+
+# Issues and pull requests with these labels will be ignored. Set to `[]` to disable
+exemptLabels: []
+
+# Label to add before locking, such as `outdated`. Set to `false` to disable
+lockLabel: false
+
+# Comment to post before locking. Set to `false` to disable
+lockComment: false
+
+# Assign `resolved` as the reason for locking. Set to `false` to disable
+setLockReason: false
+
+# Limit to only `issues` or `pulls`
+# only: issues
+
+# Optionally, specify configuration settings just for `issues` or `pulls`
+# issues:
+#   exemptLabels:
+#     - help-wanted
+#   lockLabel: outdated
+
+# pulls:
+#   daysUntilLock: 30
+
+# Repository to extend settings from
+# _extends: repo

examples/clouds/aws_cloud.py

@@ -0,0 +1,64 @@
+"""
+examples.clouds.aws_cloud
+~~~~~~~~~~~~
+
+Open a file from a Amazon S3 cloud and save dash files to it
+
+
+:copyright: (c) 2019 by Amin Yazdanpanah.
+:website: https://www.aminyazdanpanah.com
+:email: [email protected]
+:license: MIT, see LICENSE for more details.
+"""
+
+import argparse
+import sys
+
+import ffmpeg_streaming
+from ffmpeg_streaming import AWS
+
+
+def aws_cloud(bucket_name, key):
+    cloud = AWS(aws_access_key_id='YOUR_KEY_ID', aws_secret_access_key='YOUR_KEY_SECRET')
+    download_options = {
+        'bucket_name': bucket_name,
+        'key': key,
+    }
+    upload_options = {
+        'bucket_name': bucket_name,
+    }
+
+    from_aws_cloud = (cloud, download_options, None)
+    to_aws_cloud = (cloud, upload_options)
+
+    return from_aws_cloud, to_aws_cloud
+
+
+def transcode_progress(percentage, ffmpeg, media):
+    # You can update a field in your database
+    # You can also create a socket connection and show a progress bar to users
+    sys.stdout.write("\rTranscoding...(%s%%)[%s%s]" % (percentage, '#' * percentage, '-' * (100 - percentage)))
+    sys.stdout.flush()
+
+
+def main():
+    parser = argparse.ArgumentParser()
+
+    parser.add_argument('-b', '--bucket_name', required=True, help='Bucket name (required).')
+    parser.add_argument('-k', '--key', required=True, help='Key name (required)')
+
+    args = parser.parse_args()
+
+    from_aws_cloud, to_aws_cloud = aws_cloud(args.bucket_name, args.key)
+
+    (
+        ffmpeg_streaming
+            .dash(from_aws_cloud, adaption='"id=0,streams=v id=1,streams=a"')
+            .format('libx265')
+            .auto_rep()
+            .package('/var/www/media/stream.mpd', to_aws_cloud, transcode_progress)
+    )
+
+
+if __name__ == "__main__":
+    sys.exit(main())

examples/clouds/azure_cloud.py

@@ -0,0 +1,65 @@
+"""
+examples.clouds.azure_clod
+~~~~~~~~~~~~
+
+Open a file from a Microsoft Azure cloud and save hls files to it
+
+
+:copyright: (c) 2019 by Amin Yazdanpanah.
+:website: https://www.aminyazdanpanah.com
+:email: [email protected]
+:license: MIT, see LICENSE for more details.
+"""
+
+import argparse
+import sys
+
+import ffmpeg_streaming
+from ffmpeg_streaming import MicrosoftAzure
+
+
+def azure_cloud(container, blob):
+    cloud = MicrosoftAzure(account_name='account_name', account_key='account_key')
+
+    download_options = {
+        'container': container,
+        'blob': blob
+    }
+    upload_options = {
+        'container': container,
+    }
+
+    from_azure_cloud = (cloud, download_options, None)
+    to_azure_cloud = (cloud, upload_options)
+
+    return from_azure_cloud, to_azure_cloud
+
+
+def transcode_progress(percentage, ffmpeg, media):
+    # You can update a field in your database
+    # You can also create a socket connection and show a progress bar to users
+    sys.stdout.write("\rTranscoding...(%s%%)[%s%s]" % (percentage, '#' * percentage, '-' * (100 - percentage)))
+    sys.stdout.flush()
+
+
+def main():
+    parser = argparse.ArgumentParser()
+
+    parser.add_argument('-c', '--container', required=True, help='Bucket name (required).')
+    parser.add_argument('-b', '--blob', required=True, help='Key name (required)')
+
+    args = parser.parse_args()
+
+    from_azure_cloud, to_azure_cloud = azure_cloud(args.container, args.blob)
+
+    (
+        ffmpeg_streaming
+            .hls(from_azure_cloud)
+            .format('libx264')
+            .auto_rep()
+            .package(clouds=to_azure_cloud, progress=transcode_progress)
+    )
+
+
+if __name__ == "__main__":
+    sys.exit(main())

examples/clouds/cloud.py

@@ -0,0 +1,64 @@
+"""
+examples.clouds.cloud
+~~~~~~~~~~~~
+
+Open a file from a cloud and save dash files to it
+
+
+:copyright: (c) 2019 by Amin Yazdanpanah.
+:website: https://www.aminyazdanpanah.com
+:email: [email protected]
+:license: MIT, see LICENSE for more details.
+"""
+
+import sys
+
+import ffmpeg_streaming
+from ffmpeg_streaming import Cloud
+
+
+def download_progress(percentage, downloaded, total):
+    # You can update a field in your database
+    # You can also create a socket connection and show a progress bar to users
+    sys.stdout.write("\rDownloading...(%s%%)[%s%s]" % (percentage, '#' * percentage, '-' * (100 - percentage)))
+    sys.stdout.flush()
+
+
+def transcode_progress(percentage, ffmpeg, media):
+    # You can update a field in your database
+    # You can also create a socket connection and show a progress bar to users
+    sys.stdout.write("\rTranscoding...(%s%%)[%s%s]" % (percentage, '#' * percentage, '-' * (100 - percentage)))
+    sys.stdout.flush()
+
+
+def main():
+    cloud = Cloud()
+    download_options = {
+        'url': 'https://www.aminyazdanpanah.com/my_sweetie.mp4',
+        'progress': download_progress
+    }
+    upload_options = {
+        'url': 'https://localhost:8000/api/upload',
+        'method': 'post',
+        'auth': ('username', 'password'),
+        'headers': {
+            'User-Agent': 'Mozilla/5.0 (compatible; AminYazdanpanahBot/1.0; +http://aminyazdanpanah.com/bots)',
+            'Accept': 'application/json',
+            'Authorization': 'Bearer ACCESS_TOKEN'
+        }
+    }
+
+    from_cloud = (cloud, download_options, None)
+    to_cloud = (cloud, upload_options)
+
+    (
+        ffmpeg_streaming
+            .dash(from_cloud, adaption='"id=0,streams=v id=1,streams=a"')
+            .format('libx265')
+            .auto_rep()
+            .package('/var/www/media/stream.mpd', to_cloud, transcode_progress)
+    )
+
+
+if __name__ == "__main__":
+    sys.exit(main())

examples/clouds/custom_cloud.py

@@ -0,0 +1,67 @@
+"""
+examples.clouds.cloud
+~~~~~~~~~~~~
+
+Open a file from a custom cloud and save dash files to it
+
+
+:copyright: (c) 2019 by Amin Yazdanpanah.
+:website: https://www.aminyazdanpanah.com
+:email: [email protected]
+:license: MIT, see LICENSE for more details.
+"""
+
+import sys
+
+import ffmpeg_streaming
+from ffmpeg_streaming import Clouds
+
+
+class CustomCloud(Clouds):
+
+    def upload_directory(self, directory, **options):
+        # @TODO: upload a directory to a cloud
+        pass
+
+    def download(self, filename=None, **options):
+        # @TODO: download a file to a local path
+        pass
+
+
+def custom_cloud():
+
+    cloud = CustomCloud()
+    download_options = {
+        'YOUR_OPTIONS': 'my_sweetie.mp4',
+    }
+    upload_options = {
+        'YOUR_OPTIONS': 'my_sweetie.mp4',
+    }
+
+    from_custom_cloud = (cloud, download_options, None)
+    to_custom_cloud = (cloud, upload_options)
+
+    return from_custom_cloud, to_custom_cloud
+
+
+def transcode_progress(percentage, ffmpeg, media):
+    # You can update a field in your database
+    # You can also create a socket connection and show a progress bar to users
+    sys.stdout.write("\rTranscoding...(%s%%)[%s%s]" % (percentage, '#' * percentage, '-' * (100 - percentage)))
+    sys.stdout.flush()
+
+
+def main():
+    from_custom_cloud, to_custom_cloud = custom_cloud()
+
+    (
+        ffmpeg_streaming
+            .dash(from_custom_cloud, adaption='"id=0,streams=v id=1,streams=a"')
+            .format('libx265')
+            .auto_rep()
+            .package(clouds=to_custom_cloud, progress=transcode_progress)
+    )
+
+
+if __name__ == "__main__":
+    sys.exit(main())

examples/clouds/google_cloud.py

@@ -0,0 +1,63 @@
+"""
+examples.clouds.google_cloud
+~~~~~~~~~~~~
+
+Open a file from a google cloud and save hls files to it
+
+
+:copyright: (c) 2019 by Amin Yazdanpanah.
+:website: https://www.aminyazdanpanah.com
+:email: [email protected]
+:license: MIT, see LICENSE for more details.
+"""
+
+import argparse
+import sys
+
+import ffmpeg_streaming
+from ffmpeg_streaming import GoogleCloudStorage
+
+
+def google_cloud(bucket_name, object_name):
+    cloud = GoogleCloudStorage(bucket_name)
+    download_options = {
+        'object_name': object_name,
+    }
+    upload_options = {
+        'encryption': 'SOME_BASE64_ENCRYPTION',
+    }
+
+    from_google_cloud = (cloud, download_options, None)
+    to_google_cloud = (cloud, upload_options)
+
+    return from_google_cloud, to_google_cloud
+
+
+def transcode_progress(percentage, ffmpeg, media):
+    # You can update a field in your database
+    # You can also create a socket connection and show a progress bar to users
+    sys.stdout.write("\rTranscoding...(%s%%)[%s%s]" % (percentage, '#' * percentage, '-' * (100 - percentage)))
+    sys.stdout.flush()
+
+
+def main():
+    parser = argparse.ArgumentParser()
+
+    parser.add_argument('-b', '--bucket_name', required=True, help='Bucket name (required).')
+    parser.add_argument('-o', '--object_name', required=True, help='object name (required).')
+
+    args = parser.parse_args()
+
+    from_google_cloud, to_google_cloud = google_cloud(args.bucket_name, args.object_name)
+
+    (
+        ffmpeg_streaming
+            .hls(from_google_cloud)
+            .format('libx264')
+            .auto_rep()
+            .package('/var/www/media/stream.mpd', to_google_cloud, transcode_progress)
+    )
+
+
+if __name__ == "__main__":
+    sys.exit(main())