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

# @Time : 2021/4/24 20:50

# @File : baidu_voice_service.py

# @Author : Rocky C@www.30daydo.com



import os

import time



import requests

import sys

import pickle

sys.path.append('..')

from config import API_KEY,SECRET_KEY

from base64 import b64encode

from pathlib import PurePath

import subprocess



BASE = PurePath(__file__).parent



# 需要识别的文件

# 文件格式

# 文件后缀只支持 pcm/wav/amr 格式，极速版额外支持m4a 格式



CUID = '24057753' # 随意

# 采样率

RATE = 16000  # 固定值





ASR_URL = 'http://vop.baidu.com/server_api'



#测试自训练平台需要打开以下信息， 自训练平台模型上线后，您会看见 第二步：“”获取专属模型参数pid:8001，modelid:1234”，按照这个信息获取 dev_pid=8001，lm_id=1234

'''

http://vop.baidu.com/server_api

1537	普通话(纯中文识别)	输入法模型	有标点	支持自定义词库

1737	英语	英语模型	无标点	不支持自定义词库

1637	粤语	粤语模型	有标点	不支持自定义词库

1837	四川话	四川话模型	有标点	不支持自定义词库

1936	普通话远场

'''

DEV_PID = 1737



SCOPE = 'brain_enhanced_asr'  # 有此scope表示有asr能力，没有请在网页里开通极速版





class DemoError(Exception):

    pass





TOKEN_URL = 'http://openapi.baidu.com/oauth/2.0/token'



def fetch_token():



    params = {'grant_type': 'client_credentials',

              'client_id': API_KEY,

              'client_secret': SECRET_KEY}

    r = requests.post(

        url=TOKEN_URL,

        data=params

    )



    result = r.json()

    if ('access_token' in result.keys() and 'scope' in result.keys()):

        if SCOPE and (not SCOPE in result['scope'].split(' ')):  # SCOPE = False 忽略检查

            raise DemoError('scope is not correct')



        return result['access_token']



    else:

        raise DemoError('MAYBE API_KEY or SECRET_KEY not correct: access_token or scope not found in token response')





"""  TOKEN end """



def dump_token(token):

    with open(os.path.join(BASE,'token.pkl'),'wb') as fp:

        pickle.dump({'token':token},fp)



def load_token(filename):



    if not os.path.exists(filename):

        token=fetch_token()

        dump_token(token)

        return token

    else:

        with open(filename,'rb') as fp:

            token = pickle.load(fp)

            return token['token']



def recognize_service(token,filename):

    FORMAT = filename[-3:]

    with open(filename, 'rb') as speech_file:

        speech_data = speech_file.read()



    length = len(speech_data)

    if length == 0:

        raise DemoError('file %s length read 0 bytes' % filename)



    b64_data = b64encode(speech_data)

    params = {'cuid': CUID, 'token': token, 'dev_pid': DEV_PID,'speech':b64_data,'len':length,'format':FORMAT,'rate':RATE,'channel':1}



    headers = {

        'Content-Type':'application/json',

    }

    r = requests.post(url=ASR_URL,json=params,headers=headers)

    return r.json()



def rate_convertor(filename):

    filename = filename.split('.')[0]

    CMD=f'ffmpeg.exe -y -i {filename}.mp3 -ac 1 -ar 16000 {filename}.wav'

    try:

        p=subprocess.Popen(CMD, stdin=subprocess.PIPE)

        p.communicate()

        time.sleep(1)

    except Exception as e:

        print(e)

        return False,None

    else:

        return True,f'{filename}.wav'



def clear(file):

    try:

        os.remove(file)

    except Exception as e:

        print(e)



def get_voice_text(audio_file):



    filename = 'token.pkl'

    token = load_token(filename)

    convert_status,file = rate_convertor(audio_file)

    clear(file)

    if not convert_status:

        return None



    result = recognize_service(token,file)



    return result['result'][0]



if __name__ == '__main__':

    get_voice_text('1.mp3')

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

# @Time : 2021/4/25 15:16

# @File : download_mp3.py

# @Author : Rocky C@www.30daydo.com







#!/usr/bin/env python3

import os

import subprocess

import time

import re

import requests

import urllib.request

import zipfile

import io

from google.cloud import speech_v1

from random import randint, uniform

from bs4 import BeautifulSoup

