Skip to content
GitLab
Projects
Groups
Snippets
Help
Loading...
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Sign in / Register
Toggle navigation
C
compact-slowcontrol
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Locked Files
Issues
4
Issues
4
List
Boards
Labels
Service Desk
Milestones
Iterations
Merge Requests
0
Merge Requests
0
Requirements
Requirements
List
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Test Cases
Security & Compliance
Security & Compliance
Dependency List
License Compliance
Operations
Operations
Incidents
Environments
Packages & Registries
Packages & Registries
Package Registry
Container Registry
Analytics
Analytics
CI / CD
Code Review
Insights
Issue
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
Peter-Bernd Otte
compact-slowcontrol
Commits
f77e6035
Commit
f77e6035
authored
Aug 15, 2019
by
Peter-Bernd Otte
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Changed HTTP Headers and more MQTT debug msgs
parent
12b66cb3
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
5 additions
and
5 deletions
+5
-5
python/mqttWebServer/mqttWebServer.py
python/mqttWebServer/mqttWebServer.py
+5
-5
No files found.
python/mqttWebServer/mqttWebServer.py
100644 → 100755
View file @
f77e6035
...
...
@@ -57,8 +57,8 @@ client= paho.Client(args.mqtt_client_name)
client
.
on_message
=
on_message
client
.
on_connect
=
on_connect
client
.
on_disconnect
=
on_disconnect
logger
.
debug
(
"connecting to broker "
+
args
.
mqtt_broker_host
)
client
.
enable_logger
(
logger
)
logger
.
info
(
"connecting to broker "
+
args
.
mqtt_broker_host
)
client
.
connect
(
args
.
mqtt_broker_host
)
client
.
loop_start
()
#start loop to process received messages in separate thread
logger
.
info
(
"MQTT Loop started."
)
...
...
@@ -68,7 +68,7 @@ class SimpleHTTPRequestHandler(BaseHTTPRequestHandler):
def
do_GET
(
self
):
self
.
send_response
(
200
)
self
.
send_header
(
"Content-type"
,
"text/json;charset=UTF-8"
)
self
.
send_header
(
"Access-Control-Allow-Origin"
,
"
<origin> |
*"
)
self
.
send_header
(
"Access-Control-Allow-Origin"
,
"*"
)
self
.
end_headers
()
# self.path equals GET Parameter: "/foo/bar/".
erg
=
parse
.
parse
(
"/{topic}/set?{value:d}"
,
self
.
path
)
...
...
@@ -76,7 +76,7 @@ class SimpleHTTPRequestHandler(BaseHTTPRequestHandler):
#print(erg)
topic
=
unquote
(
erg
[
'topic'
])
if
erg
else
None
if
erg
and
topic
in
mlast
:
print
(
"topic:"
,
topic
)
#
print("topic:",topic)
if
'value'
in
erg
:
logger
.
info
(
"publish: "
+
str
(
topic
)
+
" value: "
+
str
(
erg
[
'value'
])
)
client
.
publish
(
topic
+
"/set"
,
erg
[
'value'
],
qos
=
1
,
retain
=
False
)
# send command to Relais
...
...
@@ -96,4 +96,4 @@ except KeyboardInterrupt:
logger
.
info
(
'^C received, shutting down the web server'
)
httpd
.
server_close
()
client
.
disconnect
()
client
.
loop_stop
()
\ No newline at end of file
client
.
loop_stop
()
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