I try to send data on Mosquitto Broker and add this same data on SQLite This is my script:
#!/usr/bin/python3
# -*- coding: utf-8 -*-
import sqlite3
import logging
class Photos:
def __init__(self):
#Connection a la basse de donnees sqlite3
self.db = sqlite3.connect('/home/pi/FlowerPower.db')
#Preparation d'un objet cursor qui va executer les futures requetes SQL sur la base de donnees
self.cursor = self.db.cursor()
logging.basicConfig(filename='subscribeFP.log',level=logging.DEBUG, format='%(asctime)s %(message)s', datefmt='%m/%d/%Y %I:%M:%S %p')
def traitement(self, msg, numSonde):
try:
#Convertit le message poste par le publisher de byte a string
queryArgs = str(msg.payload)
#Variable nom de la sonde
nomSonde = str(numSonde[2])
#Prepare la requete SQL pour la table photo
queryText = "INSERT INTO photos(sonde, date, photos) VALUES (?, ?, ?)", (nomSonde, strftime('%%d-%%m-%%Y %%H:%%%M:%%S','now','localtime'), queryArgs)
#Execute la requete SQL sur la BDD
self.cursor.execute(str(queryText))
#Commit pour etre sur que la requete SQL est effectuee
self.db.commit()
#Code d'exception
except sqlite3.Error as e:
self.logging.error('Erreur Sqlite3: ' + str(e))
#Retour en arrière si il y a une erreur (proprietes ACID)
self.db.rollback()
When I send data with a mosquitto_pub
I have this error:
File "/usr/lib/python3/dist-packages/mosquitto.py", line 720, in loop
rc = self.loop_read(max_packets)
File "/usr/lib/python3/dist-packages/mosquitto.py", line 961, in loop_read
rc = self._packet_read()
File "/usr/lib/python3/dist-packages/mosquitto.py", line 1360, in _packet_read
rc = self._packet_handle()
File "/usr/lib/python3/dist-packages/mosquitto.py", line 1775, in _packet_handle
return self._handle_publish()
File "/usr/lib/python3/dist-packages/mosquitto.py", line 1888, in _handle_publish
self.on_message(self, self._userdata, message)
File "insertionBdd.py", line 37, in on_message
photos.traitement(msg, numSonde)
File "/home/pi/photosFP.py", line 22, in traitement
queryText = "INSERT INTO photos(sonde, date, photos) VALUES (?, ?, ?)", (nomSonde, strftime('%%d-%%m-%%Y %%H:%%%M:%%S','now','localtime'), queryArgs)
NameError: global name 'strftime' is not defined
I don't understand why I have this error and I have already try to add: "from datetime importe datetime"
My other script, run with strftime
but there are not this problem...
Somebody can help me, please?
Like the message says, you haven't defined strftime
, you've only defined datetime
.
strftime
is a method of a datetime object. However, you seem to be calling it as a standalone function, passing it some strings: that's not at all how it works. I'm not sure what you are trying to do, but it looks like you want to get the current time and format that. So, you need to actually call the relevant methods:
datetime.now().strftime('%d-%m-%Y %H:%M:%S')
I'm also not sure what 'localtime'
is doing in your code, or why you doubled the percent signs.
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With