Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
M
mqtt-reciever
Overview
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
mohammed.shibili
mqtt-reciever
Commits
8106105d
Commit
8106105d
authored
Jan 27, 2023
by
mohammed.shibili
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
receiver final commit
parent
6fc94101
Hide whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
33 additions
and
7 deletions
+33
-7
app.py
+1
-2
conf/apps.conf
+7
-0
scripts/config/appconf.py
+10
-0
scripts/serviece/main.py
+15
-5
No files found.
app.py
View file @
8106105d
from
scripts.serviece.reciever
import
on_message
,
on_connect
from
scripts.serviece.main
import
on_message
,
on_connect
on_connect
()
on_connect
()
on_message
()
on_message
()
conf/apps.conf
0 → 100644
View file @
8106105d
[
log
]
host_name
=
192
.
168
.
0
.
220
port_num
=
1883
db_name
=
mqtt
.
db
topic
=
json_data
time
=
60
\ No newline at end of file
scripts/config/appconf.py
0 → 100644
View file @
8106105d
import
configparser
config
=
configparser
.
RawConfigParser
()
config
.
read
(
"conf/apps.conf"
)
host_name
=
config
.
get
(
"log"
,
"host_name"
)
port_num
=
int
(
config
.
get
(
"log"
,
"port_num"
))
db_name
=
config
.
get
(
"log"
,
"db_name"
)
topic
=
config
.
get
(
"log"
,
"topic"
)
time
=
int
(
config
.
get
(
"log"
,
"time"
))
\ No newline at end of file
scripts/serviece/
reciever
.py
→
scripts/serviece/
main
.py
View file @
8106105d
...
@@ -2,15 +2,20 @@ import json
...
@@ -2,15 +2,20 @@ import json
import
sqlite3
import
sqlite3
import
paho.mqtt.client
as
mqtt
import
paho.mqtt.client
as
mqtt
from
scripts.config.appconf
import
host_name
,
port_num
,
db_name
,
topic
,
time
def
on_connect
(
client
,
userdata
,
flags
,
rc
):
def
on_connect
(
client
,
userdata
,
flags
,
rc
):
client
.
subscribe
(
"json_data"
)
try
:
print
(
"Connected with result code "
+
str
(
rc
))
client
.
subscribe
(
topic
)
print
(
"Connected with result code "
+
str
(
rc
))
except
Exception
as
e
:
print
(
"db connection error"
,
e
)
def
on_message
(
client
,
userdata
,
message
):
def
on_message
(
client
,
userdata
,
message
):
data_from_mqtt
=
json
.
loads
(
message
.
payload
.
decode
())
data_from_mqtt
=
json
.
loads
(
message
.
payload
.
decode
())
connection
=
sqlite3
.
connect
(
'mqtt.db'
)
connection
=
sqlite3
.
connect
(
db_name
)
cursor
=
connection
.
cursor
()
cursor
=
connection
.
cursor
()
cursor
.
execute
(
'''CREATE TABLE IF NOT EXISTS mqtt_data
cursor
.
execute
(
'''CREATE TABLE IF NOT EXISTS mqtt_data
(id INT,first_name varchar(20),last_name varchar(20))'''
)
(id INT,first_name varchar(20),last_name varchar(20))'''
)
...
@@ -25,6 +30,11 @@ def on_message(client, userdata, message):
...
@@ -25,6 +30,11 @@ def on_message(client, userdata, message):
client
=
mqtt
.
Client
()
client
=
mqtt
.
Client
()
client
.
on_message
=
on_message
client
.
on_message
=
on_message
client
.
connect
(
"192.168.0.220"
,
1883
,
60
)
client
.
connect
(
host_name
,
port_num
,
time
)
client
.
on_connect
=
on_connect
client
.
on_connect
=
on_connect
client
.
loop_forever
()
try
:
client
.
loop_forever
()
except
KeyboardInterrupt
:
client
.
loop_stop
()
client
.
disconnect
()
print
(
"receiver stopped"
)
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment