mirror of
https://git.kotyczka.ch/developers/django.git
synced 2025-04-06 07:45:08 +02:00
pyapp structure
This commit is contained in:
Peter Kotyczka
parent
df108da80b
commit
88ea419c20
4
.gitignore
vendored
4
.gitignore
vendored
@ -1,3 +1,3 @@
|
||||
virtualenv
|
||||
app/queue/data/*
|
||||
app/*/__pycache__
|
||||
pyapp/queue/data/*
|
||||
pyapp/*/__pycache__
|
||||
|
||||
@ -1,66 +0,0 @@
|
||||
import tkinter as tk
|
||||
|
||||
# Create a new window with the title "Address Entry Form"
|
||||
window = tk.Tk()
|
||||
window.title("Address Entry Form")
|
||||
|
||||
# Create a new frame `frm_form` to contain the Label
|
||||
# and Entry widgets for entering address information
|
||||
frm_form = tk.Frame(relief=tk.SUNKEN, borderwidth=3)
|
||||
# Pack the frame into the window
|
||||
frm_form.pack()
|
||||
|
||||
# List of field labels
|
||||
labels = [
|
||||
"First Name:",
|
||||
"Last Name:",
|
||||
"Address Line 1:",
|
||||
"Address Line 2:",
|
||||
"City:",
|
||||
"State/Province:",
|
||||
"Postal Code:",
|
||||
"Country:",
|
||||
]
|
||||
|
||||
# Loop over the list of field labels
|
||||
for idx, text in enumerate(labels):
|
||||
# Create a Label widget with the text from the labels list
|
||||
label = tk.Label(master=frm_form, text=text)
|
||||
# Create an Entry widget
|
||||
entry = tk.Entry(master=frm_form, width=50)
|
||||
# Use the grid geometry manager to place the Label and
|
||||
# Entry widgets in the row whose index is idx
|
||||
label.grid(row=idx, column=0, sticky="e")
|
||||
entry.grid(row=idx, column=1)
|
||||
|
||||
# Create a new frame `frm_buttons` to contain the
|
||||
# Submit and Clear buttons. This frame fills the
|
||||
# whole window in the horizontal direction and has
|
||||
# 5 pixels of horizontal and vertical padding.
|
||||
frm_buttons = tk.Frame()
|
||||
frm_buttons.pack(fill=tk.X, ipadx=5, ipady=5)
|
||||
|
||||
# Create an event handler
|
||||
def handle_keypress(event):
|
||||
"""Print the character associated to the key pressed"""
|
||||
print(event.char)
|
||||
|
||||
# Bind keypress event to handle_keypress()
|
||||
window.bind("<Key>", handle_keypress)
|
||||
|
||||
def handle_click(event):
|
||||
print("Adress was submitted")
|
||||
|
||||
# Create the "Submit" button and pack it to the
|
||||
# right side of `frm_buttons`
|
||||
btn_submit = tk.Button(master=frm_buttons, text="Submit")
|
||||
btn_submit.pack(side=tk.RIGHT, padx=10, ipadx=10)
|
||||
btn_submit.bind("<Button-1>", handle_click)
|
||||
|
||||
# Create the "Clear" button and pack it to the
|
||||
# right side of `frm_buttons`
|
||||
btn_clear = tk.Button(master=frm_buttons, text="Clear")
|
||||
btn_clear.pack(side=tk.RIGHT, ipadx=10)
|
||||
|
||||
# Start the application
|
||||
window.mainloop()
|
||||
@ -1,47 +0,0 @@
|
||||
import tkinter as tk
|
||||
|
||||
window = tk.Tk()
|
||||
label = tk.Label(
|
||||
text="Python rocks!",
|
||||
foreground="white", # Set the text color to white
|
||||
background="black" # Set the background color to black
|
||||
)
|
||||
|
||||
border_effects = {
|
||||
"flat": tk.FLAT,
|
||||
"sunken": tk.SUNKEN,
|
||||
"raised": tk.RAISED,
|
||||
"groove": tk.GROOVE,
|
||||
"ridge": tk.RIDGE,
|
||||
}
|
||||
for relief_name, relief in border_effects.items():
|
||||
frame = tk.Frame(master=window, relief=relief, borderwidth=5)
|
||||
frame.pack(side=tk.LEFT)
|
||||
label = tk.Label(master=frame, text=relief_name)
|
||||
label.pack()
|
||||
|
||||
label.pack()
|
||||
entry = tk.Entry()
|
||||
entry.pack()
|
||||
|
||||
name = entry.get()
|
||||
|
||||
frame_a = tk.Frame()
|
||||
|
||||
|
||||
label_a = tk.Label(master=frame_a, text="Personalliste")
|
||||
label_a.pack()
|
||||
|
||||
frame_a.pack()
|
||||
|
||||
text_box = tk.Text()
|
||||
text_box.pack()
|
||||
|
||||
frame_b = tk.Frame()
|
||||
label_b = tk.Label(master=frame_b, text="I'm in Frame B")
|
||||
label_b.pack()
|
||||
frame_b.pack()
|
||||
|
||||
|
||||
window.mainloop()
|
||||
print(name)
|
||||
@ -1,5 +0,0 @@
|
||||
username = 'smx'
|
||||
password = 'smx'
|
||||
|
||||
#username = 'mqadmin'
|
||||
#password = '3Mnj29jKBsFybc'
|
||||
@ -1,17 +0,0 @@
|
||||
import random
|
||||
import tkinter as tk
|
||||
|
||||
def roll():
|
||||
lbl_result["text"] = str(random.randint(1, 6))
|
||||
|
||||
window = tk.Tk()
|
||||
window.columnconfigure(0, minsize=150)
|
||||
window.rowconfigure([0, 1], minsize=50)
|
||||
|
||||
btn_roll = tk.Button(text="Roll", command=roll)
|
||||
lbl_result = tk.Label()
|
||||
|
||||
btn_roll.grid(row=0, column=0, sticky="nsew")
|
||||
lbl_result.grid(row=1, column=0)
|
||||
|
||||
window.mainloop()
|
||||
@ -1,94 +0,0 @@
|
||||
import tkinter as tk
|
||||
import config as conf
|
||||
import pika
|
||||
|
||||
from tkinter.filedialog import askopenfilename, asksaveasfilename
|
||||
|
||||
def send_queue_message():
|
||||
exchange_name = 'simple-editor'
|
||||
message_all = 'Sent from RabbitMQ'
|
||||
|
||||
print(message_all)
|
||||
credentials= pika.PlainCredentials(username= conf.username, password= conf.password)
|
||||
connection= pika.BlockingConnection(pika.ConnectionParameters(host='localhost', port=5672, credentials= credentials))
|
||||
channel= connection.channel()
|
||||
channel.exchange_declare(exchange = exchange_name, durable = True, exchange_type = 'topic')
|
||||
channel.queue_declare(queue = 'AllInfo')
|
||||
txt = txt_edit.get("1.0", tk.END)
|
||||
channel.queue_bind(exchange = exchange_name, queue = 'AllInfo', routing_key = 'new')
|
||||
channel.basic_publish(exchange = exchange_name, routing_key = 'new', body = txt)
|
||||
channel.close()
|
||||
|
||||
def get_queue_message():
|
||||
exchange_name = 'simple-editor'
|
||||
credentials= pika.PlainCredentials(username= conf.username, password= conf.password)
|
||||
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost', port=5672, credentials= credentials))
|
||||
channel = connection.channel()
|
||||
channel.exchange_declare(exchange_name, durable=True, exchange_type='topic')
|
||||
txt_edit.delete("1.0", tk.END)
|
||||
|
||||
def callback(ch,method,properties,body):
|
||||
message = 'Message from Queue Part: ' + body.decode("utf-8")
|
||||
txt_edit.insert(tk.END, message)
|
||||
ch.basic_publish('exchange_not_exist', routing_key='new',cbody='Nope this is wrong')
|
||||
##ch.basic_ack(delivery_tag = method.delivery_tag + 1)
|
||||
# Display the message parts
|
||||
channel.queue_bind(exchange = exchange_name, queue = 'AllInfo', routing_key = 'new')
|
||||
channel.basic_consume(queue='AllInfo', on_message_callback=callback, auto_ack=True)
|
||||
##channel.consume(queue = 'AllInfo')
|
||||
|
||||
# Close the channel and the connection
|
||||
channel.close()
|
||||
connection.close()
|
||||
message_all = 'Retrieved from RabbitMQ'
|
||||
print(message_all)
|
||||
|
||||
def open_file():
|
||||
"""Open a file for editing."""
|
||||
filepath = askopenfilename(
|
||||
filetypes=[("Text Files", "*.txt"), ("All Files", "*.*")]
|
||||
)
|
||||
if not filepath:
|
||||
return
|
||||
txt_edit.delete("1.0", tk.END)
|
||||
with open(filepath, mode="r", encoding="utf-8") as input_file:
|
||||
text = input_file.read()
|
||||
txt_edit.insert(tk.END, text)
|
||||
window.title(f"Simple Text Editor - {filepath}")
|
||||
|
||||
def save_file():
|
||||
"""Save the current file as a new file."""
|
||||
filepath = asksaveasfilename(
|
||||
defaultextension=".txt",
|
||||
filetypes=[("Text Files", "*.txt"), ("All Files", "*.*")],
|
||||
)
|
||||
if not filepath:
|
||||
return
|
||||
with open(filepath, mode="w", encoding="utf-8") as output_file:
|
||||
text = txt_edit.get("1.0", tk.END)
|
||||
output_file.write(text)
|
||||
window.title(f"Simple Text Editor - {filepath}")
|
||||
|
||||
window = tk.Tk()
|
||||
window.title("Simple Text Editor")
|
||||
|
||||
window.rowconfigure(0, minsize=800, weight=1)
|
||||
window.columnconfigure(1, minsize=800, weight=1)
|
||||
|
||||
|
||||
txt_edit = tk.Text(window)
|
||||
frm_buttons = tk.Frame(window, relief=tk.RAISED, bd=2)
|
||||
btn_open = tk.Button(frm_buttons, text="Open", command=open_file)
|
||||
btn_save = tk.Button(frm_buttons, text="Save As...", command=save_file)
|
||||
btn_send = tk.Button(frm_buttons, text="Send", command=send_queue_message)
|
||||
btn_receive = tk.Button(frm_buttons, text="Receive", command=get_queue_message)
|
||||
|
||||
btn_open.grid(row=0, column=0, sticky="ew", padx=5, pady=5)
|
||||
btn_save.grid(row=1, column=0, sticky="ew", padx=5)
|
||||
btn_send.grid(row=2, column=0, sticky="ew", padx=5, pady=5)
|
||||
btn_receive.grid(row=3, column=0, sticky="ew", padx=5, pady=5)
|
||||
|
||||
frm_buttons.grid(row=0, column=0, sticky="ns")
|
||||
txt_edit.grid(row=0, column=1, sticky="nsew")
|
||||
|
||||
window.mainloop()
|
||||
Binary file not shown.
@ -1,45 +0,0 @@
|
||||
import optparse
|
||||
from proton import Message
|
||||
from proton.handlers import MessagingHandler
|
||||
from proton.reactor import Container
|
||||
|
||||
|
||||
class Client(MessagingHandler):
|
||||
def __init__(self, url, requests):
|
||||
super(Client, self).__init__()
|
||||
self.url = url
|
||||
self.requests = requests
|
||||
|
||||
def on_start(self, event):
|
||||
self.sender = event.container.create_sender(self.url)
|
||||
self.receiver = event.container.create_receiver(self.sender.connection, None, dynamic=True)
|
||||
|
||||
def next_request(self):
|
||||
if self.receiver.remote_source.address:
|
||||
req = Message(reply_to=self.receiver.remote_source.address, body=self.requests[0])
|
||||
self.sender.send(req)
|
||||
|
||||
def on_link_opened(self, event):
|
||||
if event.receiver == self.receiver:
|
||||
self.next_request()
|
||||
|
||||
def on_message(self, event):
|
||||
print("%s => %s" % (self.requests.pop(0), event.message.body))
|
||||
if self.requests:
|
||||
self.next_request()
|
||||
else:
|
||||
event.connection.close()
|
||||
|
||||
|
||||
REQUESTS = ["Twas brillig, and the slithy toves",
|
||||
"Did gire and gymble in the wabe.",
|
||||
"All mimsy were the borogroves,",
|
||||
"And the mome raths outgrabe."]
|
||||
|
||||
parser = optparse.OptionParser(usage="usage: %prog [options]",
|
||||
description="Send requests to the supplied address and print responses.")
|
||||
parser.add_option("-a", "--address", default="localhost:5672/examples",
|
||||
help="address to which messages are sent (default %default)")
|
||||
opts, args = parser.parse_args()
|
||||
|
||||
Container(Client(opts.address, args or REQUESTS)).run()
|
||||
@ -1,29 +0,0 @@
|
||||
import optparse
|
||||
import time
|
||||
import os
|
||||
import sys
|
||||
from proton import Message
|
||||
from proton.utils import BlockingConnection
|
||||
from proton.handlers import IncomingMessageHandler
|
||||
|
||||
broker = '5672' ##os.getenv('AMQP_BROKER_HOST_PORT')
|
||||
queue = 'proton' ##os.getenv('AMQP_ADDRESS')
|
||||
user_arg = 'smx' ##os.getenv('AMQP_USER')
|
||||
userpw_arg = 'smx' ##os.getenv('AMQP_USER_PASSWORD')
|
||||
|
||||
conn = BlockingConnection(broker, user=user_arg, password=userpw_arg)
|
||||
receiver = conn.create_receiver(queue)
|
||||
|
||||
count = 0
|
||||
try:
|
||||
while True:
|
||||
msg = receiver.receive(timeout=None)
|
||||
count += 1
|
||||
print("got message, processing for two seconds...")
|
||||
sys.stdout.flush()
|
||||
time.sleep(2)
|
||||
receiver.accept()
|
||||
finally:
|
||||
conn.close()
|
||||
|
||||
print ("All done. Processed ", count, " messages.")
|
||||
@ -1,52 +0,0 @@
|
||||
from __future__ import print_function, unicode_literals
|
||||
import optparse
|
||||
from proton import Message
|
||||
from proton.handlers import MessagingHandler
|
||||
from proton.reactor import Container
|
||||
from proton.utils import BlockingConnection
|
||||
from django.conf import settings
|
||||
|
||||
broker = '5672' ##os.getenv('AMQP_BROKER_HOST_PORT')
|
||||
queue = 'proton' ##os.getenv('AMQP_ADDRESS')
|
||||
user_arg = 'smx' ##os.getenv('AMQP_USER')
|
||||
userpw_arg = 'smx' ##os.getenv('AMQP_USER_PASSWORD')
|
||||
|
||||
class Send(MessagingHandler):
|
||||
def __init__(self, url, messages):
|
||||
super(Send, self).__init__()
|
||||
self.url = url
|
||||
self.sent = 0
|
||||
self.confirmed = 0
|
||||
self.total = messages
|
||||
|
||||
def on_start(self, event):
|
||||
event.container.create_sender(self.url)
|
||||
|
||||
def on_sendable(self, event):
|
||||
while event.sender.credit and self.sent < self.total:
|
||||
msg = Message(id=(self.sent+1), body={'sequence':(self.sent+1)})
|
||||
event.sender.send(msg)
|
||||
self.sent += 1
|
||||
|
||||
def on_accepted(self, event):
|
||||
self.confirmed += 1
|
||||
if self.confirmed == self.total:
|
||||
print("all messages confirmed")
|
||||
event.connection.close()
|
||||
|
||||
def on_disconnected(self, event):
|
||||
self.sent = self.confirmed
|
||||
|
||||
conn = BlockingConnection(broker, user=user_arg, password=userpw_arg)
|
||||
|
||||
parser = optparse.OptionParser(usage="usage: %prog [options]",
|
||||
description="Send messages to the supplied address.")
|
||||
parser.add_option("-a", "--address", default="0.0.0.0:16161/examples",
|
||||
help="address to which messages are sent (default %default)")
|
||||
parser.add_option("-m", "--messages", type="int", default=100,
|
||||
help="number of messages to send (default %default)")
|
||||
opts, args = parser.parse_args()
|
||||
|
||||
try:
|
||||
Container(Send(opts.address, opts.messages)).run()
|
||||
except KeyboardInterrupt: pass
|
||||
@ -1,51 +0,0 @@
|
||||
import optparse
|
||||
import sys
|
||||
from proton import Condition, Message, Url
|
||||
from proton.handlers import MessagingHandler
|
||||
from proton.reactor import Container
|
||||
|
||||
exit_status = 0
|
||||
|
||||
|
||||
class Server(MessagingHandler):
|
||||
def __init__(self, url, address):
|
||||
super(Server, self).__init__()
|
||||
self.url = url
|
||||
self.address = address
|
||||
|
||||
def on_start(self, event):
|
||||
print("Listening on", self.url)
|
||||
self.container = event.container
|
||||
self.conn = event.container.connect(self.url, desired_capabilities="ANONYMOUS-RELAY")
|
||||
|
||||
def on_connection_opened(self, event):
|
||||
if event.connection.remote_offered_capabilities and 'ANONYMOUS-RELAY' in event.connection.remote_offered_capabilities:
|
||||
self.receiver = event.container.create_receiver(self.conn, self.address)
|
||||
self.server = self.container.create_sender(self.conn, None)
|
||||
else:
|
||||
global exit_status
|
||||
print("Server needs a broker which supports ANONYMOUS-RELAY", file=sys.stderr)
|
||||
exit_status = 1
|
||||
c = event.connection
|
||||
c.condition = Condition('amqp:not-implemented', description="ANONYMOUS-RELAY required")
|
||||
c.close()
|
||||
|
||||
def on_message(self, event):
|
||||
print("Received", event.message)
|
||||
self.server.send(Message(address=event.message.reply_to, body=event.message.body.upper(),
|
||||
correlation_id=event.message.correlation_id))
|
||||
|
||||
|
||||
parser = optparse.OptionParser(usage="usage: %prog [options]")
|
||||
parser.add_option("-a", "--address", default="localhost:5672/examples",
|
||||
help="address from which messages are received (default %default)")
|
||||
opts, args = parser.parse_args()
|
||||
|
||||
url = Url(opts.address)
|
||||
|
||||
try:
|
||||
Container(Server(url, url.path)).run()
|
||||
except KeyboardInterrupt:
|
||||
pass
|
||||
|
||||
sys.exit(exit_status)
|
||||
@ -1,96 +0,0 @@
|
||||
import tornado.ioloop
|
||||
import tornado.web
|
||||
from tornado.gen import coroutine
|
||||
from tornado.concurrent import Future
|
||||
from proton import Message
|
||||
from proton.handlers import MessagingHandler
|
||||
from proton_tornado import Container
|
||||
|
||||
|
||||
class Client(MessagingHandler):
|
||||
def __init__(self, host, address):
|
||||
super(Client, self).__init__()
|
||||
self.host = host
|
||||
self.address = address
|
||||
self.sent = []
|
||||
self.pending = []
|
||||
self.reply_address = None
|
||||
self.sender = None
|
||||
self.receiver = None
|
||||
|
||||
def on_start(self, event):
|
||||
conn = event.container.connect(self.host)
|
||||
self.sender = event.container.create_sender(conn, self.address)
|
||||
self.receiver = event.container.create_receiver(conn, None, dynamic=True)
|
||||
|
||||
def on_link_opened(self, event):
|
||||
if event.receiver == self.receiver:
|
||||
self.reply_address = event.link.remote_source.address
|
||||
self.do_request()
|
||||
|
||||
def on_sendable(self, event):
|
||||
self.do_request()
|
||||
|
||||
def on_message(self, event):
|
||||
if self.sent:
|
||||
request, future = self.sent.pop(0)
|
||||
print("%s => %s" % (request, event.message.body))
|
||||
future.set_result(event.message.body)
|
||||
self.do_request()
|
||||
|
||||
def do_request(self):
|
||||
if self.pending and self.reply_address and self.sender.credit:
|
||||
request, future = self.pending.pop(0)
|
||||
self.sent.append((request, future))
|
||||
req = Message(reply_to=self.reply_address, body=request)
|
||||
self.sender.send(req)
|
||||
|
||||
def request(self, body):
|
||||
future = Future()
|
||||
self.pending.append((body, future))
|
||||
self.do_request()
|
||||
self.container.touch()
|
||||
return future
|
||||
|
||||
|
||||
class ExampleHandler(tornado.web.RequestHandler):
|
||||
def initialize(self, client):
|
||||
self.client = client
|
||||
|
||||
def get(self):
|
||||
self._write_open()
|
||||
self._write_form()
|
||||
self._write_close()
|
||||
|
||||
@coroutine
|
||||
def post(self):
|
||||
response = yield self.client.request(self.get_body_argument("message"))
|
||||
self.set_header("Content-Type", "text/html")
|
||||
self._write_open()
|
||||
self._write_form()
|
||||
self.write("Response: " + response)
|
||||
self._write_close()
|
||||
|
||||
def _write_open(self):
|
||||
self.write('<html><body>')
|
||||
|
||||
def _write_close(self):
|
||||
self.write('</body></html>')
|
||||
|
||||
def _write_form(self):
|
||||
self.write('<form action="/client" method="POST">'
|
||||
'Request: <input type="text" name="message">'
|
||||
'<input type="submit" value="Submit">'
|
||||
'</form>')
|
||||
|
||||
|
||||
loop = tornado.ioloop.IOLoop.instance()
|
||||
client = Client("localhost:5672", "examples")
|
||||
client.container = Container(client, loop=loop)
|
||||
client.container.initialise()
|
||||
app = tornado.web.Application([tornado.web.url(r"/client", ExampleHandler, dict(client=client))])
|
||||
app.listen(8888)
|
||||
try:
|
||||
loop.start()
|
||||
except KeyboardInterrupt:
|
||||
loop.stop()
|
||||
@ -1,5 +0,0 @@
|
||||
username = 'smx'
|
||||
password = 'smx'
|
||||
|
||||
#username = 'mqadmin'
|
||||
#password = '3Mnj29jKBsFybc'
|
||||
@ -1,79 +0,0 @@
|
||||
#!/usr/bin/env python3
|
||||
#
|
||||
# Licensed to the Apache Software Foundation (ASF) under one
|
||||
# or more contributor license agreements. See the NOTICE file
|
||||
# distributed with this work for additional information
|
||||
# regarding copyright ownership. The ASF licenses this file
|
||||
# to you under the Apache License, Version 2.0 (the
|
||||
# "License"); you may not use this file except in compliance
|
||||
# with the License. You may obtain a copy of the License at
|
||||
#
|
||||
# http://www.apache.org/licenses/LICENSE-2.0
|
||||
#
|
||||
# Unless required by applicable law or agreed to in writing,
|
||||
# software distributed under the License is distributed on an
|
||||
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
||||
# KIND, either express or implied. See the License for the
|
||||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
#
|
||||
|
||||
import optparse
|
||||
from proton.handlers import MessagingHandler
|
||||
from proton.reactor import ApplicationEvent, Container, EventInjector
|
||||
from db_common import Db
|
||||
|
||||
|
||||
class Recv(MessagingHandler):
|
||||
def __init__(self, url, count):
|
||||
super(Recv, self).__init__(auto_accept=False)
|
||||
self.url = url
|
||||
self.delay = 0
|
||||
self.last_id = None
|
||||
self.expected = count
|
||||
self.received = 0
|
||||
self.accepted = 0
|
||||
self.db = Db("dst_db", EventInjector())
|
||||
|
||||
def on_start(self, event):
|
||||
event.container.selectable(self.db.injector)
|
||||
e = ApplicationEvent("id_loaded")
|
||||
e.container = event.container
|
||||
self.db.get_id(e)
|
||||
|
||||
def on_id_loaded(self, event):
|
||||
self.last_id = event.id
|
||||
event.container.create_receiver(self.url)
|
||||
|
||||
def on_record_inserted(self, event):
|
||||
self.accept(event.delivery)
|
||||
self.accepted += 1
|
||||
if self.accepted == self.expected:
|
||||
event.connection.close()
|
||||
self.db.close()
|
||||
|
||||
def on_message(self, event):
|
||||
id = int(event.message.id)
|
||||
if (not self.last_id) or id > self.last_id:
|
||||
if self.expected == 0 or self.received < self.expected:
|
||||
self.received += 1
|
||||
self.last_id = id
|
||||
self.db.insert(id, event.message.body, ApplicationEvent("record_inserted", delivery=event.delivery))
|
||||
print("inserted message %s" % id)
|
||||
else:
|
||||
self.release(event.delivery)
|
||||
else:
|
||||
self.accept(event.delivery)
|
||||
|
||||
|
||||
parser = optparse.OptionParser(usage="usage: %prog [options]")
|
||||
parser.add_option("-a", "--address", default="localhost:5672/examples",
|
||||
help="address from which messages are received (default %default)")
|
||||
parser.add_option("-m", "--messages", type="int", default=0,
|
||||
help="number of messages to receive; 0 receives indefinitely (default %default)")
|
||||
opts, args = parser.parse_args()
|
||||
|
||||
try:
|
||||
Container(Recv(opts.address, opts.messages)).run()
|
||||
except KeyboardInterrupt:
|
||||
pass
|
||||
@ -1,110 +0,0 @@
|
||||
#!/usr/bin/env python3
|
||||
#
|
||||
# Licensed to the Apache Software Foundation (ASF) under one
|
||||
# or more contributor license agreements. See the NOTICE file
|
||||
# distributed with this work for additional information
|
||||
# regarding copyright ownership. The ASF licenses this file
|
||||
# to you under the Apache License, Version 2.0 (the
|
||||
# "License"); you may not use this file except in compliance
|
||||
# with the License. You may obtain a copy of the License at
|
||||
#
|
||||
# http://www.apache.org/licenses/LICENSE-2.0
|
||||
#
|
||||
# Unless required by applicable law or agreed to in writing,
|
||||
# software distributed under the License is distributed on an
|
||||
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
||||
# KIND, either express or implied. See the License for the
|
||||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
#
|
||||
|
||||
import optparse
|
||||
import queue
|
||||
|
||||
|
||||
from proton import Message
|
||||
from proton.handlers import MessagingHandler
|
||||
from proton.reactor import ApplicationEvent, Container, EventInjector
|
||||
from db_common import Db
|
||||
|
||||
|
||||
class Send(MessagingHandler):
|
||||
def __init__(self, url, count):
|
||||
super(Send, self).__init__()
|
||||
self.url = url
|
||||
self.delay = 0
|
||||
self.sent = 0
|
||||
self.confirmed = 0
|
||||
self.load_count = 0
|
||||
self.records = queue.Queue(maxsize=50)
|
||||
self.target = count
|
||||
self.db = Db("src_db", EventInjector())
|
||||
|
||||
def keep_sending(self):
|
||||
return self.target == 0 or self.sent < self.target
|
||||
|
||||
def on_start(self, event):
|
||||
self.container = event.container
|
||||
self.container.selectable(self.db.injector)
|
||||
self.sender = self.container.create_sender(self.url)
|
||||
|
||||
def on_records_loaded(self, event):
|
||||
if self.records.empty():
|
||||
if event.subject == self.load_count:
|
||||
print("Exhausted available data, waiting to recheck...")
|
||||
# check for new data after 5 seconds
|
||||
self.container.schedule(5, self)
|
||||
else:
|
||||
self.send()
|
||||
|
||||
def request_records(self):
|
||||
if not self.records.full():
|
||||
print("loading records...")
|
||||
self.load_count += 1
|
||||
self.db.load(self.records, event=ApplicationEvent(
|
||||
"records_loaded", link=self.sender, subject=self.load_count))
|
||||
|
||||
def on_sendable(self, event):
|
||||
self.send()
|
||||
|
||||
def send(self):
|
||||
while self.sender.credit and not self.records.empty():
|
||||
if not self.keep_sending():
|
||||
return
|
||||
record = self.records.get(False)
|
||||
id = record['id']
|
||||
self.sender.send(Message(id=id, durable=True, body=record['description']), tag=str(id))
|
||||
self.sent += 1
|
||||
print("sent message %s" % id)
|
||||
self.request_records()
|
||||
|
||||
def on_settled(self, event):
|
||||
id = int(event.delivery.tag)
|
||||
self.db.delete(id)
|
||||
print("settled message %s" % id)
|
||||
self.confirmed += 1
|
||||
if self.confirmed == self.target:
|
||||
event.connection.close()
|
||||
self.db.close()
|
||||
|
||||
def on_disconnected(self, event):
|
||||
self.db.reset()
|
||||
self.sent = self.confirmed
|
||||
|
||||
def on_timer_task(self, event):
|
||||
print("Rechecking for data...")
|
||||
self.request_records()
|
||||
|
||||
|
||||
parser = optparse.OptionParser(usage="usage: %prog [options]",
|
||||
description="Send messages to the supplied address.")
|
||||
parser.add_option("-a", "--address", default="localhost:5672/examples",
|
||||
help="address to which messages are sent (default %default)")
|
||||
parser.add_option("-m", "--messages", type="int", default=0,
|
||||
help="number of messages to send; 0 sends indefinitely (default %default)")
|
||||
opts, args = parser.parse_args()
|
||||
|
||||
try:
|
||||
Container(Send(opts.address, opts.messages)).run()
|
||||
except KeyboardInterrupt:
|
||||
pass
|
||||
@ -1,6 +0,0 @@
|
||||
import stomp
|
||||
|
||||
conn = stomp.Connection()
|
||||
conn.connect('smx', 'smx', wait=True)
|
||||
conn.send(content_type='application/raw',body=' Hello Stomp ', destination='/queue/test')
|
||||
conn.disconnect()
|
||||
@ -1,39 +0,0 @@
|
||||
import stomp
|
||||
from stomp.listener import TestListener
|
||||
import testutils
|
||||
|
||||
|
||||
##@pytest.fixture()
|
||||
def conn():
|
||||
conn = stomp.Connection11(get_artemis_host())
|
||||
conn.set_listener("testlistener", TestListener("123", print_to_log=True))
|
||||
conn.connect(get_artemis_user(), get_artemis_password(), wait=True)
|
||||
yield conn
|
||||
conn.disconnect(receipt=None)
|
||||
|
||||
|
||||
##@pytest.fixture()
|
||||
def conn2():
|
||||
conn2 = stomp.Connection11(get_artemis_host())
|
||||
conn2.set_listener("testlistener", TestListener("456", print_to_log=True))
|
||||
conn2.connect(get_artemis_user(), get_artemis_password(), wait=True, headers={'consumerWindowSize': 0})
|
||||
yield conn2
|
||||
conn2.disconnect(receipt=None)
|
||||
|
||||
|
||||
class TestArtemis(object):
|
||||
|
||||
def test_send_to_artemis(self, conn):
|
||||
conn.subscribe(destination="/queue/test", id=1, ack="auto")
|
||||
|
||||
conn.send(body="this is a test", destination="/queue/test", receipt="123")
|
||||
|
||||
validate_send(conn)
|
||||
|
||||
def test_prefetchsize(self, conn2):
|
||||
conn2.subscribe(destination="/queue/test2", id=2, ack="auto", headers={'consumerWindowSize': 0})
|
||||
|
||||
conn2.send(body="testing sending a message after subscribing with prefetch",
|
||||
destination="/queue/test2", receipt="456")
|
||||
|
||||
validate_send(conn2)
|
||||
@ -1,41 +0,0 @@
|
||||
import tkinter as tk
|
||||
|
||||
def fahrenheit_to_celsius():
|
||||
"""Convert the value for Fahrenheit to Celsius and insert the
|
||||
result into lbl_result.
|
||||
"""
|
||||
fahrenheit = ent_temperature.get()
|
||||
celsius = (5 / 9) * (float(fahrenheit) - 32)
|
||||
lbl_result["text"] = f"{round(celsius, 2)} \N{DEGREE CELSIUS}"
|
||||
|
||||
# Set up the window
|
||||
window = tk.Tk()
|
||||
window.title("Temperature Converter")
|
||||
window.resizable(width=False, height=False)
|
||||
|
||||
# Create the Fahrenheit entry frame with an Entry
|
||||
# widget and label in it
|
||||
frm_entry = tk.Frame(master=window)
|
||||
ent_temperature = tk.Entry(master=frm_entry, width=10)
|
||||
lbl_temp = tk.Label(master=frm_entry, text="\N{DEGREE FAHRENHEIT}")
|
||||
|
||||
# Layout the temperature Entry and Label in frm_entry
|
||||
# using the .grid() geometry manager
|
||||
ent_temperature.grid(row=0, column=0, sticky="e")
|
||||
lbl_temp.grid(row=0, column=1, sticky="w")
|
||||
|
||||
# Create the conversion Button and result display Label
|
||||
btn_convert = tk.Button(
|
||||
master=window,
|
||||
text="\N{RIGHTWARDS BLACK ARROW}",
|
||||
command=fahrenheit_to_celsius
|
||||
)
|
||||
lbl_result = tk.Label(master=window, text="\N{DEGREE CELSIUS}")
|
||||
|
||||
# Set up the layout using the .grid() geometry manager
|
||||
frm_entry.grid(row=0, column=0, padx=10)
|
||||
btn_convert.grid(row=0, column=1, pady=10)
|
||||
lbl_result.grid(row=0, column=2, padx=10)
|
||||
|
||||
# Run the application
|
||||
window.mainloop()
|
||||
BIN
demo/db.sqlite3
BIN
demo/db.sqlite3
Binary file not shown.
@ -1,10 +0,0 @@
|
||||
import requests
|
||||
|
||||
endpoint = "https://httpbin.org/status/200"
|
||||
endpoint = "https://httpbin.org/anything"
|
||||
endpoint = "http://localhost:8000/api"
|
||||
|
||||
get_response = requests.get(endpoint) # HTTP get request
|
||||
print(get_response.text)
|
||||
|
||||
# REST API -> Web API
|
||||
@ -1,16 +0,0 @@
|
||||
"""
|
||||
ASGI config for demo project.
|
||||
|
||||
It exposes the ASGI callable as a module-level variable named ``application``.
|
||||
|
||||
For more information on this file, see
|
||||
https://docs.djangoproject.com/en/5.0/howto/deployment/asgi/
|
||||
"""
|
||||
|
||||
import os
|
||||
|
||||
from django.core.asgi import get_asgi_application
|
||||
|
||||
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'demo.settings')
|
||||
|
||||
application = get_asgi_application()
|
||||
@ -1,124 +0,0 @@
|
||||
"""
|
||||
Django settings for demo project.
|
||||
|
||||
Generated by 'django-admin startproject' using Django 5.0.1.
|
||||
|
||||
For more information on this file, see
|
||||
https://docs.djangoproject.com/en/5.0/topics/settings/
|
||||
|
||||
For the full list of settings and their values, see
|
||||
https://docs.djangoproject.com/en/5.0/ref/settings/
|
||||
"""
|
||||
|
||||
from pathlib import Path
|
||||
|
||||
# Build paths inside the project like this: BASE_DIR / 'subdir'.
|
||||
BASE_DIR = Path(__file__).resolve().parent.parent
|
||||
|
||||
|
||||
# Quick-start development settings - unsuitable for production
|
||||
# See https://docs.djangoproject.com/en/5.0/howto/deployment/checklist/
|
||||
|
||||
# SECURITY WARNING: keep the secret key used in production secret!
|
||||
SECRET_KEY = 'django-insecure-z$@7i%n)hn)=5-c8!%)y1-493jkohy8=s-xq8=iu(aud)xx0_+'
|
||||
|
||||
# SECURITY WARNING: don't run with debug turned on in production!
|
||||
DEBUG = True
|
||||
|
||||
ALLOWED_HOSTS = []
|
||||
|
||||
|
||||
# Application definition
|
||||
|
||||
INSTALLED_APPS = [
|
||||
'django.contrib.admin',
|
||||
'django.contrib.auth',
|
||||
'django.contrib.contenttypes',
|
||||
'django.contrib.sessions',
|
||||
'django.contrib.messages',
|
||||
'django.contrib.staticfiles',
|
||||
'pyapp',
|
||||
]
|
||||
|
||||
MIDDLEWARE = [
|
||||
'django.middleware.security.SecurityMiddleware',
|
||||
'django.contrib.sessions.middleware.SessionMiddleware',
|
||||
'django.middleware.common.CommonMiddleware',
|
||||
'django.middleware.csrf.CsrfViewMiddleware',
|
||||
'django.contrib.auth.middleware.AuthenticationMiddleware',
|
||||
'django.contrib.messages.middleware.MessageMiddleware',
|
||||
'django.middleware.clickjacking.XFrameOptionsMiddleware',
|
||||
]
|
||||
|
||||
ROOT_URLCONF = 'demo.urls'
|
||||
|
||||
TEMPLATES = [
|
||||
{
|
||||
'BACKEND': 'django.template.backends.django.DjangoTemplates',
|
||||
'DIRS': [],
|
||||
'APP_DIRS': True,
|
||||
'OPTIONS': {
|
||||
'context_processors': [
|
||||
'django.template.context_processors.debug',
|
||||
'django.template.context_processors.request',
|
||||
'django.contrib.auth.context_processors.auth',
|
||||
'django.contrib.messages.context_processors.messages',
|
||||
],
|
||||
},
|
||||
},
|
||||
]
|
||||
|
||||
WSGI_APPLICATION = 'demo.wsgi.application'
|
||||
|
||||
|
||||
# Database
|
||||
# https://docs.djangoproject.com/en/5.0/ref/settings/#databases
|
||||
|
||||
DATABASES = {
|
||||
'default': {
|
||||
'ENGINE': 'django.db.backends.sqlite3',
|
||||
'NAME': BASE_DIR / 'db.sqlite3',
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
# Password validation
|
||||
# https://docs.djangoproject.com/en/5.0/ref/settings/#auth-password-validators
|
||||
|
||||
AUTH_PASSWORD_VALIDATORS = [
|
||||
{
|
||||
'NAME': 'django.contrib.auth.password_validation.UserAttributeSimilarityValidator',
|
||||
},
|
||||
{
|
||||
'NAME': 'django.contrib.auth.password_validation.MinimumLengthValidator',
|
||||
},
|
||||
{
|
||||
'NAME': 'django.contrib.auth.password_validation.CommonPasswordValidator',
|
||||
},
|
||||
{
|
||||
'NAME': 'django.contrib.auth.password_validation.NumericPasswordValidator',
|
||||
},
|
||||
]
|
||||
|
||||
|
||||
# Internationalization
|
||||
# https://docs.djangoproject.com/en/5.0/topics/i18n/
|
||||
|
||||
LANGUAGE_CODE = 'en-us'
|
||||
|
||||
TIME_ZONE = 'UTC'
|
||||
|
||||
USE_I18N = True
|
||||
|
||||
USE_TZ = True
|
||||
|
||||
|
||||
# Static files (CSS, JavaScript, Images)
|
||||
# https://docs.djangoproject.com/en/5.0/howto/static-files/
|
||||
|
||||
STATIC_URL = 'static/'
|
||||
|
||||
# Default primary key field type
|
||||
# https://docs.djangoproject.com/en/5.0/ref/settings/#default-auto-field
|
||||
|
||||
DEFAULT_AUTO_FIELD = 'django.db.models.BigAutoField'
|
||||
@ -1,27 +0,0 @@
|
||||
"""
|
||||
URL configuration for demo project.
|
||||
|
||||
The `urlpatterns` list routes URLs to views. For more information please see:
|
||||
https://docs.djangoproject.com/en/5.0/topics/http/urls/
|
||||
Examples:
|
||||
Function views
|
||||
1. Add an import: from my_app import views
|
||||
2. Add a URL to urlpatterns: path('', views.home, name='home')
|
||||
Class-based views
|
||||
1. Add an import: from other_app.views import Home
|
||||
2. Add a URL to urlpatterns: path('', Home.as_view(), name='home')
|
||||
Including another URLconf
|
||||
1. Import the include() function: from django.urls import include, path
|
||||
2. Add a URL to urlpatterns: path('blog/', include('blog.urls'))
|
||||
"""
|
||||
from django.contrib import admin
|
||||
from django.urls import path,include
|
||||
from pyapp.views import pyapp_home
|
||||
from pyapp.views import api_home
|
||||
|
||||
urlpatterns = [
|
||||
path('admin/', admin.site.urls),
|
||||
path('', include("pyapp.urls")),
|
||||
path('pyapp/', pyapp_home),
|
||||
path('api/', api_home),
|
||||
]
|
||||
@ -1,16 +0,0 @@
|
||||
"""
|
||||
WSGI config for demo project.
|
||||
|
||||
It exposes the WSGI callable as a module-level variable named ``application``.
|
||||
|
||||
For more information on this file, see
|
||||
https://docs.djangoproject.com/en/5.0/howto/deployment/wsgi/
|
||||
"""
|
||||
|
||||
import os
|
||||
|
||||
from django.core.wsgi import get_wsgi_application
|
||||
|
||||
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'demo.settings')
|
||||
|
||||
application = get_wsgi_application()
|
||||
@ -1,22 +0,0 @@
|
||||
#!/usr/bin/env python
|
||||
"""Django's command-line utility for administrative tasks."""
|
||||
import os
|
||||
import sys
|
||||
|
||||
|
||||
def main():
|
||||
"""Run administrative tasks."""
|
||||
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'demo.settings')
|
||||
try:
|
||||
from django.core.management import execute_from_command_line
|
||||
except ImportError as exc:
|
||||
raise ImportError(
|
||||
"Couldn't import Django. Are you sure it's installed and "
|
||||
"available on your PYTHONPATH environment variable? Did you "
|
||||
"forget to activate a virtual environment?"
|
||||
) from exc
|
||||
execute_from_command_line(sys.argv)
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
main()
|
||||
@ -1,5 +0,0 @@
|
||||
from django.contrib import admin
|
||||
from pyapp.models import ShoppingItem
|
||||
|
||||
# Register your models here.
|
||||
admin.site.register(ShoppingItem)
|
||||
@ -1,6 +0,0 @@
|
||||
from django.apps import AppConfig
|
||||
|
||||
|
||||
class PyappConfig(AppConfig):
|
||||
default_auto_field = 'django.db.models.BigAutoField'
|
||||
name = 'pyapp'
|
||||
@ -1,33 +0,0 @@
|
||||
# Generated by Django 5.0.2 on 2024-02-23 10:59
|
||||
|
||||
import datetime
|
||||
from django.db import migrations, models
|
||||
|
||||
|
||||
class Migration(migrations.Migration):
|
||||
|
||||
initial = True
|
||||
|
||||
dependencies = [
|
||||
]
|
||||
|
||||
operations = [
|
||||
migrations.CreateModel(
|
||||
name='Product',
|
||||
fields=[
|
||||
('id', models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
|
||||
('title', models.CharField(max_length=120)),
|
||||
('content', models.TextField(blank=True, null=True)),
|
||||
('price', models.DecimalField(decimal_places=2, default=99.99, max_digits=15)),
|
||||
],
|
||||
),
|
||||
migrations.CreateModel(
|
||||
name='ShoppingItem',
|
||||
fields=[
|
||||
('id', models.BigAutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
|
||||
('created_at', models.DateField(default=datetime.date.today)),
|
||||
('name', models.CharField(max_length=120)),
|
||||
('done', models.BooleanField(default=False)),
|
||||
],
|
||||
),
|
||||
]
|
||||
@ -1,24 +0,0 @@
|
||||
# Generated by Django 5.0.2 on 2024-02-26 20:29
|
||||
|
||||
from django.db import migrations, models
|
||||
|
||||
|
||||
class Migration(migrations.Migration):
|
||||
|
||||
dependencies = [
|
||||
('migration', '0001_initial'),
|
||||
]
|
||||
|
||||
operations = [
|
||||
migrations.AddField(
|
||||
model_name='shoppingitem',
|
||||
name='price',
|
||||
field=models.DecimalField(decimal_places=2, default=0.0, max_digits=10),
|
||||
),
|
||||
migrations.AddField(
|
||||
model_name='shoppingitem',
|
||||
name='quantity',
|
||||
field=models.PositiveIntegerField(default=0.0),
|
||||
preserve_default=False,
|
||||
),
|
||||
]
|
||||
Binary file not shown.
Binary file not shown.
Binary file not shown.
@ -1,18 +0,0 @@
|
||||
from django.db import models
|
||||
from datetime import date
|
||||
|
||||
|
||||
class ShoppingItem(models.Model):
|
||||
created_at = models.DateField(default=date.today)
|
||||
name = models.CharField(max_length=120)
|
||||
done = models.BooleanField(default=False)
|
||||
price = models.DecimalField(max_digits=10, decimal_places=2, default = 0.0)
|
||||
quantity = models.PositiveIntegerField()
|
||||
|
||||
def __str__(self):
|
||||
return str(self.id) + ' - ' + self.name
|
||||
|
||||
class Product(models.Model):
|
||||
title = models.CharField(max_length=120)
|
||||
content= models.TextField(blank=True, null=True)
|
||||
price = models.DecimalField(max_digits=15,decimal_places=2,default=99.99)
|
||||
@ -1,7 +0,0 @@
|
||||
from rest_framework import serializers
|
||||
from .models import ShoppingItem
|
||||
|
||||
class ShoppingItemSerializer(serializers.ModelSerializer):
|
||||
class Meta:
|
||||
model = ShoppingItem
|
||||
fields = '__all__'
|
||||
@ -1,3 +0,0 @@
|
||||
from django.test import TestCase
|
||||
|
||||
# Create your tests here.
|
||||
@ -1,8 +0,0 @@
|
||||
from django.urls import path
|
||||
from pyapp import views
|
||||
|
||||
urlpatterns = [
|
||||
path("", views.index, name= "index"),
|
||||
path("", views.pyapp_home, name= "pyapp"),
|
||||
path("", views.api_home, name= "api"),
|
||||
]
|
||||
@ -1,37 +0,0 @@
|
||||
from django.shortcuts import render
|
||||
from django.http import HttpResponse, JsonResponse
|
||||
from pyapp.models import ShoppingItem
|
||||
from rest_framework import viewsets
|
||||
from pyapp.serializers import ShoppingItemSerializer
|
||||
|
||||
class ShoppingItemViewSet(viewsets.ModelViewSet):
|
||||
queryset = ShoppingItem.objects.all()
|
||||
serializer_class = ShoppingItemSerializer
|
||||
|
||||
def index(response):
|
||||
return HttpResponse("Welcome to PyApp")
|
||||
|
||||
def pyapp_home(request):
|
||||
if request.method == 'POST':
|
||||
print('Received Data',request.POST['itemName'])
|
||||
ShoppingItem.objects.create(name= request.POST['itemName'])
|
||||
all_items = ShoppingItem.objects.all()
|
||||
return render(request,'pyapp.html',{'all_items': all_items})
|
||||
|
||||
def api_home(request,endpoint, params={"message": "Your JSON Repsonse"}):
|
||||
body = request.body
|
||||
data = {}
|
||||
try:
|
||||
data = json.loads(body)
|
||||
except:
|
||||
pass
|
||||
print(request.GET)
|
||||
print(data)
|
||||
data['params'] = dict(request.GET)
|
||||
data['headers'] = dict(request.headers)
|
||||
data['content_type'] = request.content_type
|
||||
return JsonResponse(data)
|
||||
|
||||
##return JsonResponse()
|
||||
|
||||
|
||||
@ -1,22 +0,0 @@
|
||||
import pika, time, config
|
||||
#declaring the credentials needed for connection like host, port, username, password, exchange etc
|
||||
credentials= pika.PlainCredentials(username= config.username, password= config.password)
|
||||
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost', port=5672, credentials= credentials))
|
||||
channel = connection.channel()
|
||||
channel.exchange_declare('pydev', durable=True, exchange_type='topic')
|
||||
#defining callback functions responding to corresponding queue callbacks
|
||||
def callbackFunctionForQueueA(ch,method,properties,body):
|
||||
print('Got a message from Queue A: ', body)
|
||||
def callbackFunctionForQueueB(ch,method,properties,body):
|
||||
print('Got a message from Queue B: ', body)
|
||||
def callbackFunctionForQueueC(ch,method,properties,body):
|
||||
print('Got a message from Queue C: ', body)
|
||||
#Attaching consumer callback functions to respective queues that we wrote above
|
||||
channel.basic_consume(queue='A', on_message_callback=callbackFunctionForQueueA, auto_ack=True)
|
||||
channel.basic_consume(queue='B', on_message_callback=callbackFunctionForQueueB, auto_ack=True)
|
||||
channel.basic_consume(queue='C', on_message_callback=callbackFunctionForQueueC, auto_ack=True)
|
||||
#this will be command for starting the consumer session
|
||||
channel.start_consuming()
|
||||
##time.sleep(2)
|
||||
##channel.stop_consuming()
|
||||
channel.close()
|
||||
@ -1,23 +0,0 @@
|
||||
import pika
|
||||
##import amqp
|
||||
import config
|
||||
#declaring the credentials needed for connection like host, port, username, password, exchange etc
|
||||
credentials= pika.PlainCredentials(username= config.username, password= config.password)
|
||||
connection= pika.BlockingConnection(pika.ConnectionParameters(host='localhost', port=61616, credentials= credentials))
|
||||
channel = connection.channel()
|
||||
channel.exchange_declare(exchange='pydev', durable=True, exchange_type='topic')
|
||||
channel.queue_declare(queue= 'A')
|
||||
channel.queue_bind(exchange='pydev', queue='A', routing_key='A')
|
||||
channel.queue_declare(queue= 'B')
|
||||
channel.queue_bind(exchange='pydev', queue='B', routing_key='B')
|
||||
channel.queue_declare(queue= 'C')
|
||||
channel.queue_bind(exchange='pydev', queue='C', routing_key='C')
|
||||
#messaging to queue named C
|
||||
message_spec= 'Only this channel can see this message'
|
||||
message_all= 'Welcome to python queue handling...'
|
||||
channel.basic_publish(exchange='pydev', routing_key='A', body= message_all)
|
||||
channel.basic_publish(exchange='pydev', routing_key='B', body= message_all)
|
||||
channel.basic_publish(exchange='pydev', routing_key='C', body= message_all)
|
||||
channel.basic_publish(exchange='pydev', routing_key='B', body= message_spec)
|
||||
channel.basic_publish(exchange='pydev', routing_key='C', body= message_spec)
|
||||
channel.close()
|
||||
@ -1,3 +0,0 @@
|
||||
python3 manage.py runserver 9990
|
||||
|
||||
##python3 manage.py startapp banking-app
|
||||
BIN
pyapp/pyapp/__pycache__/admin.cpython-311.pyc
Normal file
BIN
pyapp/pyapp/__pycache__/admin.cpython-311.pyc
Normal file
Binary file not shown.
BIN
pyapp/pyapp/__pycache__/apps.cpython-311.pyc
Normal file
BIN
pyapp/pyapp/__pycache__/apps.cpython-311.pyc
Normal file
Binary file not shown.
BIN
pyapp/pyapp/__pycache__/models.cpython-311.pyc
Normal file
BIN
pyapp/pyapp/__pycache__/models.cpython-311.pyc
Normal file
Binary file not shown.
@ -1,6 +1,6 @@
|
||||
<html>
|
||||
<head>
|
||||
<title>Pyapp</title>
|
||||
<title>PyApp</title>
|
||||
<link rel="preconnect" href="https://fonts.googleapis.com">
|
||||
<link rel="preconnect" href="https://fonts.gstatic.com" crossorigin>
|
||||
<link href="https://fonts.googleapis.com/css2?family=Open+Sans:wght@300&display=swap" rel="stylesheet">
|
||||
@ -34,7 +34,7 @@
|
||||
</head>
|
||||
<body>
|
||||
<header>
|
||||
<h1>Shopping List</h1>
|
||||
<h1>PyApp Apis</h1>
|
||||
</header>
|
||||
{% for item in all_items %}
|
||||
<div class="list-item">
|
||||
Loading…
x
Reference in New Issue
Block a user