From 531bbae3a3c72b8bf2a058636ce7f2e774f2d758 Mon Sep 17 00:00:00 2001
From: JimZhang <zzl22100048@gmail.com>
Date: Tue, 16 May 2023 12:07:35 +0800
Subject: [PATCH] refactor: add example folder

---
 example/rabbitmq.py | 31 +++++++++++++++++++++++++++++++
 1 file changed, 31 insertions(+)
 create mode 100644 example/rabbitmq.py

diff --git a/example/rabbitmq.py b/example/rabbitmq.py
new file mode 100644
index 0000000..80409f9
--- /dev/null
+++ b/example/rabbitmq.py
@@ -0,0 +1,31 @@
+from datetime import datetime
+from typing import List
+
+from amqpworker.app import App
+from amqpworker.connections import AMQPConnection
+from amqpworker.rabbitmq import RabbitMQMessage
+from amqpworker.routes import AMQPRouteOptions
+
+amqp_conn = AMQPConnection(hostname='106.15.78.184', username='whc', password='whc', port=32675)
+
+app = App(connections=[amqp_conn])
+
+
+@app.amqp.consume(
+    ['yhc_risk_info_v9_annual_report'],
+    options=AMQPRouteOptions(bulk_size=1024 * 8, bulk_flush_interval=2)
+)
+def _handler(msgs: List[RabbitMQMessage]):
+    print(f"Recv {len(msgs)} {datetime.now().isoformat()}")
+    for i in msgs:
+        print(i)
+
+
+
+# @app.run_every(1)
+# def produce(*args, **kwargs):
+#     # logger.error("tick produce")
+#     amqp_conn.put(data={'msg': 'ok'}, routing_key='test')
+
+
+app.run()