fix event_time micro / milli seconds bug.

Author: yipjustin

examples/event_sample.py

@@ -19,11 +19,15 @@
     "prop5" : ["a", "b", "c"],
     "prop6" : 4.56 ,
     }
+first_event_time = datetime(
+    2004, 12, 13, 21, 39, 45, 618000, pytz.timezone('US/Mountain'))
 first_event_response = client.create_event(
     event="my_event",
     entity_type="user",
     entity_id="uid",
-    properties=first_event_properties)
+    properties=first_event_properties,
+    first_event_time=first_event_time,
+    )
 print("First Event response")
 print(first_event_response)
 print
@@ -40,7 +44,7 @@
     target_entity_type="item",
     target_entity_id="iid",
     properties=second_event_properties,
-    event_time=datetime(2014, 12, 13, 21, 38, 45, 618, pytz.utc))
+    event_time=datetime(2014, 12, 13, 21, 38, 45, 618000, pytz.utc))
 print("Second Event response")
 print(second_event_response)
 print

predictionio/__init__.py

@@ -177,8 +177,11 @@ def acreate_event(self, event, entity_type, entity_id,
     if properties is not None:
       data["properties"] = properties
 
-    event_time = event_time_validation(event_time)
-    data["eventTime"] = event_time.isoformat()
+    et = event_time_validation(event_time)
+    # EventServer uses milliseconds, but python datetime class uses micro. Hence
+    # need to skip the last three digits.
+    et_str = et.strftime("%Y-%m-%dT%H:%M:%S.%f")[:-3] + et.strftime("%z")
+    data["eventTime"] = et_str
 
     path = "/events.json"
     request = AsyncRequest("POST", path, **data)