update readme to run

README.md

@@ -28,5 +28,81 @@ Python Boilerplate for Google Cloud PubSub running task in python
 ## Test
 *TBD using pycharm*
 
-## Run
+## Run 
 
+To run with sample code
+
+add messenger_main.py with this code 
+
+    import json
+    import logging
+    import os
+    import time
+
+    from PubSubRunner.cloud_util import CloudUtil
+    from PubSubRunner.runner_application import RunnerApplication
+    from PubSubRunner.runner_config import RunnerConfig
+
+    logging.basicConfig(level=logging.DEBUG)
+
+
+    def deliver(message):
+        logging.debug('deliver: {}'.format(message))
+        if int(message['delay']) > 0:
+            time.sleep(int(message['delay']))
+        logging.debug('deliver: {} done.'.format(message))
+
+
+    def task(message, runner=deliver):
+        """
+        :param message: json from pubsub
+        :param runner:
+        :return: message: 'directory':output path relative with output_directory for 'filename' input
+        inside directory contains hls processed files inside.
+        """
+        logging.debug('receive: {}'.format(message))
+        assert 'delay' in message, 'KeyError: filename'
+        assert len(message['delay']) > 0
+        runner(message)
+        logging.debug('send: {}'.format(message))
+        return message
+
+
+    if __name__ == '__main__':
+        # intend to run by python3 messenger_main.py
+        # check console with LINE: INFO:root:publish : {"delay": "{delay}"} like
+        # > INFO:root:publish : {"delay": "1"}
+        # and look around for warning like
+        # > WARNING:google.cloud.pubsub_v1.subscriber._protocol.leaser:Dropping 2 items because they were leased too long.
+        #
+        # when complete 600 seconds (in case create by this lib) it will shown
+        # > INFO:google.cloud.pubsub_v1.subscriber._protocol.streaming_pull_manager:Observed recoverable stream error
+        # 504 Deadline Exceeded
+        #
+        os.environ['GOOGLE_APPLICATION_CREDENTIALS'] = '../services.json'  # expect file to be here
+        os.environ['CLOUD_PROJECT'] = 'your-project'  # TODO: change this name, topic and subscription will auto gen
+        os.environ['CLOUD_PUBSUB_SUBSCRIBE_TOPIC'] = 'delay-03'
+        os.environ['CLOUD_PUBSUB_SUBSCRIBE_SUBSCRIPTION'] = 'delay-03-1'
+        os.environ['CLOUD_PUBSUB_PUBLISH_TOPIC'] = 'delay-04'
+        os.environ['CLOUD_PUBSUB_MAX_LEASE_DURATION'] = '60'  # play with this value
+        os.environ['CLOUD_PUBSUB_ACK_DEADLINE'] = '30'  # play with this value
+
+
+        def job():
+            config = RunnerConfig()
+            CloudUtil.publish_data(config.cloud_project, config.cloud_pubsub_subscribe_topic, json.dumps({'delay': '1'}))
+            CloudUtil.publish_data(config.cloud_project, config.cloud_pubsub_subscribe_topic, json.dumps({'delay': '15'}))
+            CloudUtil.publish_data(config.cloud_project, config.cloud_pubsub_subscribe_topic, json.dumps({'delay': '25'}))
+            CloudUtil.publish_data(config.cloud_project, config.cloud_pubsub_subscribe_topic, json.dumps({'delay': '45'}))
+
+
+        RunnerApplication(task).run(job=job)
+
+
+run
+
+    python messenger_main.py
+     
+or
+
+    python3 messenger_main.py