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
b2e45239
Commit
b2e45239
authored
Feb 03, 2023
by
rakesh.pv
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
85% work done
parent
69ccaa75
Show whitespace changes
Inline
Side-by-side
Showing
7 changed files
with
29 additions
and
28 deletions
+29
-28
.idea/misc.xml
+2
-1
.idea/python_redis.iml
+2
-1
scripts/core/handlers/assign_doctor_to_patient.py
+1
-0
scripts/core/handlers/check_patient_visited.py
+0
-21
scripts/core/handlers/create_new_patient_data.py
+2
-0
scripts/core/handlers/send_to_mqtt_patient_details.py
+0
-0
scripts/core/handlers/store_patient_details_in_redis.py
+22
-5
No files found.
.idea/misc.xml
View file @
b2e45239
<?xml version="1.0" encoding="UTF-8"?>
<?xml version="1.0" encoding="UTF-8"?>
<project
version=
"4"
>
<project
version=
"4"
>
<component
name=
"ProjectRootManager"
version=
"2"
project-jdk-name=
"Python 3.11 (
python
_redis)"
project-jdk-type=
"Python SDK"
/>
<component
name=
"ProjectRootManager"
version=
"2"
project-jdk-name=
"Python 3.11 (
mqtt
_redis)"
project-jdk-type=
"Python SDK"
/>
</project>
</project>
\ No newline at end of file
.idea/python_redis.iml
View file @
b2e45239
...
@@ -4,7 +4,7 @@
...
@@ -4,7 +4,7 @@
<content
url=
"file://$MODULE_DIR$"
>
<content
url=
"file://$MODULE_DIR$"
>
<excludeFolder
url=
"file://$MODULE_DIR$/venv"
/>
<excludeFolder
url=
"file://$MODULE_DIR$/venv"
/>
</content>
</content>
<orderEntry
type=
"
inheritedJdk
"
/>
<orderEntry
type=
"
jdk"
jdkName=
"Python 3.11 (mqtt_redis)"
jdkType=
"Python SDK
"
/>
<orderEntry
type=
"sourceFolder"
forTests=
"false"
/>
<orderEntry
type=
"sourceFolder"
forTests=
"false"
/>
</component>
</component>
</module>
</module>
\ No newline at end of file
scripts/core/handlers/assign_doctor_to_patient.py
View file @
b2e45239
...
@@ -19,6 +19,7 @@ def assign_doctor(patient_id):
...
@@ -19,6 +19,7 @@ def assign_doctor(patient_id):
r
.
set
(
patient_id
,
doctor_topic
)
r
.
set
(
patient_id
,
doctor_topic
)
print
(
patient_id
,
" assigned to "
,
doctor_topic
)
print
(
patient_id
,
" assigned to "
,
doctor_topic
)
except
Exception
as
e
:
except
Exception
as
e
:
print
(
"Exception occurred due to
\"
"
,
e
,
"
\"
"
)
print
(
"Exception occurred due to
\"
"
,
e
,
"
\"
"
)
...
...
scripts/core/handlers/check_patient_visited.py
deleted
100644 → 0
View file @
69ccaa75
from
scripts.config.redis_connection
import
r
from
scripts.core.handlers.assign_doctor_to_patient
import
assign_doctor
def
check_patient_id
(
patient_id
):
try
:
if
r
.
exists
(
patient_id
):
doctor_topic
=
r
.
get
(
patient_id
)
print
(
patient_id
,
" consulted "
,
doctor_topic
.
decode
(),
" before."
)
print
(
"patient id already present in redis database"
)
else
:
print
()
assign_doctor
(
patient_id
)
except
Exception
as
e
:
print
(
"Exception occurred due to
\"
"
,
e
,
"
\"
"
)
scripts/core/handlers/create_new_patient_data.py
View file @
b2e45239
import
json
import
json
from
scripts.core.handlers.assign_doctor_to_patient
import
send_patient_details
from
scripts.core.handlers.assign_doctor_to_patient
import
send_patient_details
from
scripts.core.handlers.store_patient_details_in_redis
import
insert_data_redis
from
scripts.core.handlers.store_patient_details_in_redis
import
insert_data_redis
def
insert_new_data
():
def
insert_new_data
():
patient_name
=
input
(
"enter patient name"
)
patient_name
=
input
(
"enter patient name"
)
patient_id
=
int
(
input
(
"enter patient id"
))
patient_id
=
int
(
input
(
"enter patient id"
))
patient_description
=
input
(
"enter patient description"
)
patient_description
=
input
(
"enter patient description"
)
...
...
scripts/core/handlers/send_to_mqtt_patient_details.py
0 → 100644
View file @
b2e45239
scripts/core/handlers/store_patient_details_in_redis.py
View file @
b2e45239
from
scripts.config.redis_connection
import
r
from
scripts.config.redis_connection
import
r
from
scripts.core.handlers.check_patient_visited
import
check_patient_id
from
scripts.core.handlers.assign_doctor_to_patient
import
assign_doctor
,
send_patient_details
from
scripts.core.handlers.assign_doctor_to_patient
import
assign_doctor
,
send_patient_details
def
check_patient_id
(
patient_id
):
try
:
if
r
.
exists
(
patient_id
):
doct
=
r
.
get
(
patient_id
)
print
(
patient_id
,
" consulted "
,
doct
.
decode
(),
" already in previous visit."
)
print
(
"patient id already present in redis database"
)
else
:
print
()
assign_doctor
(
patient_id
)
except
Exception
as
e
:
print
(
"Exception occurred due to
\"
"
,
e
,
"
\"
"
)
def
insert_data_redis
(
patient_id
,
x
):
def
insert_data_redis
(
patient_id
,
x
):
# -> scripts.core.handlers.check_patient_visited
# -> scripts.core.handlers.check_patient_visited
send_patient_details
(
x
)
check_patient_id
(
patient_id
)
check_patient_id
(
patient_id
)
r
.
set
(
patient_id
,
x
)
assign_doctor
(
patient_id
)
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