Pinned Loading

1. computer-vision-projects computer-vision-projects Public

   #computervision #panopticsegmentation #instancesegmentation

   Jupyter Notebook

2. project-NAnPack project-NAnPack Public

   A Numerical Analysis Package in Python

   Python 12 2

3. twitter_stream_listener.py twitter_stream_listener.py

   1

   class StreamListener(tweepy.StreamingClient):

   2

       def __init__(self, kafka_topic, kafka_producer, batch_size, wait_on_rate_limit):

   3

           super().__init__(bearer_token=keys.bearer_token, wait_on_rate_limit=wait_on_rate_limit)

   4

           self.topic = kafka_topic

   5

           self.producer = kafka_producer

4. create_kafka_topic.sh create_kafka_topic.sh

   1

   # ---

   2

   # Syntax for starting Zookeeper server locally

   3

   .\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties

   4

   5

   # Syntax for starting Kafka server locally

5. kafka_tweet_consumer.py kafka_tweet_consumer.py

   1

   def get_kafka_consumer():

   2

       kafka_consumer = KafkaConsumer(topic='data-science-tweets',

   3

                                      bootstrap_servers=['localhosy:9092'],

   4

                                      # value_deserializer=lambda x: json.loads(x.decode('utf-8')

   5

                                      )