logs2dataflow.py 文件源码

def es_get_timestamp_filer(since=None):
    # @see https://www.elastic.co/guide/en/elasticsearch/reference/2.3/query-dsl-range-query.html
        return {
            "range": {
                "@timestamp": {
                    "gt": since,
                }
            }
        } if since is not None else {}