Add a xtype parameter for future ES expansion
This commit is contained in:
parent
df195d968c
commit
6979b6c34a
|
@ -516,6 +516,7 @@ class Transactions(object):
|
||||||
def write_to_es(self, msgtype, cast):
|
def write_to_es(self, msgtype, cast):
|
||||||
cast["type"] = msgtype
|
cast["type"] = msgtype
|
||||||
cast["ts"] = str(datetime.now().isoformat())
|
cast["ts"] = str(datetime.now().isoformat())
|
||||||
|
cast["xtype"] = "tx"
|
||||||
self.es.index(index=settings.ES.Index, document=cast)
|
self.es.index(index=settings.ES.Index, document=cast)
|
||||||
|
|
||||||
def get_remaining(self):
|
def get_remaining(self):
|
||||||
|
|
Loading…
Reference in New Issue