Skip to content
GitLab
Menu
Projects
Groups
Snippets
Loading...
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Sign in
Toggle navigation
Menu
Open sidebar
AVPetukhov
Practica 2021
Commits
b56def20
Commit
b56def20
authored
Jul 11, 2021
by
AVPetukhov
Browse files
Delete consumerV3.py
parent
dbb543bc
Changes
1
Hide whitespace changes
Inline
Side-by-side
consumerV3.py
deleted
100644 → 0
View file @
dbb543bc
import
json
import
matplotlib.pyplot
as
plt
import
pika
,
sys
,
os
,
math
x
=
[]
y
=
[]
plt
.
grid
()
def
main
():
credentials
=
pika
.
PlainCredentials
(
'Anton'
,
'Anton'
)
connection
=
pika
.
BlockingConnection
(
pika
.
ConnectionParameters
(
host
=
'217.9.89.214'
,
port
=
5672
,
virtual_host
=
'/'
,
credentials
=
credentials
))
channel
=
connection
.
channel
()
channel
.
queue_declare
(
queue
=
'Anton'
)
def
callback
(
ch
,
method
,
properties
,
body
):
print
(
"Received %r"
%
body
)
a
=
json
.
loads
(
body
)
print
(
a
)
for
i
in
range
(
151
):
inndict
=
a
[
i
]
x
.
append
(
inndict
[
'x'
])
y
.
append
(
inndict
[
'y'
])
if
len
(
x
)
==
151
and
len
(
y
)
==
151
:
return
plotbuilder
(
x
,
y
)
def
plotbuilder
(
x
,
y
):
plt
.
title
(
'y=x^2'
)
plt
.
plot
(
x
,
y
,
color
=
"#27B685"
)
plt
.
show
()
channel
.
basic_consume
(
queue
=
'Anton'
,
on_message_callback
=
callback
,
auto_ack
=
True
)
print
(
'Waiting for messages. To exit press CTRL+C'
)
channel
.
start_consuming
()
if
__name__
==
'__main__'
:
try
:
main
()
except
KeyboardInterrupt
:
print
(
'Interrupted'
)
try
:
sys
.
exit
(
0
)
except
SystemExit
:
os
.
_exit
(
0
)
\ No newline at end of file
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