From dc6256d47612479911083a30ec13e7cd9d6f5aa1 Mon Sep 17 00:00:00 2001 From: louieli Date: Tue, 12 Sep 2017 18:58:31 +0800 Subject: [PATCH] Update sync.go add datetime to date cast --- river/sync.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/river/sync.go b/river/sync.go index bd01a3d5..ef03e93f 100644 --- a/river/sync.go +++ b/river/sync.go @@ -25,6 +25,7 @@ const ( const ( fieldTypeList = "list" + fieldTypeDateTime = "datetime" ) type posSaver struct { @@ -345,6 +346,13 @@ func (r *River) makeInsertReqData(req *elastic.BulkRequest, rule *Rule, values [ } else { req.Data[elastic] = v } + } else if fieldType == fieldTypeDateTime { + if str, ok := v.(string); ok { + tm,_ := time.ParseInLocation("2006-01-02 15:04:05",str,time.Local) + req.Data[elastic] = tm.Unix() * 1000 + } else { + req.Data[elastic] = v + } } else { req.Data[elastic] = v }