from selenium import webdriver

from selenium.common.exceptions import NoSuchElementException

from selenium.webdriver.common.by import By

from selenium.webdriver.common.action_chains import ActionChains

from selenium.webdriver.support import expected_conditions as EC

from selenium.webdriver.support.ui import WebDriverWait

from google_recaptcha.baidu_voice_service import get_voice_text,clear





class Gcaptcha:



    def __init__(self, url):

        self.response = None



        self.attempts = 0

        self.successful = 0

        self.failed = 0

        self.solved = 0



        self.mp3 = 'audio.mp3'

        # self.wav='audio.wav'



        # Set Chrome to run in headless mode and mute the audio

        opts = webdriver.ChromeOptions()

        # opts.headless = True

        opts.add_argument("--mute-audio")

        # opts.add_argument("--headless",)



      

        CHROME_PATH = r'C:\git\EZProject\bin\chromedriver.exe'

        self.driver = webdriver.Chrome(executable_path=CHROME_PATH,options=opts)

        self.driver.maximize_window()

        self.driver.get(url)

        self.__bypass_webdriver_check()



        # Initialize gcaptcha solver

        self.__initialize()



        while True:

            # Download MP3 file

            mp3_file = self.__download_mp3()



            # Transcribe MP3 file

            result = get_voice_text(self.mp3)



            # audio_transcription = transcribe(mp3_file)

            # self.transcription.attempts += 1



            # If the MP3 file is properly transcribed

            if result is not None:

                # self.transcription.successful += 1



                # Verify transcription

                verify = self.__submit_transcription(result)



                # Transcription successful with confidence >60%

                if verify:

                    gcaptcha_response = self.__get_response()

                    self.response = gcaptcha_response

                    # self.recaptcha.solved += 1



                    # Delete MP3 file



                    self.driver.close()

                    self.driver.quit()

                    break

                # Multiple correct solutions required. Solving again.

                else:

                    self.solved += 1

                    clear(self.mp3)



            # If the MP3 file could not be transcribed

            else:

                self.failed += 1

                clear(self.mp3)



                # Click on the "Get a new challenge" button to use a new MP3 file

                self.__refresh_mp3()

                # time.sleep(uniform(2, 4))







    def __initialize(self):

        # Access initial gcaptcha iframe

        self.driver.switch_to.frame(self.driver.find_element(By.CSS_SELECTOR, 'iframe[name^=a]'))

        self.__bypass_webdriver_check()



        # Click the gcaptcha checkbox

        checkbox = self.driver.find_element(By.CSS_SELECTOR, '#recaptcha-anchor')

        self.__mouse_click(checkbox)



        # Go back to original content to access second gcaptcha iframe

        self.driver.switch_to.default_content()



        # Wait roughly 3 seconds for second gcaptcha iframe to load

        time.sleep(uniform(2.5, 3))



        # Find second gcaptcha iframe

        gcaptcha = WebDriverWait(self.driver, 10).until(

            EC.presence_of_element_located((By.CSS_SELECTOR, 'iframe[name^=c]'))

        )



        # Access second gcaptcha iframe

        self.driver.switch_to.frame(gcaptcha)

        self.__bypass_webdriver_check()



        # Click the audio button

        audio_button = WebDriverWait(self.driver, 10).until(

            EC.presence_of_element_located((By.CSS_SELECTOR, '.rc-button-audio'))

        )

        self.__mouse_click(audio_button)

        time.sleep(0.5)



    def __mouse_click(self, element):

        cursor = ActionChains(self.driver)

        cursor.move_to_element(element)

        cursor.pause(uniform(0.3, 0.5))

        cursor.click()

        cursor.perform()



    def __bypass_webdriver_check(self):

        self.driver.execute_script(

            'const newProto = navigator.__proto__; delete newProto.webdriver; navigator.__proto__ = newProto;')



    def __download_mp3(self):

        self.driver.switch_to.default_content()

        self.driver.switch_to.frame(self.driver.find_element(By.CSS_SELECTOR, 'iframe[name^=c]'))

        self.__bypass_webdriver_check()



        # Check if the Google servers are blocking us

        if len(self.driver.find_elements(By.CSS_SELECTOR, '.rc-doscaptcha-body-text')) == 0:

            audio_file = WebDriverWait(self.driver, 10).until(

                EC.presence_of_element_located((By.CSS_SELECTOR, '.rc-audiochallenge-tdownload-link'))

            )



            # Click the play button

            play_button = WebDriverWait(self.driver, 10).until(

                EC.presence_of_element_located((By.CSS_SELECTOR, '.rc-audiochallenge-play-button > button'))

            )

            self.__mouse_click(play_button)



            # Get URL of MP3 file

            audio_url = audio_file.get_attribute('href')



            # Predefine the MP3 file name



            # Download the MP3 file

            try:

                urllib.request.urlretrieve(audio_url, self.mp3)

            except Exception as e:

                print(e)

                return None

            else:

                return self.mp3

        else:

            Error('Too many requests have been sent to Google. You are currently being blocked by their servers.')

            exit(-1)



    def __refresh_mp3(self):

        self.driver.switch_to.default_content()

        self.driver.switch_to.frame(self.driver.find_element(By.CSS_SELECTOR, 'iframe[name^=c]'))

        self.__bypass_webdriver_check()



        # Click on the refresh button to retrieve a new mp3 file

        refresh_button = self.driver.find_element(By.CSS_SELECTOR, '#recaptcha-reload-button')

        self.__mouse_click(refresh_button)



    def __submit_transcription(self, text):

        self.driver.switch_to.default_content()

        self.driver.switch_to.frame(self.driver.find_element(By.CSS_SELECTOR, 'iframe[name^=c]'))

        self.__bypass_webdriver_check()



        # Input field for response

        input_field = self.driver.find_element(By.CSS_SELECTOR, '#audio-response')



        # Instantly type the full text without delays because Google isn't checking delays between keystrokes

        input_field.send_keys(text)



        # Click "Verify" button

        verify_button = self.driver.find_element(By.CSS_SELECTOR, '#recaptcha-verify-button')

        self.__mouse_click(verify_button)



        # Wait roughly 3 seconds for verification to complete

        time.sleep(uniform(2, 3))



        self.driver.switch_to.default_content()

        self.driver.switch_to.frame(self.driver.find_element(By.CSS_SELECTOR, 'iframe[name^=a]'))

        self.__bypass_webdriver_check()



        # Check to see if verified by recaptcha

        try:

            self.driver.find_element(By.CSS_SELECTOR, '.recaptcha-checkbox-checked')

        except NoSuchElementException:

            return False

        else:

            return True



    def __get_response(self):

        # Switch back to main parent window and get gcaptcha response

        self.driver.switch_to.default_content()

        response = self.driver.find_element(By.CSS_SELECTOR, '#g-recaptcha-response').get_attribute('value')

        return response





