Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
K
kl_task7_MQTTreceiver
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
arun.uday
kl_task7_MQTTreceiver
Commits
ef07dc7b
Commit
ef07dc7b
authored
Feb 06, 2023
by
arun.uday
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
commit4
parent
c4ca5413
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
31 additions
and
26 deletions
+31
-26
scripts/config/application_config.py
+1
-0
scripts/core/handlers/operations_db.py
+2
-2
scripts/services/receiver_app_services_run.py
+28
-24
No files found.
scripts/config/application_config.py
View file @
ef07dc7b
...
...
@@ -8,6 +8,7 @@ config.read("conf/applications.conf")
# path
base_path
=
config
.
get
(
"path"
,
'base_path'
)
sub_path
=
config
.
get
(
"path"
,
"sub_path"
)
full_path
=
base_path
+
sub_path
# mqtt
...
...
scripts/core/handlers/operations_db.py
View file @
ef07dc7b
import
sqlite3
from
scripts.config.application_config
import
db_name
,
db_table
from
scripts.config.application_config
import
db_name
,
db_table
,
full_path
from
scripts.utilis.db_queries
import
DbQueries
class
SqliteOperations
:
def
__init__
(
self
):
# connecting to the database
self
.
conn
=
sqlite3
.
connect
(
db_name
)
self
.
conn
=
sqlite3
.
connect
(
full_path
+
db_name
)
def
create_db
(
self
):
try
:
...
...
scripts/services/receiver_app_services_run.py
View file @
ef07dc7b
...
...
@@ -14,28 +14,32 @@ app = FastAPI()
@app.get
(
"/"
)
def
receiver
():
def
on_connect
(
client_name
,
userdata
,
flags
,
rc
):
print
(
userdata
,
" "
,
flags
)
print
(
"Connected with result code "
+
str
(
rc
))
client_name
.
subscribe
(
topic_name
)
try
:
def
on_connect
(
client_name
,
userdata
,
flags
,
rc
):
print
(
userdata
,
" "
,
flags
)
print
(
"Connected with result code "
+
str
(
rc
))
client_name
.
subscribe
(
topic_name
)
def
on_message
(
client_name
,
userdata
,
msg
):
print
(
client_name
,
" "
,
userdata
)
# decoding the msg to string
payload_decoded
=
msg
.
payload
.
decode
(
utf_encode
)
json_data
=
json
.
loads
(
payload_decoded
)
# decoded msg to list
data_list
=
list
(
json_data
.
values
())
# list to dataframe
frames
=
pd
.
DataFrame
(
data_list
,
index
=
None
)
obj_db
=
SqliteOperations
()
# inserting the data to table
obj_db
.
insert_db
(
frames
)
# fetching the data
data_fetched
=
obj_db
.
fetch_data
()
display_fetched_data
(
data_fetched
)
client
=
mqtt
.
Client
()
client
.
connect
(
mqtt_host
,
int
(
port
),
int
(
request_no
))
client
.
on_connect
=
on_connect
client
.
on_message
=
on_message
client
.
loop_forever
()
except
Exception
as
e
:
print
(
e
)
def
on_message
(
client_name
,
userdata
,
msg
):
print
(
client_name
,
" "
,
userdata
)
# decoding the msg to string
payload_decoded
=
msg
.
payload
.
decode
(
utf_encode
)
json_data
=
json
.
loads
(
payload_decoded
)
# decoded msg to list
data_list
=
list
(
json_data
.
values
())
# list to dataframe
frames
=
pd
.
DataFrame
(
data_list
,
index
=
None
)
obj_db
=
SqliteOperations
()
# inserting the data to table
obj_db
.
insert_db
(
frames
)
# fetching the data
data_fetched
=
obj_db
.
fetch_data
()
display_fetched_data
(
data_fetched
)
client
=
mqtt
.
Client
()
client
.
connect
(
mqtt_host
,
int
(
port
),
int
(
request_no
))
client
.
on_connect
=
on_connect
client
.
on_message
=
on_message
client
.
loop_forever
()
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