Kann mir jemand mit MySQL und Python helfen?

Guten Morgen,

ich weiß nicht ob ich hier richtig bin. Ich versuche es einfach. Bitte eventuell verschieben oder löschen.

Also ich möchte mit Python Daten aus einer Tabelle von MySql raus hohlen und dann in eine andere Datenbank schreiben.

Ich kann auf die Datenbank zu greifen und auch etwas auslesen.

Jetzt brauche ich etwas Hilfe um die Daten mit dem richtigen Typ raus zu hohlen.

Details würde ich im Nächsten Beitrag schreiben. Weiß ja noch nicht ob ich hier Grundsätzlich richtig bin;-)

Danke schon jetzt.

Also versuche ich mein Vorhaben so gut ich kann zu erklären.

Ich habe einen Linuxrechner der Messwerte in eine Lokale MySQL Datenbank schreibt.

Die Tabelle besteht aus "ID" "TIME" "SENSOR" "WERT" wobei ID ein int mit Autoinkrement ist Time ein TIMESTAMP Sensor ein varchar und Wert wider ein int.

Dieser Rechner ist nicht immer mit dem Internet verbunden.

Ich möchte jetzt ein Python Skript schreiben das die ID von der Lokalen Datenbank mit einer Datenbank auf einem Server vergleicht.

Wenn die ID nicht die selbe ist möchte ich die Daten aus der Lokalen Datenbank in die Server Datenbank auf dem Server übertragen.

mycursor.execute("select MAX(ID) from raspi16")
myresult = mycursor.fetchall()
print(myresult)

Liefert mir zwar den Wert von ID aber leider nicht als integer sondern

[(35,)]

Also ist meine erste Hürde die Formatierung der Daten die ich aus der MySQL Datenbank hohle.

Ich hoffe ich habe mich einigermaßen erklären können.

Danke für die Hilfe

Danke für den Tipp.

Traceback (most recent call last):
  File "./testpy", line 57, in <module>
    myresult = mycursor.fetch()
AttributeError: 'CMySQLCursor' object has no attribute 'fetch'

Bekomme ich als Fehler zurück

Mit "fetchone()" klappt es aber.

Wieder eine kleinen Schritt weiter.

Mal versuchen etwas weiter zu kommen. Darf ich wenn ich die nächste Hürde finde wieder fragen?

Danke in der Zwischenzeit

Hallo bin nun am nächsten Stolperstein angelangt.

Ich möchte die Abfrage der Tabelle Dynamisch bzw Variabel machen.

Leider weiß ich nicht wie ich das anstellen soll.

Mein Code sieht so aus:

raspi16_cursor = mydb.cursor()
spiegel_cursor = mydb.cursor()

raspi16_cursor.execute("select MAX(ID) from raspi16")
anzahl_raspi16 = raspi16_cursor.fetchone()
print "raspi16 hat %d Eintraege!" % (anzahl_raspi16)
spiegel_cursor.execute("select MAX(ID) from spiegel")
anzahl_spiegel = spiegel_cursor.fetchone()
print "spiegel hat %d Eintraege!" % (anzahl_spiegel)
# berechnung der fehlenden Zeilen
fehlende = anzahl_raspi16[0] - anzahl_spiegel[0]

print "folgende Eintraege fehlen......!"
# Versuch eine Variable MySql Abrage zu machen
raspi16_cursor.execute("SELECT * FROM raspi16 ORDER BY ID LIMIT anzahl_raspi16[0],fehlende[0]")
myresult = raspi16_cursor.fetchall()

for x in myresult:
  print(x)# Hier wäre das schreiben der Werte in die andere Datenbank auch schön zu realisieren.

Auserdem möchte ich in der for Schleife die daten in meine Server Datenbank schreiben weiß aber nicht wie ich die unterschiedlichen werte richtig an die DB übertragen kann.

Zitat von whoami0501

