update examples -> add time left

Author: aminyazdanpanah

examples/clouds/aws_cloud.py

@@ -12,7 +12,9 @@
 """
 
 import argparse
+import datetime
 import sys
+import time
 
 import ffmpeg_streaming
 from ffmpeg_streaming import AWS
@@ -34,10 +36,24 @@ def aws_cloud(bucket_name, key):
     return from_aws_cloud, to_aws_cloud
 
 
-def transcode_progress(percentage, ffmpeg):
-    # You can update a field in your database
+start_time = time.time()
+
+
+def per_to_time_left(percentage):
+    if percentage != 0:
+        diff_time = time.time() - start_time
+        seconds_left = 100 * diff_time / percentage - diff_time
+        time_left = str(datetime.timedelta(seconds=int(seconds_left))) + ' left'
+    else:
+        time_left = 'calculating...'
+
+    return time_left
+
+
+def transcode_progress(per, ffmpeg):
+    # You can update a field in your database or can log it to a file
     # 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.write("\rTranscoding...(%s%%) %s [%s%s]" % (per, per_to_time_left(per), '#' * per, '-' * (100 - per)))
     sys.stdout.flush()
 
 

examples/clouds/azure_cloud.py

@@ -12,7 +12,9 @@
 """
 
 import argparse
+import datetime
 import sys
+import time
 
 import ffmpeg_streaming
 from ffmpeg_streaming import MicrosoftAzure
@@ -35,10 +37,24 @@ def azure_cloud(container, blob):
     return from_azure_cloud, to_azure_cloud
 
 
-def transcode_progress(percentage, ffmpeg):
-    # You can update a field in your database
+start_time = time.time()
+
+
+def per_to_time_left(percentage):
+    if percentage != 0:
+        diff_time = time.time() - start_time
+        seconds_left = 100 * diff_time / percentage - diff_time
+        time_left = str(datetime.timedelta(seconds=int(seconds_left))) + ' left'
+    else:
+        time_left = 'calculating...'
+
+    return time_left
+
+
+def transcode_progress(per, ffmpeg):
+    # You can update a field in your database or can log it to a file
     # 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.write("\rTranscoding...(%s%%) %s [%s%s]" % (per, per_to_time_left(per), '#' * per, '-' * (100 - per)))
     sys.stdout.flush()
 
 

examples/clouds/cloud.py

@@ -10,8 +10,9 @@
 :email: [email protected]
 :license: MIT, see LICENSE for more details.
 """
-
+import datetime
 import sys
+import time
 
 import ffmpeg_streaming
 from ffmpeg_streaming import Cloud
@@ -24,15 +25,8 @@ def download_progress(percentage, downloaded, total):
     sys.stdout.flush()
 
 
-def transcode_progress(percentage, ffmpeg):
-    # 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()
+def cloud():
+    _cloud = Cloud()
     download_options = {
         'url': 'https://www.aminyazdanpanah.com/my_sweetie.mp4',
         'progress': download_progress
@@ -49,8 +43,35 @@ def main():
         }
     }
 
-    from_cloud = (cloud, download_options, None)
-    to_cloud = (cloud, upload_options)
+    from_cloud = (_cloud, download_options, None)
+    to_cloud = (_cloud, upload_options)
+
+    return from_cloud, to_cloud
+
+
+start_time = time.time()
+
+
+def per_to_time_left(percentage):
+    if percentage != 0:
+        diff_time = time.time() - start_time
+        seconds_left = 100 * diff_time / percentage - diff_time
+        time_left = str(datetime.timedelta(seconds=int(seconds_left))) + ' left'
+    else:
+        time_left = 'calculating...'
+
+    return time_left
+
+
+def transcode_progress(per, ffmpeg):
+    # You can update a field in your database or can log it to a file
+    # You can also create a socket connection and show a progress bar to users
+    sys.stdout.write("\rTranscoding...(%s%%) %s [%s%s]" % (per, per_to_time_left(per), '#' * per, '-' * (100 - per)))
+    sys.stdout.flush()
+
+
+def main():
+    from_cloud, to_cloud = cloud()
 
     (
         ffmpeg_streaming

examples/clouds/custom_cloud.py

@@ -10,8 +10,9 @@
 :email: [email protected]
 :license: MIT, see LICENSE for more details.
 """
-
+import datetime
 import sys
+import time
 
 import ffmpeg_streaming
 from ffmpeg_streaming import Clouds
@@ -44,10 +45,24 @@ def custom_cloud():
     return from_custom_cloud, to_custom_cloud
 
 
-def transcode_progress(percentage, ffmpeg):
-    # You can update a field in your database
+start_time = time.time()
+
+
+def per_to_time_left(percentage):
+    if percentage != 0:
+        diff_time = time.time() - start_time
+        seconds_left = 100 * diff_time / percentage - diff_time
+        time_left = str(datetime.timedelta(seconds=int(seconds_left))) + ' left'
+    else:
+        time_left = 'calculating...'
+
+    return time_left
+
+
+def transcode_progress(per, ffmpeg):
+    # You can update a field in your database or can log it to a file
     # 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.write("\rTranscoding...(%s%%) %s [%s%s]" % (per, per_to_time_left(per), '#' * per, '-' * (100 - per)))
     sys.stdout.flush()
 
 

examples/clouds/google_cloud.py

