Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
D
Data Quality Checking Subscriber
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Analytics
CI / CD Analytics
Repository Analytics
Value Stream Analytics
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
ajil.k
Data Quality Checking Subscriber
Commits
60834b5b
Commit
60834b5b
authored
Feb 21, 2023
by
ajil.k
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
updated
parent
6e498d0a
Changes
6
Hide whitespace changes
Inline
Side-by-side
Showing
6 changed files
with
5 additions
and
5 deletions
+5
-5
app.py
app.py
+1
-1
main.py
main.py
+1
-1
scripts/config/application_config.py
scripts/config/application_config.py
+0
-0
scripts/constants/mqtt_connection.py
scripts/constants/mqtt_connection.py
+1
-1
scripts/constants/redis_connection.py
scripts/constants/redis_connection.py
+1
-1
scripts/core/handlers/handle_subcribed_data.py
scripts/core/handlers/handle_subcribed_data.py
+1
-1
No files found.
app.py
View file @
60834b5b
# importing libraries
import
uvicorn
from
scripts.con
stants
.application_config
import
port_no
from
scripts.con
fig
.application_config
import
port_no
from
scripts.logging.logger
import
logger
if
__name__
==
"__main__"
:
...
...
main.py
View file @
60834b5b
# importing libraries
import
uvicorn
from
fastapi
import
FastAPI
from
scripts.con
stants
.application_config
import
port_no
from
scripts.con
fig
.application_config
import
port_no
from
scripts.services.subscriber
import
subscriber
app
=
FastAPI
()
...
...
scripts/con
stants
/application_config.py
→
scripts/con
fig
/application_config.py
View file @
60834b5b
File moved
scripts/constants/mqtt_connection.py
View file @
60834b5b
# MQTT client connection for publishing website information
import
paho.mqtt.client
as
mqtt
from
scripts.con
stants
.application_config
import
broker
,
mqtt_port
,
time_out
from
scripts.con
fig
.application_config
import
broker
,
mqtt_port
,
time_out
from
scripts.logging.logger
import
logger
...
...
scripts/constants/redis_connection.py
View file @
60834b5b
# Importing redis library
import
redis
from
scripts.con
stants
.application_config
import
host
,
redis_port
,
good_data
,
maintenance_data
,
error_data
from
scripts.con
fig
.application_config
import
host
,
redis_port
,
good_data
,
maintenance_data
,
error_data
from
scripts.logging.logger
import
logger
try
:
...
...
scripts/core/handlers/handle_subcribed_data.py
View file @
60834b5b
import
json
from
scripts.con
stants
.application_config
import
topic
from
scripts.con
fig
.application_config
import
topic
from
scripts.constants.mqtt_connection
import
mqtt_client_connection
from
scripts.core.handlers.store_in_redis
import
store_data_in_db
from
scripts.logging.logger
import
logger
...
...
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