Ist mein Code denn soweit OK? (Und kann mir bei der Gelegenheit vielleicht auch jemand sagen, wie ich die letzte auskommentierte Zeile einbauen müsste, damit die nicht geschlossen werden, während die Threads noch laufen?)
Code: Alles auswählen
#!/usr/bin/env python
# -*- coding: utf-8 -*-
import MySQLdb, feedparser, sys
from threading import Thread
class getNews(Thread):
def __init__ (self,url):
Thread.__init__(self)
self.url = url
def run(self):
feed = feedparser.parse(self.url)
for entry in feed.entries:
try:
cursor.execute('INSERT INTO nachrichten(titel, url) VALUES("%s", "%s")', (entry.title.replace('\n', ' '), entry.link))
except:
pass
try:
db = MySQLdb.connect(host = 'rdbms.strato.de', user = 'HANNOVER96', passwd = 'muttisliebling', db = 'KGB567125')
cursor = db.cursor()
except:
sys.exit('Could not connect to database server')
cursor.execute('SELECT url FROM feedquellen')
for response in cursor:
t = getNews(response[0])
t.start()
# cursor.close(); db.close();