@@ -12,7 +12,9 @@
 """
 
 import argparse
+import datetime
 import sys
+import time
 
 import ffmpeg_streaming
 from ffmpeg_streaming import GoogleCloudStorage
@@ -33,10 +35,24 @@ def google_cloud(bucket_name, object_name):
     return from_google_cloud, to_google_cloud
 
 
-def transcode_progress(percentage, ffmpeg):
-    # You can update a field in your database
+start_time = time.time()
+
+
+def per_to_time_left(percentage):
+    if percentage != 0:
+        diff_time = time.time() - start_time
+        seconds_left = 100 * diff_time / percentage - diff_time
+        time_left = str(datetime.timedelta(seconds=int(seconds_left))) + ' left'
+    else:
+        time_left = 'calculating...'
+
+    return time_left
+
+
+def transcode_progress(per, ffmpeg):
+    # You can update a field in your database or can log it to a file
     # 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.write("\rTranscoding...(%s%%) %s [%s%s]" % (per, per_to_time_left(per), '#' * per, '-' * (100 - per)))
     sys.stdout.flush()
 
 

examples/clouds/moultiple_clouds.py

@@ -10,19 +10,34 @@
 :email: [email protected]
 :license: MIT, see LICENSE for more details.
 """
-
+import datetime
 import sys
+import time
 
 import ffmpeg_streaming
 from examples.clouds.aws_cloud import aws_cloud
 from examples.clouds.azure_cloud import azure_cloud
 from examples.clouds.google_cloud import google_cloud
 
 
-def transcode_progress(percentage, ffmpeg):
-    # You can update a field in your database
+start_time = time.time()
+
+
+def per_to_time_left(percentage):
+    if percentage != 0:
+        diff_time = time.time() - start_time
+        seconds_left = 100 * diff_time / percentage - diff_time
+        time_left = str(datetime.timedelta(seconds=int(seconds_left))) + ' left'
+    else:
+        time_left = 'calculating...'
+
+    return time_left
+
+
+def transcode_progress(per, ffmpeg):
+    # You can update a field in your database or can log it to a file
     # 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.write("\rTranscoding...(%s%%) %s [%s%s]" % (per, per_to_time_left(per), '#' * per, '-' * (100 - per)))
     sys.stdout.flush()
 
 

examples/dash/dash.py

@@ -12,14 +12,31 @@
 """
 
 import argparse
+import datetime
 import sys
+import time
+
 import ffmpeg_streaming
 
 
-def transcode_progress(percentage, ffmpeg):
-    # You can update a field in your database
+start_time = time.time()
+
+
+def per_to_time_left(percentage):
+    if percentage != 0:
+        diff_time = time.time() - start_time
+        seconds_left = 100 * diff_time / percentage - diff_time
+        time_left = str(datetime.timedelta(seconds=int(seconds_left))) + ' left'
+    else:
+        time_left = 'calculating...'
+
+    return time_left
+
+
+def transcode_progress(per, ffmpeg):
+    # You can update a field in your database or can log it to a file
     # 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.write("\rTranscoding...(%s%%) %s [%s%s]" % (per, per_to_time_left(per), '#' * per, '-' * (100 - per)))
     sys.stdout.flush()
 
 

examples/dash/dash_manual.py

@@ -12,16 +12,33 @@
 """
 
 import argparse
+import datetime
 import sys
+import time
+
 import ffmpeg_streaming
 
 from ffmpeg_streaming import Representation
 
 
-def transcode_progress(percentage, ffmpeg):
-    # You can update a field in your database
+start_time = time.time()
+
+
+def per_to_time_left(percentage):
+    if percentage != 0:
+        diff_time = time.time() - start_time
+        seconds_left = 100 * diff_time / percentage - diff_time
+        time_left = str(datetime.timedelta(seconds=int(seconds_left))) + ' left'
+    else:
+        time_left = 'calculating...'
+
+    return time_left
+
+
+def transcode_progress(per, ffmpeg):
+    # You can update a field in your database or can log it to a file
     # 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.write("\rTranscoding...(%s%%) %s [%s%s]" % (per, per_to_time_left(per), '#' * per, '-' * (100 - per)))
     sys.stdout.flush()
 
 

examples/hls/hls.py

@@ -12,31 +12,47 @@
 """
 
 import argparse
+import datetime
 import sys
+import time
+
 import ffmpeg_streaming
 
+start_time = time.time()
+
+
+def per_to_time_left(percentage):
+    if percentage != 0:
+        diff_time = time.time() - start_time
+        seconds_left = 100 * diff_time / percentage - diff_time
+        time_left = str(datetime.timedelta(seconds=int(seconds_left))) + ' left'
+    else:
+        time_left = 'calculating...'
+
+    return time_left
 
-def transcode_progress(percentage, ffmpeg):
-    # You can update a field in your database
+
+def transcode_progress(per, ffmpeg):
+    # You can update a field in your database or can log it to a file
     # 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.write("\rTranscoding...(%s%%) %s [%s%s]" % (per, per_to_time_left(per), '#' * per, '-' * (100 - per)))
     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()
+    # 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)
+            .hls("c:\\test\\test8.mkv", hls_time=20)
             .format('libx264')
             .auto_rep()
-            .package(args.output, progress=transcode_progress)
+            .package("c:\\test\\maman\\ahmad.m3u8", progress=transcode_progress)
     )