Das deutsche Python-Forum

Code: Alles auswählen

class Download_Thread(QThread):
    finished_thread = pyqtSignal()
    notify_progress = pyqtSignal(int)
 
    def __init__(self, loc, link):
        QThread.__init__(self)
 
        self.url = link
        self.location = loc

        self._run_semaphore = QSemaphore(1)
 
    def run(self):
        print self.url
        print self.location
        file = requests.get(self.url, stream=True)
        file_size = int(requests.head(self.url).headers.get('content-length', [0]))
        print "%s Byte" %file_size
        result = file_size / (1024*5)
        print result
        chunk_size = int(result)
        downloaded_bytes = 0
            
        with open(self.location, 'wb') as fd:
            for chunk in file.iter_content(chunk_size):
                fd.write(chunk)
                downloaded_bytes = fd.tell() # sehr genau und direkt
                print (float(downloaded_bytes)/file_size*100)
                self.notify_progress.emit(float(downloaded_bytes)/file_size*100)
                if self._run_semaphore.available() == 0:
                    self._run_semaphore.release(1)
                    break
 
        print "Finish"
        self.finished_thread.emit()

    def stop(self):
        print "Cancel"
        self.finished_thread.emit()
        self._run_semaphore.acquire(1)
 
if __name__ == "__main__":
    app = QApplication(sys.argv)
    window = MyCustomDialog()
    window.resize(600, 400)
    window.show()
    sys.exit(app.exec_())

Code: Alles auswählen

import os
import requests
import sys
 
from PyQt4.QtCore import QThread, pyqtSignal, Qt, QSemaphore
from PyQt4.QtGui import QVBoxLayout, QPushButton, QDialog, QProgressBar, QApplication

class MyCustomDialog(QDialog):
 
    def __init__(self, parent=None):
        super(MyCustomDialog, self).__init__(parent)
        layout = QVBoxLayout(self)
 
        # Create a progress bar and a button and add them to the main layout
        self.progressBar = QProgressBar(self)
        self.progressBar.setAlignment(Qt.AlignCenter)
        #self.progressBar.setValue(0)
        #self.progressBar.setRange(0, 1)
        layout.addWidget(self.progressBar)
 
        button = QPushButton("Start", self)
        layout.addWidget(button)
        buttonCnacel = QPushButton("Cancel", self)
        layout.addWidget(buttonCnacel)
 
        button.clicked.connect(self.check_folder_exists)
 
        # Set data for download and saving in path
        self.location = os.path.abspath(os.path.join('temp', 'example-app-0.3.win32.zip'))
        self.url = 'http://sophus.bplaced.net/download/example-app-0.3.win32.zip'
 
        self.download_task = Download_Thread(self.location, self.url)
        self.download_task.notify_progress.connect(self.on_progress)
        self.download_task.finished_thread.connect(self.on_finished)

        buttonCnacel.clicked.connect(self.download_task.stop)
 
    def on_progress(self, i):            
        self.progressBar.setValue(i)
 
    def on_start(self):
        self.download_task.start()
 
    def check_folder_exists(self):
        location = os.path.abspath(os.path.join('temp'))
        if not os.path.exists(location):
            os.makedirs(location)
            print "Folder was created"
            self.on_start()
        else:
            print "Folder already exists"
            self.on_start()
 
    def on_finished(self):
        print "stop"
        self.progressBar.setValue(0)

    def closeEvent(self, evnt):
        self.connect(self.download_task.stop)
 
 
class Download_Thread(QThread):
    finished_thread = pyqtSignal()
    notify_progress = pyqtSignal(int)
 
    def __init__(self, loc, link):
        QThread.__init__(self)
 
        self.url = link
        self.location = loc

        self._run_semaphore = QSemaphore(1)
 
    def run(self):
        file = requests.get(self.url, stream=True)
        file_size = int(requests.head(self.url).headers.get('content-length', [0]))
        print "%s Byte" %file_size
        result = file_size / (1024*5)
        print result
        chunk_size = int(result)
        downloaded_bytes = 0

        with open(self.location, 'wb') as fd:
            for chunk in file.iter_content(chunk_size):
                fd.write(chunk)
                downloaded_bytes = fd.tell() 
                print (float(downloaded_bytes)/file_size*100)
                self.notify_progress.emit(float(downloaded_bytes)/file_size*100)
                if self._run_semaphore.available() == 0:
                    self._run_semaphore.release(1)
                    break
 
        print "Finish"
        self.finished_thread.emit()

    def stop(self):
        print "Cancel"
        self.finished_thread.emit()
        self._run_semaphore.acquire(1)
 
if __name__ == "__main__":
    app = QApplication(sys.argv)
    window = MyCustomDialog()
    window.resize(600, 400)
    window.show()
    sys.exit(app.exec_())

Code: Alles auswählen

try:
    # some piece of Code
    # now we simulate an error:
    throw SomeSpecialError("something went wrong")
    # more Code
except SomeSpecialError:
    # react on that special error somehow...

Code: Alles auswählen

import requests

url1 = 'http://sophu.bplaced.net/changelog/version.txt2'

def start():
    try:
        response = requests.get(url1)
    except requests.exceptions.HTTPError as e:
        print "And you get an HTTPError:", e.message
    except requests.exceptions.URLRequired as url_r:
        print "And you get an URLRequired: ", url_r

start()

Code: Alles auswählen

1 / 0

Code: Alles auswählen

import requests

url = 'http://sophus.bplaced.net/changelog/version.txt3'

def start():
    response = requests.get(url)     
start()

Code: Alles auswählen

import requests

requests.get('http://sophus.bplaced.net/changelog/version.txt3')
<Response [200]>