D4
/
analyzer-d4-passivedns
mirror of https://github.com/D4-project/analyzer-d4-passivedns
2
0
Fork 0
Code Issues Releases Wiki Activity

support env for docker

pull/3/head
ljaqueme 2019-06-11 14:41:32 -06:00
parent d85e4422c9
commit c852241b52
3 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
bin/pdns-cof-server.py
View File

File diff suppressed because one or more lines are too long

6
bin/pdns-import.py
View File

@ -20,6 +20,7 @@ import time
import logging import logging
import sys import sys
import argparse import argparse
import os
parser = argparse.ArgumentParser(description='Import array of standard Passive DNS cof format into your Passive DNS server') parser = argparse.ArgumentParser(description='Import array of standard Passive DNS cof format into your Passive DNS server')
parser.add_argument('--file', dest='filetoimport', help='JSON file to import') parser.add_argument('--file', dest='filetoimport', help='JSON file to import')
@ -47,8 +48,11 @@ logger.addHandler(ch)
logger.info("Starting and using FIFO {} from D4 server".format(myqueue)) logger.info("Starting and using FIFO {} from D4 server".format(myqueue))
analyzer_redis_host = os.getenv('D4_ANALYZER_REDIS_HOST', '127.0.0.1')
analyzer_redis_port = int(os.getenv('D4_ANALYZER_REDIS_PORT', 6400))
d4_server = config.get('global', 'd4-server') d4_server = config.get('global', 'd4-server')
r = redis.Redis(host="127.0.0.1",port=6400) r = redis.Redis(host=analyzer_redis_host, port=analyzer_redis_port)
r_d4 = redis.Redis(host=d4_server.split(':')[0], port=d4_server.split(':')[1], db=2) r_d4 = redis.Redis(host=d4_server.split(':')[0], port=d4_server.split(':')[1], db=2)

6
bin/pdns-ingestion.py
View File

@ -22,6 +22,7 @@ import configparser
import time import time
import logging import logging
import sys import sys
import os
config = configparser.RawConfigParser() config = configparser.RawConfigParser()
config.read('../etc/analyzer.conf') config.read('../etc/analyzer.conf')
@ -45,8 +46,11 @@ logger.addHandler(ch)
logger.info("Starting and using FIFO {} from D4 server".format(myqueue)) logger.info("Starting and using FIFO {} from D4 server".format(myqueue))
analyzer_redis_host = os.getenv('D4_ANALYZER_REDIS_HOST', '127.0.0.1')
analyzer_redis_port = int(os.getenv('D4_ANALYZER_REDIS_PORT', 6400))
d4_server = config.get('global', 'd4-server') d4_server = config.get('global', 'd4-server')
r = redis.Redis(host="127.0.0.1",port=6400) r = redis.Redis(host=analyzer_redis_host, port=analyzer_redis_port)
r_d4 = redis.Redis(host=d4_server.split(':')[0], port=d4_server.split(':')[1], db=2) r_d4 = redis.Redis(host=d4_server.split(':')[0], port=d4_server.split(':')[1], db=2)