diff options
| author | Bryan Newbold <bnewbold@robocracy.org> | 2018-11-13 11:32:41 -0800 |
|---|---|---|
| committer | Bryan Newbold <bnewbold@robocracy.org> | 2018-11-13 11:32:41 -0800 |
| commit | 279b22e30d9b590838268f5f5acdaa1110ee593a (patch) | |
| tree | c9965a089be1b8ef607573ea9261c0c378c0ab47 /python/fatcat_tools/worker_common.py | |
| parent | 7ebda2e051b51e49544ab75673b19ec5f27d9d45 (diff) | |
| download | fatcat-279b22e30d9b590838268f5f5acdaa1110ee593a.tar.gz fatcat-279b22e30d9b590838268f5f5acdaa1110ee593a.zip | |
shuffle around fatcat_tools layout
Diffstat (limited to 'python/fatcat_tools/worker_common.py')
| -rw-r--r-- | python/fatcat_tools/worker_common.py | 25 |
1 files changed, 0 insertions, 25 deletions
diff --git a/python/fatcat_tools/worker_common.py b/python/fatcat_tools/worker_common.py deleted file mode 100644 index 77ea2c15..00000000 --- a/python/fatcat_tools/worker_common.py +++ /dev/null @@ -1,25 +0,0 @@ - -import re -import sys -import csv -import json -import itertools -import fatcat_client -from pykafka import KafkaClient -from fatcat_client.rest import ApiException - - -class FatcatWorker: - """ - Common code for for Kafka producers and consumers. - """ - - def __init__(self, kafka_hosts, produce_topic=None, consume_topic=None, api_host_url=None): - if api_host_url: - conf = fatcat_client.Configuration() - conf.host = api_host_url - self.api = fatcat_client.DefaultApi(fatcat_client.ApiClient(conf)) - self.kafka = KafkaClient(hosts=kafka_hosts, broker_version="1.0.0") - self.produce_topic = produce_topic - self.consume_topic = consume_topic - |