diff --git a/requirements.txt b/requirements.txt
index af37789..e071dc3 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -1,4 +1,6 @@
 aio-pika
 sentry-sdk
 aioinflux
-requests
\ No newline at end of file
+requests
+tzdata
+tzlocal
\ No newline at end of file
diff --git a/src/app.py b/src/app.py
index a9bb21e..a8cef4d 100644
--- a/src/app.py
+++ b/src/app.py
@@ -17,6 +17,7 @@ import sentry_sdk
 from aioinflux import InfluxDBClient
 import config
 import requests
+import tzlocal
 
 if config.SENTRY_DSN:
     sentry_sdk.init(
@@ -33,7 +34,7 @@ async def on_message(message: IncomingMessage):
     Here it is to show that it's possible.
     """
     msg_json = json.loads(message.body)
-    now = datetime.now()
+    now = datetime.now(tz=tzlocal.get_localzone())
 
     r = requests.get(f"http://input-service/sample/{msg_json['tag']}")
     r.raise_for_status()