clouds

Author: aminyazdanpanah

examples/_example.mp4

@@ -0,0 +1,40 @@
+import argparse
+import sys
+import ffmpeg_streaming
+
+from ffmpeg_streaming.from_clouds import from_url
+
+
+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():
+    parser = argparse.ArgumentParser()
+
+    parser.add_argument('-url', '--url', required=True, help='The URL to the video file.')
+    parser.add_argument('-o', '--output', required=True, help='The output to write files.')
+
+    args = parser.parse_args()
+
+    (
+        ffmpeg_streaming
+            .dash(from_url(args.url, progress=download_progress), adaption='"id=0,streams=v id=1,streams=a"')
+            .format('libx265')
+            .auto_rep()
+            .package(args.output, transcode_progress)
+    )
+
+
+if __name__ == "__main__":
+    sys.exit(main())

examples/dash-from_url.py

@@ -0,0 +1,31 @@
+import argparse
+import sys
+import ffmpeg_streaming
+
+
+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('-i', '--input', required=True, help='The path to the video file (required).')
+    parser.add_argument('-o', '--output', default=None, help='The output to write files.')
+
+    args = parser.parse_args()
+
+    (
+        ffmpeg_streaming
+            .dash(args.input, adaption='"id=0,streams=v id=1,streams=a"')
+            .format('libx265')
+            .auto_rep()
+            .package(args.output, transcode_progress)
+    )
+
+
+if __name__ == "__main__":
+    sys.exit(main())

examples/dash.py

@@ -1,37 +1,37 @@
-import os
+import argparse
 import sys
 import ffmpeg_streaming
+
 from ffmpeg_streaming import Representation
 
 
-def progress(percentage, ffmpeg, media):
+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("\r Transcoding... (%s%%)[%s%s]" % (percentage, '#' * percentage, '-' * (100 - percentage)))
+    sys.stdout.write("\rTranscoding...(%s%%)[%s%s]" % (percentage, '#' * percentage, '-' * (100 - percentage)))
     sys.stdout.flush()
 
 
-def create_dash_files(_input, _output, __progress=None):
+def main():
+    parser = argparse.ArgumentParser()
+
+    parser.add_argument('-i', '--input', required=True, help='The path to the video file (required).')
+    parser.add_argument('-o', '--output', default=None, help='The output to write files.')
+
+    args = parser.parse_args()
+
     rep1 = Representation(width=256, height=144, kilo_bitrate=200, audio_k_bitrate=64)
     rep2 = Representation(width=854, height=480, kilo_bitrate=500, audio_k_bitrate=128)
     rep3 = Representation(width=1080, height=720, kilo_bitrate=1000, audio_k_bitrate=320)
 
     (
         ffmpeg_streaming
-            .dash(_input, adaption='"id=0,streams=v id=1,streams=a"')
+            .dash(args.input, adaption='"id=0,streams=v id=1,streams=a"')
             .format('libx265')
             .add_rep(rep1, rep2, rep3)
-            .package(_output, __progress)
+            .package(args.output, transcode_progress)
     )
 
 
 if __name__ == "__main__":
-    name = os.path.basename(__file__).split('.')[0]
-    current_dir = os.path.dirname(os.path.abspath(__file__))
-
-    _input = os.path.join(current_dir, '_example.mp4')
-    _output = os.path.join(current_dir, name, 'output')
-
-    _progress = progress
-
-    create_dash_files(_input, _output, _progress)
+    sys.exit(main())

examples/dash/dash-from_url.py

@@ -0,0 +1,40 @@
+import argparse
+import sys
+import ffmpeg_streaming
+
+from ffmpeg_streaming.from_clouds import from_url
+
+
+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():
+    parser = argparse.ArgumentParser()
+
+    parser.add_argument('-url', '--url', required=True, help='The URL to the video file.')
+    parser.add_argument('-o', '--output', required=True, help='The output to write files.')
+
+    args = parser.parse_args()
+
+    (
+        ffmpeg_streaming
+            .hls(from_url(args.url, progress=download_progress), hls_time=20)
+            .format('libx264')
+            .auto_rep()
+            .package(args.output, progress=transcode_progress)
+    )
+
+
+if __name__ == "__main__":
+    sys.exit(main())

examples/dash/dash.py

@@ -0,0 +1,31 @@
+import argparse
+import sys
+import ffmpeg_streaming
+
+
+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('-i', '--input', required=True, help='The path to the video file (required).')
+    parser.add_argument('-o', '--output', default=None, help='The output to write files.')
+
+    args = parser.parse_args()
+
+    (
+        ffmpeg_streaming
+            .hls(args.input, hls_time=20)
+            .format('libx264')
+            .auto_rep()
+            .package(args.output, transcode_progress)
+    )
+
+
+if __name__ == "__main__":
+    sys.exit(main())