Dev

.gitignore

@@ -11,3 +11,4 @@ _templates/*
 __pycache__/
 .cache
 .python-version
+venv/*

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2021 一叶知秋
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

Schedule/demo.py

@@ -0,0 +1,28 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import time
+
+import schedule
+
+
+def job():
+    print("I'm working...")
+
+
+# 每十分钟执行任务
+schedule.every(10).minutes.do(job)
+# 每个小时执行任务
+schedule.every().hour.do(job)
+# 每天的10:30执行任务
+schedule.every().day.at("10:30").do(job)
+# 每个月执行任务
+schedule.every().monday.do(job)
+# 每个星期三的13:15分执行任务
+schedule.every().wednesday.at("13:15").do(job)
+# 每分钟的第17秒执行任务
+schedule.every().minute.at(":17").do(job)
+# 每10秒执行任务
+schedule.every(10).seconds.do(job)
+while True:
+    schedule.run_pending()
+    time.sleep(1)

Schedule/demo10.py

@@ -0,0 +1,44 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+
+
+import functools
+
+import schedule
+
+"""
+Schedule 不会自动捕捉异常，它遇到异常会直接抛出，这会导致一个严重的问题：后续所有的作业都会被中断执行，因此我们需要捕捉到这些异常。
+"""
+
+
+def catch_exceptions(cancel_on_failure=False):
+    def catch_exceptions_decorator(job_func):
+        @functools.wraps(job_func)
+        def wrapper(*args, **kwargs):
+            try:
+                return job_func(*args, **kwargs)
+            except:
+                import traceback
+                print(traceback.format_exc())
+                if cancel_on_failure:
+                    return schedule.CancelJob
+
+        return wrapper
+
+    return catch_exceptions_decorator
+
+
+@catch_exceptions(cancel_on_failure=True)
+def bad_task():
+    return 1 / 0
+
+@catch_exceptions(cancel_on_failure=True)
+def job():
+    print("i'm working...")
+
+
+schedule.every(5).seconds.do(bad_task)
+schedule.every(7).seconds.do(job)
+
+while True:
+    schedule.run_pending()

Schedule/demo2.py

@@ -0,0 +1,20 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import time
+import schedule
+
+"""
+只运行一次任务
+"""
+
+
+def job_that_executes_once():
+    print('i\'m working...')
+    # 此处编写的任务只会执行一次...
+    return schedule.CancelJob
+
+
+schedule.every().day.at('22:30').do(job_that_executes_once)
+while True:
+    schedule.run_pending()
+    time.sleep(1)

Schedule/demo3.py

@@ -0,0 +1,33 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import time
+import schedule
+
+"""
+获取目前所有的作业
+取消所有作业
+"""
+
+def greet(name):
+    print('Hello', name)
+
+
+def hello():
+    print('Hello world')
+
+
+# do() 将额外的参数传递给job函数
+schedule.every(2).seconds.do(greet, 'Alice')
+schedule.every(4).seconds.do(greet, 'Bob')
+schedule.every(6).seconds.do(greet, name='jack')
+
+schedule.every().second.do(hello)
+# 获取目前所有的作业
+all_jobs = schedule.get_jobs()
+print(all_jobs)
+# 取消所有作业
+schedule.clear()
+
+while True:
+    schedule.run_pending()
+    time.sleep(1)

Schedule/demo4.py

@@ -0,0 +1,30 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import time
+
+import schedule
+
+"""
+标签功能
+"""
+
+
+def greet(name):
+    print('Hello {}'.format(name))
+
+
+# .tag 打标签
+schedule.every().day.do(greet, 'Andrea').tag('daily-tasks', 'friend')
+schedule.every().hour.do(greet, 'John').tag('hourly-tasks', 'friend')
+schedule.every().hour.do(greet, 'Monica').tag('hourly-tasks', 'customer')
+schedule.every().day.do(greet, 'Derek').tag('daily-tasks', 'guest')
+
+# get_jobs(标签)：可以获取所有该标签的任务
+friends = schedule.get_jobs('friend')
+
+# 取消所有 daily-tasks 标签的任务
+schedule.clear('daily-tasks')
+
+while True:
+    schedule.run_pending()
+    time.sleep(1)

Schedule/demo5.py

@@ -0,0 +1,32 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+from datetime import datetime, timedelta, time
+import schedule
+
+"""
+设定作业截止时间
+"""
+
+
+def job():
+    print('Boo')
+
+
+# 每个小时运行作业，18:30后停止
+schedule.every(1).hours.until('18:30').do(job)
+
+# 每个小时运行作业，2030-01-01 18:33 today
+schedule.every(1).hours.until('2030-01-01 18:33').do(job)
+
+# 每个小时运行作业，8个小时后停止
+schedule.every(1).hours.until(timedelta(hours=8)).do(job)
+
+# 每个小时运行作业，11:32:42后停止
+schedule.every(1).hours.until(time(11,32,42)).do(job)
+
+# 每个小时运行作业，2020-5-17 11:36:20后停止
+schedule.every(1).hours.until(datetime(2020, 5, 17, 11, 36, 20)).do(job)
+
+# 截止日期之后，该作业将无法运行。
+while True:
+    schedule.run_pending()

Schedule/demo6.py

@@ -0,0 +1,23 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import schedule
+
+"""
+立即运行所有作业，而不管其安排如何
+"""
+
+
+def job_1():
+    print('Foo')
+
+
+def job_2():
+    print('Bar')
+
+
+schedule.every().monday.at("12:40").do(job_1)
+schedule.every().tuesday.at("16:40").do(job_2)
+
+schedule.run_all()
+# 立即运行所有作业，每次作业间隔10秒
+schedule.run_all(delay_seconds=10)

Schedule/demo7.py

@@ -0,0 +1,16 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import time
+from schedule import every,run_pending,repeat
+
+"""
+装饰器安排作业
+"""
+# 此装饰器效果等同于 schedule.every(10).minutes.do(job)
+@repeat(every(10).minutes)
+def job():
+    print("I am a scheduled job")
+
+while True:
+    run_pending()
+    time.sleep(1)

Schedule/demo8.py

@@ -0,0 +1,30 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import threading
+import time
+import schedule
+"""
+并行执行
+
+默认情况下，Schedule 按顺序执行所有作业。其背后的原因是，很难找到让每个人都高兴的并行执行模型。
+
+不过你可以通过多线程的形式来运行每个作业以解决此限制：
+"""
+def job1():
+    print("I'm running on threads %s" % threading.current_thread())
+def job2():
+    print("I'm running on threads %s" % threading.current_thread())
+def job3():
+    print("I'm running on threads %s" % threading.current_thread())
+
+def run_threaded(job_func):
+    job_thread = threading.Thread(target=job_func)
+    job_thread.start()
+
+schedule.every(10).seconds.do(run_threaded, job1)
+schedule.every(10).seconds.do(run_threaded, job2)
+schedule.every(10).seconds.do(run_threaded, job3)
+
+while True:
+    schedule.run_pending()
+    time.sleep(1)

Schedule/demo9.py

@@ -0,0 +1,21 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+import logging
+import schedule
+"""
+日志记录
+"""
+logging.basicConfig()
+schedule_logger = logging.getLogger('schedule')
+# 日志级别为DEBUG
+schedule_logger.setLevel(level=logging.DEBUG)
+
+
+def job():
+    print("Hello, Logs")
+
+
+schedule.every().second.do(job)
+schedule.run_all()
+
+schedule.clear()

YouTubesphb/YouTube 音视频合并.bat

@@ -0,0 +1,12 @@
+@echo off
+title YouTube ����Ƶ�ϲ� 20140127
+echo ���ߣ�Crexyer
+echo ��վ��http://www.crexyer.com/
+echo.
+set /p audio=�뽫����Ƶ���ļ���ק���˴������»س�ȷ�ϣ�
+set /p video=�뽫����Ƶ���ļ���ק���˴������»س�ȷ�ϣ�
+ffmpeg.exe -i %audio% -i %video% -acodec copy -vcodec copy output.mp4
+echo.
+echo �ϲ�������
+echo �ļ��Ѿ���������ص� output.mp4 �ļ���
+pause

algorithm_datastructure/dict_tools.py

@@ -4,6 +4,7 @@
 
 class ObjectDict(dict):
     """from tornado.util.ObjectDict, access dict by dot"""
+
     def __getattr__(self, key):
         try:
             return self[key]
@@ -16,7 +17,6 @@ def __setattr__(self, key, value):
 
 import collections
 
-
 class TransformedDict(collections.MutableMapping):
     """A dictionary that applies an arbitrary key-altering
        function before accessing the keys"""
@@ -43,10 +43,12 @@ def __len__(self):
     def __keytransform__(self, key):
         return key
 
+
 # pip install fronzendict
 
 class FronzenDict(TransformedDict):
     """immutable dict, init by a dict"""
+
     def __init__(self, d):
         self.store = d
 
@@ -57,4 +59,7 @@ def __setitem__(self, key, value):
 
 # since python3.3, you can use immutable dict
 import types
-d_proxy = types.MappingProxyType(d)    # can add new key/value by assignment but can not assign key alrady exists
+
+d = {1: 'hello', 2: 'world'}
+d_proxy = types.MappingProxyType(d)  # can add new key/value by assignment but can not assign key alrady exists
+print(d_proxy)