Btw - wenn du derartige Zeitserien speicherst, solltest du dir vielleicht auch mal InfuxDB anschauen. Das nutze ich bei meiner Wetterstation auch.

Die InfluxDB wirkt für mich bei Zeitserien und Tools wie Grafana in der Performance weitaus überlegen.

Danke für den Tipp ich möchte aber zuesrst mal ein wenig in die MySql Geschichte rein kommen.

In einem 2 Moment ist InfuxDb sicher interessant. Bin aber mit den ganzen noch zu Jungfräulich

Danke für die Hilfe

Hallo:-)

Konnte mein erste Problem mit den Platzhalter lösen.

raspi16_cursor = mydb.cursor()
spiegel_cursor = mydb.cursor()

raspi16_cursor.execute("select MAX(ID) from raspi16")
anzahl_raspi16 = raspi16_cursor.fetchone()
print "raspi16 hat %d Eintraege!" % (anzahl_raspi16)
spiegel_cursor.execute("select MAX(ID) from spiegel")
anzahl_spiegel = spiegel_cursor.fetchone()
print "spiegel hat %d Eintraege!" % (anzahl_spiegel)
# berechnung der fehlenden Zeilen
fehlende = anzahl_raspi16[0] - anzahl_spiegel[0]

print "folgende Eintraege fehlen......!"
raspi16_cursor.execute("SELECT * FROM raspi16 ORDER BY ID LIMIT %s,%s" % (anzahl_spiegel[0],fehlende))
myresult = raspi16_cursor.fetchall()

for x in myresult:
  print(x)
  #Hier fehlt jetzt das schreiben in die Serveer DB
print"xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx" 
mydb.close()

Jetzt müsste ich es noch schaffen mit der For Schleife in die Datenbank auf den Server die Daten zu schreiben.

Danke für die Hilfe

Guten Morgen,

habe gestern das Skript im Groben hin bekommen.

raspi16_cursor = mydb.cursor()
spiegel_cursor = mydb.cursor()

raspi16_cursor.execute("select MAX(ID) from raspi16")
anzahl_raspi16 = raspi16_cursor.fetchone()
print ("raspi16 hat %d Eintraege!" % (anzahl_raspi16))
spiegel_cursor.execute("select MAX(ID) from spiegel")
anzahl_spiegel = spiegel_cursor.fetchone()
print ("spiegel hat %d Eintraege!" % (anzahl_spiegel))
# berechnung der fehlenden Zeilen
fehlende = anzahl_raspi16[0] - anzahl_spiegel[0]

if fehlende >= 1:
    print("Es gibt Arbeit!")
    raspi16_cursor.execute("SELECT * FROM raspi16 ORDER BY ID LIMIT %s,%s" % (anzahl_spiegel[0],fehlende))
    myresult = raspi16_cursor.fetchall()
    for i in range (0, (fehlende-0)):
        mycursor = mydb.cursor()
        sql = "INSERT INTO spiegel (ID,TIME,EVENT, WERT) VALUES (%s, %s, %s, %s)"
        val = (myresult[i][0], myresult[i][1],myresult[i][2],myresult[i][3])
        mycursor.execute(sql, val)
        mydb.commit()
        print ("i=%d %d %s %s %s" % (i,myresult[i][0], myresult[i][1],myresult[i][2],myresult[i][3]))
else :
    print("NICHTS ZU TUN!")   

print("----------------------------------------------------------------------------------------------------" )
mydb.close()

Das Skript funktioniert. Wäre aber für Anregungen dankbar. Ist ja meine erste Erfahrung mit Python.

Zitat von whoami0501

Hast du bei den prints einfach die Klammern weggelassen oder arbeitest du ernsthaft mit Python2?

Das habe ich unbewusst getan. Wollte eigentlich Python3 schreiben.

Danke für die Hilfe

Kann man sich eine Wahrnung ausgeben lassen wenn man Python2 aus versehen macht?

Ok Danke für die Hilfe.

Gibt es zum Skript selbst auch Anmerkungen?