class Error(Exception):

    def __init__(self, message):

        get_files = os.listdir()

        match_regex = re.compile(r'^audio\d+.mp3|chromedriver_\w+\d+.zip$')

        filtered_files = [f for f in get_files if match_regex.match(f)]



        for file in filtered_files:

            clear(file)



        raise Exception(f'ERROR: {message}')





if __name__=='__main__':

    gcaptcha = Gcaptcha('https://www.google.com/recaptcha/api2/demo')

ffmpeg.exe -i 3.mp3 -ac 1 -ar 16000 16k.wav

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

# @Time : 2021/4/24 20:50

# @File : baidu_voice_service.py

# @Author : Rocky C@www.30daydo.com



import os

import requests

import sys

import pickle

sys.path.append('..')

from config import API_KEY,SECRET_KEY

from base64 import b64encode

from pathlib import PurePath





BASE = PurePath(__file__).parent



# 需要识别的文件

AUDIO_FILE = r'C:\OtherGit\speech-demo\rest-api-asr\python\audio\2.m4a'  # 只支持 pcm/wav/amr 格式，极速版额外支持m4a 格式

# 文件格式

FORMAT = AUDIO_FILE[-3:]  # 文件后缀只支持 pcm/wav/amr 格式，极速版额外支持m4a 格式



CUID = '24057753'

# 采样率

RATE = 16000  # 固定值





ASR_URL = 'http://vop.baidu.com/server_api'



#测试自训练平台需要打开以下信息， 自训练平台模型上线后，您会看见 第二步：“”获取专属模型参数pid:8001，modelid:1234”，按照这个信息获取 dev_pid=8001，lm_id=1234

