2020-10-09 18:16:21 +01:00

30 lines
591 B
Python

#!/usr/bin/env python
import sys
sys.path.append('/home/tweet-collector/')
from threading import Thread
from tweets.collector import collectorMain
from src.utils.jsonLogger import setup_logging
from probes.probes import runFlaskProbes
def callCollector(args):
collectorMain(args)
def callProbes():
runFlaskProbes()
if __name__=='__main__':
setup_logging()
Thread(target=callProbes).start()
hashtags = [ "bitcoin" ]
callCollector(hashtags)
# for i in range(len(currencies)):
# Thread(target=callCollector, args=[hashtags[i], hourStack]).start()