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
d7715ddc
Commit
d7715ddc
authored
Feb 06, 2023
by
rakesh.pv
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
modification done
parent
afc05fff
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
32 additions
and
16 deletions
+32
-16
main.py
+1
-1
scripts/core/routes/routes.py
+17
-0
scripts/core/services/app.py
+14
-15
No files found.
main.py
View file @
d7715ddc
import
uvicorn
import
uvicorn
uvicorn
.
run
(
"scripts.core.services.app:app"
)
uvicorn
.
run
(
"scripts.core.services.app:app"
,
port
=
7000
)
scripts/core/routes/routes.py
0 → 100644
View file @
d7715ddc
from
fastapi
import
APIRouter
from
scripts.core.handlers.create_new_patient_data
import
insert_new_data
,
publish_to_mqtt
router
=
APIRouter
()
@router.get
(
"/"
)
def
index
():
return
{
"message :"
,
" FAST API IS CONNECTED"
}
# ->scripts.core.handlers.create_new_patient_data
@router.get
(
"/consulation/"
)
def
consult_doctor
():
x
=
insert_new_data
()
publish_to_mqtt
(
x
)
scripts/core/services/app.py
View file @
d7715ddc
from
fastapi
import
FastAPI
,
APIRouter
from
fastapi
import
FastAPI
,
APIRouter
from
fastapi
import
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
from
scripts.core.handlers.create_new_patient_data
import
insert_new_data
,
publish_to_mqtt
from
scripts.core.routes
import
routes
app
=
FastAPI
()
app
=
FastAPI
()
router
=
APIRouter
(
prefix
=
'/test'
,
tags
=
[
'task'
]
)
@app.get
(
"/"
)
@app.get
(
"/"
)
def
index
():
def
index
():
return
{
"message :"
,
" FAST API IS CONNECTED"
}
return
{
" message : FastApi Connected"
}
# ->scripts.core.handlers.create_new_patient_data
@app.get
(
"/consulation/"
)
def
consult_doctor
():
x
=
insert_new_data
()
publish_to_mqtt
(
x
)
app
.
include_router
(
routes
.
router
)
# @router.get("/")
# def index():
# return {"message :", " FAST API IS CONNECTED"}
#
#
# # ->scripts.core.handlers.create_new_patient_data
# @router.get("/consulation/")
# def consult_doctor():
# x = insert_new_data()
# publish_to_mqtt(x)
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