'''

http://vop.baidu.com/server_api

1537	普通话(纯中文识别)	输入法模型	有标点	支持自定义词库

1737	英语	英语模型	无标点	不支持自定义词库

1637	粤语	粤语模型	有标点	不支持自定义词库

1837	四川话	四川话模型	有标点	不支持自定义词库

1936	普通话远场

'''

DEV_PID = 1737



SCOPE = 'brain_enhanced_asr'  # 有此scope表示有asr能力，没有请在网页里开通极速版





class DemoError(Exception):

    pass





TOKEN_URL = 'http://openapi.baidu.com/oauth/2.0/token'



def fetch_token():



    params = {'grant_type': 'client_credentials',

              'client_id': API_KEY,

              'client_secret': SECRET_KEY}

    r = requests.post(

        url=TOKEN_URL,

        data=params

    )



    result = r.json()

    if ('access_token' in result.keys() and 'scope' in result.keys()):

        if SCOPE and (not SCOPE in result['scope'].split(' ')):  # SCOPE = False 忽略检查

            raise DemoError('scope is not correct')



        return result['access_token']



    else:

        raise DemoError('MAYBE API_KEY or SECRET_KEY not correct: access_token or scope not found in token response')





"""  TOKEN end """



def dump_token(token):

    with open(os.path.join(BASE,'token.pkl'),'wb') as fp:

        pickle.dump({'token':token},fp)



def load_token(filename):



    if not os.path.exists(filename):

        token=fetch_token()

        dump_token(token)

        return token

    else:

        with open(filename,'rb') as fp:

            token = pickle.load(fp)

            return token['token']



def recognize_service(token,filename):



    with open(filename, 'rb') as speech_file:

        speech_data = speech_file.read()



    length = len(speech_data)

    if length == 0:

        raise DemoError('file %s length read 0 bytes' % AUDIO_FILE)



    b64_data = b64encode(speech_data)

    params = {'cuid': CUID, 'token': token, 'dev_pid': DEV_PID,'speech':b64_data,'len':length,'format':FORMAT,'rate':RATE,'channel':1}



    headers = {

        'Content-Type':'application/json',

    }

    r = requests.post(url=ASR_URL,json=params,headers=headers)

    return r.json()





def main():

    filename = 'token.pkl'

    token = load_token(filename)

    result = recognize_service(token,AUDIO_FILE)

    print(result['result'])



if __name__ == '__main__':

    main()

ret = self.doc.update_one({'announcementId':announcementId},{'$setOnInsert':item},upsert=True)

ret.matched_count, ret.modified_count

find . -type f -name "*.py" | xargs grep "redis"

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

# @Time : 2021/4/14 1:46

# @File : search_string_in_folder.py

# @Author : Rocky C@www.30daydo.com



'''

搜索代码脚本

'''

import fire

import glob

import re



# TODO 用PYQT重写一个



PATH_LIST = [r'C:\git\\',r'C:\OtherGit\\',r'C:\OneDrive\viewed_code\\']

POST_FIX = 'py' # 后缀文件

# 关键词

WORDS=[]



EXCLUDE_PATH=[r'C:\OtherGit\cpython']



DEBUG = True



