tests/consumer.py

   1 #
   2 # Copyright 2016 NEC Corporation.
   3 #
   4 # Licensed under the Apache License, Version 2.0 (the "License"); you may
   5 # not use this file except in compliance with the License. You may obtain
   6 # a copy of the License at
   7 #
   8 #      http://www.apache.org/licenses/LICENSE-2.0
   9 #
  10 # Unless required by applicable law or agreed to in writing, software
  11 # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
  12 # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
  13 # License for the specific language governing permissions and limitations
  14 # under the License.
  15
  16 import argparse
  17 from flask import Flask
  18 from flask import request
  19 import json
  20 import os
  21 import time
  22
  23
  24 app = Flask(__name__)
  25
  26
  27 @app.route('/failure', methods=['POST'])
  28 def event_posted():
  29     app.logger.debug('doctor consumer notified at %s' % time.time())
  30     app.logger.debug('received data = %s' % request.data)
  31     d = json.loads(request.data)
  32     return "OK"
  33
  34
  35 def get_args():
  36     parser = argparse.ArgumentParser(description='Doctor Sample Monitor')
  37     parser.add_argument('port', metavar='PORT', type=int, nargs='?',
  38                         help='a port for inspectpr')
  39     return parser.parse_args()
  40
  41
  42 def main():
  43     args = get_args()
  44     app.run(port=args.port, debug=True)
  45
  46
  47 if __name__ == '__main__':
  48     main()