# Path: fooltrader/connector/kafka_connector.py
# def cryptocurrency_tick_to_kafka(exchange, pairs=None):
#     for tick in fetch_ticks(exchange, pairs=pairs):
#         producer.send(get_kafka_tick_topic(tick['securityId']),
#                       bytes(json.dumps(tick), encoding='utf8'),
#                       timestamp_ms=tick['timestamp'])
# 
#         logger.debug("tick_to_kafka {}".format(tick))


import argparse
from fooltrader.connector.kafka_connector import cryptocurrency_tick_to_kafka
# -*- coding: utf-8 -*-


if __name__ == '__main__':
    parser = argparse.ArgumentParser()
    parser.add_argument('exchange', help='the exchange to crawl')

# Path: fooltrader/connector/kafka_connector.py
# def cryptocurrency_tick_to_kafka(exchange, pairs=None):
#     for tick in fetch_ticks(exchange, pairs=pairs):
#         producer.send(get_kafka_tick_topic(tick['securityId']),
#                       bytes(json.dumps(tick), encoding='utf8'),
#                       timestamp_ms=tick['timestamp'])
# 
#         logger.debug("tick_to_kafka {}".format(tick))


# Path: fooltrader/datamanager/cryptocurrency_manager.py
import argparse
from fooltrader.connector.kafka_connector import cryptocurrency_tick_to_kafka

# -*- coding: utf-8 -*-


if __name__ == '__main__':
    parser = argparse.ArgumentParser()
    parser.add_argument('exchange', help='the exchange to crawl')

    parser.add_argument('--pairs', help='the pair list')