class FileSearcher:



    def __init__(self,kw):

        self.root_path_list = PATH_LIST

        self.default_coding ='utf-8'

        self.exception_handle_coding='gbk'

        self.kw=[]

        if not isinstance(kw,tuple):

            kw=(kw,)



        for k in kw:

            k=k.strip()

            self.kw.append(k)



    def search(self,file,encoding):

        match_dict = dict()



        for w in self.kw:

            match_dict.setdefault(w, False)



        line_number = 0

        line_list=list()

        with open(file, 'r', encoding=encoding) as fp:



            while 1:

                try:

                    line = fp.readline()



                except UnicodeDecodeError as e:



                    if DEBUG:

                        print(f'Error coding in file {file}')

                        print(e)



                    return None,None,None



                except Exception as e:

                    if DEBUG:

                        print(f'Error in file {file}')

                        print(e)

                    break



                if not line:

                    break



                line = line.strip()

                if not line:

                    continue



                for w in self.kw:

                    m=re.search(w,line,re.IGNORECASE)

                    if m:

                        match_dict.update({w:True})

                        line_list.append(line_number)



                line_number+=1



        return True,match_dict.copy(),line_list.copy()



    def print_match_result(self,file,line_list,encoding):



        with open(file, 'r', encoding=encoding) as fp:

            line_number = 0

            while 1:

                try:

                    line = fp.readline()

                except Exception as e:

                    if DEBUG:

                        print(f'Error in file {file}')

                        print(e)

                    break



                if not line:

                    break

                line=line.strip()



                if not line:

                    continue



                if line_number in line_list:

                    print(f'{file} :: {line_number} ====>\n {line[:50]}\n')



                line_number += 1



    def run(self):

        for path in self.root_path_list:



            search_path=path+'**/*.'+POST_FIX



            for file in glob.iglob(search_path,recursive=True):



                for ex_path in EXCLUDE_PATH:

                    ex_path=ex_path.replace('\\','')

                    temp_file=file.replace('\\','')

                    if ex_path in temp_file:

                        continue



                    use_encoding=self.default_coding

                    encode_proper,match_dict,line_list=self.search(file,use_encoding)



                    if not encode_proper:

                        use_encoding = self.exception_handle_coding

                        encode_proper,match_dict,line_list=self.search(file, use_encoding)



                    if match_dict is not None and len(match_dict)>0 and all(match_dict.values()):

                        # print(match_dict.values())

                        self.print_match_result(file,line_list,use_encoding)

                        # print(line_list)





def test_error_file():

    path=r'C:\git\CodePool\example-code\19-dyn-attr-prop\oscon\schedule2.py'

    with open(path,'r',encoding='utf8') as fp:

        while 1:

            x=fp.readline()

            if not x:

                break

            print(x)



def main(kw):

    app = FileSearcher(kw)

    app.run()



if __name__ == '__main__':

    fire.Fire(main)

def check_coroutine(fun):

    if iscoroutinefunction(fun):

        print('是协程')

    else:

        print('不是协程')

async def visit_web():

    browser = await pyppeteer.launch(

        {'headless': False,

         'userDataDir': UserDataDir,

         'defaultViewport': {'width': 1800, 'height': 1000},

         'ignoreDefaultArgs':True,

         }

    )

    page = await browser.newPage()



    # 可以在launch下配置

    # await page.setViewport({

    #     "width": 1900,

    #     "height": 1020

    # })





    # 先执行下面的JS 再去goto

    await page.evaluate(

        '''() =>{ Object.defineProperties(navigator,{ webdriver:{ get: () => false } }) }''')

    # await page.screenshot({'path': 'test.png', 'fullPage': True})

    # await page.pdf({'path': 'test.pdf'})

    # await asyncio.sleep(5)



    await page.goto(url=URL)



    # 这里的js是异步的写法

    dimensions = await page.evaluate(

        '''

        ()=>{

        return {

        width:document.documentElement.clientWidth,

        height:document.documentElement.clientHeight,

        deviceScaleFactor_:window.devicePixelRatio,

        }

        }

        '''

    )



    result = await page.evaluate(

        '''

        ()=>{

        var title = document.title;

          return {title:title};

          }

          '''



    )





    await browser.close()

check_coroutine(visit_web)

    browser = await pyppeteer.launch(

        {'headless': False,

         'userDataDir': UserDataDir,

         'defaultViewport': {'width': 1800, 'height': 1000},

         # 'enable-automation':False,

         'ignoreDefaultArgs':['--enable-automation'],

         }

    )

    browser = await pyppeteer.launch(

        {'headless': False,

         'userDataDir': UserDataDir,

         'defaultViewport': {'width': 1800, 'height': 1000}

         }

    )

        self.handleSIGINT = options.get('handleSIGINT', True)

        self.handleSIGTERM = options.get('handleSIGTERM', True)

        self.handleSIGHUP = options.get('handleSIGHUP', True)

        self.ignoreHTTPSErrors = options.get('ignoreHTTPSErrors', False)

        self.defaultViewport = options.get('defaultViewport', {'width': 800, 'height': 600})  # noqa: E501

        self.slowMo = options.get('slowMo', 0)

        self.timeout = options.get('timeout', 30000)

        self.autoClose = options.get('autoClose', True)

获取 排除满足强赎天数剩余N天的可转债，排除强赎可转债。



