Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
M
mqtt_redis
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
rakesh.pv
mqtt_redis
Commits
afc05fff
Commit
afc05fff
authored
Feb 06, 2023
by
rakesh.pv
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
modification done
parent
a5ad958b
Show whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
32 additions
and
34 deletions
+32
-34
scripts/core/handlers/assign_doctor_to_patient.py
+4
-4
scripts/core/handlers/create_new_patient_data.py
+12
-5
scripts/core/handlers/store_patient_details_in_redis.py
+4
-2
scripts/core/services/app.py
+12
-23
No files found.
scripts/core/handlers/assign_doctor_to_patient.py
View file @
afc05fff
...
...
@@ -7,15 +7,15 @@ mqtt_client = mqtt.Client()
mqtt_client
.
connect
(
MQTT_HOST
,
MQTT_PORT
)
#
no_of_doctor
=
int
(
input
(
" enter the number of doctor [ mqtt topic ]"
))
c
=
0
c
ount
=
0
def
assign_doctor_to_patient
(
patient_id
):
try
:
global
c
global
c
ount
c
=
(
c
+
1
)
doctor_topic
=
"doctor"
+
str
(
c
)
c
ount
=
(
count
+
1
)
doctor_topic
=
"doctor"
+
str
(
c
ount
)
r
.
set
(
patient_id
,
doctor_topic
)
print
(
patient_id
,
" assigned to "
,
doctor_topic
)
...
...
scripts/core/handlers/create_new_patient_data.py
View file @
afc05fff
import
json
import
paho.mqtt.client
as
mqtt
from
scripts.config.mqtt_connection
import
MQTT_TOPIC
,
MQTT_HOST
,
MQTT_PORT
from
scripts.core.handlers.store_patient_details_in_redis
import
insert_data_redis
# from scripts.core.handlers.assign_doctor_to_patient import send_patient_details
def
insert_new_data
():
patient_name
=
input
(
"enter patient name"
)
patient_id
=
int
(
input
(
"enter patient id"
))
...
...
@@ -29,7 +28,15 @@ def insert_new_data():
print
(
" data that will be published to broker is :
\n\n
"
,
"patiend id :
\n
"
,
patient_id
,
"
\n
patient description
\n\n
"
,
json
.
dumps
(
data_to_be_sent
))
# -> scripts.core.handlers.store_patient_details_in_redis
Mqtt_msg
=
json
.
dumps
(
data_to_be_sent
)
insert_data_redis
(
patient_id
,
json
.
dumps
(
data_to_be_sent
))
Mqtt_msg
=
json
.
dumps
(
entire_data
)
return
Mqtt_msg
def
publish_to_mqtt
(
x
):
mqttc
=
mqtt
.
Client
()
mqttc
.
connect
(
MQTT_HOST
,
MQTT_PORT
)
mqttc
.
publish
(
MQTT_TOPIC
,
x
)
mqttc
.
loop_forever
()
scripts/core/handlers/store_patient_details_in_redis.py
View file @
afc05fff
from
scripts.config.mqtt_connection
import
MQTT_TOPIC
,
MQTT_HOST
,
MQTT_PORT
from
scripts.config.redis_connection
import
r
from
scripts.core.handlers.assign_doctor_to_patient
import
assign_doctor_to_patient
...
...
@@ -22,6 +25,5 @@ def check_patient_id(patient_id):
def
insert_data_redis
(
patient_id
,
x
):
# -> scripts.core.handlers.check_patient_visited
check_patient_id
(
patient_id
)
# -> scripts.core.handlers.check_patient_visited
scripts/core/services/app.py
View file @
afc05fff
import
paho.mqtt.client
as
mqtt
from
fastapi
import
FastAPI
from
scripts.config.mqtt_connection
import
MQTT_HOST
,
MQTT_PORT
,
MQTT_TOPIC
from
scripts.core.handlers.create_new_patient_data
import
insert_new_data
from
fastapi
import
FastAPI
,
APIRouter
from
scripts.config.mqtt_connection
import
MQTT_TOPIC
,
MQTT_HOST
,
MQTT_PORT
from
scripts.core.handlers.create_new_patient_data
import
insert_new_data
,
publish_to_mqtt
app
=
FastAPI
()
router
=
APIRouter
(
prefix
=
'/test'
,
tags
=
[
'task'
]
)
@app.get
(
"/"
)
def
index
():
...
...
@@ -15,24 +21,7 @@ def index():
# ->scripts.core.handlers.create_new_patient_data
@app.get
(
"/consulation/"
)
def
consult_doctor
():
x
=
insert_new_data
()
def
on_publish
(
client
,
userdata
,
mid
):
print
(
"Message Published..."
)
def
on_connect
(
client
,
userdata
,
flags
,
rc
):
client
.
subscribe
(
MQTT_TOPIC
)
client
.
publish
(
MQTT_TOPIC
,
x
)
def
on_message
(
client
,
userdata
,
msg
):
print
(
msg
.
topic
)
print
(
msg
.
payload
)
x
=
insert_new_data
()
publish_to_mqtt
(
x
)
client
.
disconnect
()
mqttc
=
mqtt
.
Client
()
mqttc
.
on_publish
=
on_publish
mqttc
.
on_connect
=
on_connect
mqttc
.
on_message
=
on_message
mqttc
.
connect
(
MQTT_HOST
,
MQTT_PORT
)
mqttc
.
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