Skip to content

Commit

Permalink
clean logstash configuration
Browse files Browse the repository at this point in the history
  • Loading branch information
AdrianAlcolea committed Nov 20, 2023
1 parent 7e0861a commit 649325d
Show file tree
Hide file tree
Showing 2 changed files with 16 additions and 1 deletion.
Empty file added src/setup/logstash/__init__.py
Empty file.
17 changes: 16 additions & 1 deletion src/setup/logstash/generate_logstash_config_files.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,8 +12,22 @@

import os

import definitions
from routers.search_routers import router_list
from .definitions import (
BASE_FIELDS,
INFO,
CONF_BASE,
INIT_INPUT_BASE,
SYNC_INPUT_BASE,
FILTER,
INIT_OUTPUT_BASE,
SYNC_OUTPUT_BASE,
SQL_BASE,
SQL_RM_BASE,
INIT_CLAUSE,
SYNC_CLAUSE,
)


def generate_conf_file(conf_path, es_user, es_pass):

Expand Down Expand Up @@ -104,6 +118,7 @@ def generate_pipeline_sql_rm_files(pipeline_sql_path, entity):
# SQL query
f.write(SQL_RM_BASE.format(entity))


def main():

# Get configuration variables
Expand Down

0 comments on commit 649325d

Please sign in to comment.