比如：DAY=4 ，那么假设强赎满足天数为15天，那么返回市场上强赎强赎倒数天数大于4天的可转债，即返回小于或者等于11天以下的转债。把满足条件还差4天的转债排除掉了，当然，已经公告强赎的也会被排除。







import requests



URL = 'http://11.11.11.11/api/redeem/'

# DAY 强赎倒数剩余天数小于 DAY （4）天， 已经公告强赎的也是被排除的

DAY = 4



SIGN = '私信星主获取' # sign和以前一致



data = {'day': DAY,

        'sign': SIGN}

r = requests.post(URL, data=data)



print(r.json())

urllib3.exceptions.MaxRetryError: HTTPSConnectionPool(host='storage.googleapis.com', port=443): Max retries exceeded with url: /chromium-browser-snapshots/Win_

x64/588429/chrome-win32.zip (Caused by NewConnectionError('<urllib3.connection.HTTPSConnection object at 0x00000000037D3880>: Failed to establish a new connect

ion: [Errno 11004] getaddrinfo failed'))

def get_all_code(date):

    ''' 

    获取某天的股市运行的股票，排除停牌 

    ''' 

     df=DataAPI.MktEqudAdjGet(secID=u"",ticker=u"",

                           tradeDate=date, 

                           beginDate=u"", 

                           endDate=u"", 

                           isOpen="", 

                           field=u"", 

                           pandas="1")

    df=df[df['turnoverValue']>0] # 停牌 

    return df['ticker'].tolist()

 1import time

 2import datetime

 3

 4stock_profit_list=

 5start=time.time()

 6

 7today=datetime.datetime.now().strftime('%Y-%m-%d')

 8

 9def get_trade_date():

10    df=DataAPI.TradeCalGet(exchangeCD=u"XSHG,XSHE",

11                           beginDate=high_date,

12                           endDate=today,isOpen=u"1",

13                           field=u"",pandas="1")

14    return df['calendarDate'].tolist()

15

16def fixed_investment(code):

17    stock_profit_dict={}

18    stock_profit_dict['code']=code

19    df=DataAPI.MktEqudAdjGet(secID=u"",ticker=code,tradeDate=u'',beginDate=high_date,endDate=today,isOpen="1",field=u"",pandas="1")

20    total_amount=0

21    invest_count=0

22    every_invest_cash=10000

23    total_money_list=list()

24    last_date=None

25    for trade_date in trade_date_list_interval:

26        trade_df = df[df['tradeDate']==trade_date]

27        if len(trade_df)>0:

28            invest_count+=1

29            price=trade_df['closePrice'].iloc[0]

30            amount=every_invest_cash/price

31            cost=invest_count*every_invest_cash

32            profit=total_amount*price/cost

33            total_money_list.append(profit)

34            total_amount=total_amount+amount

35            total_money=price*total_amount

36            last_date=trade_date

37

38

39    stock_profit_dict['profit_rate']=profit

40    stock_profit_dict['last_date']=last_date

41    stock_profit_dict['invest_count']=invest_count

42    stock_profit_dict['total_amount']=total_amount

43    stock_profit_dict['total_money']=total_money

44    stock_profit_dict['profit_list']=total_money_list

45    stock_profit_dict['cost']=cost

46    return stock_profit_dict

47

48for code in target_codes:

49    profit_dict = fixed_investment(code)

50    stock_profit_list.append(profit_dict)

51

52print(time.time()-start)

profi_df_sorted = profit_df.sort_values(by='profit_rate',ascending=False)

profit_df['absolute_profit']=profit_df['total_money']-profit_df['cost']

profi_df_sorted['profit_rate'].mean()

fork/exec /root/crontab_script/hello.sh: exec format error

#!/bin/bash

In [1]: folder='/root/crontab_script'



In [2]: import os



In [3]: filelist=os.listdir(folder)



In [6]: def change_file(filename):

   ...:     with open(filename,'r') as fp:

   ...:         content=fp.read()

   ...:         content=content.strip()

   ...:     concat='#!/bin/bash\n'

   ...:     content=concat+content

   ...:     with open(filename,'w') as fp:

   ...:         fp.write(content)

   ...:



In [7]: for file in filelist:

   ...:     if file.endswith('.sh'):

   ...:         full_path = os.path.join(folder,file)

   ...:         change_file(full_path)

 cd xxxxx && python xxx.py