fix: lambda sample

getdozer · Nov 7, 2023 · 0ef2cd1 · 0ef2cd1
1 parent 705c74a
commit 0ef2cd1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/usecases/lambda/main.py b/usecases/lambda/main.py
@@ -19,11 +19,11 @@ def send_message(seq, device, temp):
         schema_name="events",
         typ=0,
         old=None,
-        new=types_pb2.Record(values=[
+        new=[
             types_pb2.Value(string_value=device),
             types_pb2.Value(float_value=temp),
             types_pb2.Value(string_value=datetime.datetime.now().strftime("%H:%M:%S"))
-        ]),
+        ],
         seq_no=seq
     )
     res = ingestion_client.ingest_raw(user)

diff --git a/usecases/lambda/reader.py b/usecases/lambda/reader.py
@@ -20,7 +20,7 @@ def message():
 
 
 async def main():
-    reader = await pydozer_log.LogReader.new("./.dozer", "events")
+    reader = await pydozer_log.LogReader.new("http://127.0.0.1:50053", "events")
     while True:
         data = await reader.next_op()
         if "op" in data.keys():