diff options
author | Ryota MIBU <r-mibu@cq.jp.nec.com> | 2016-01-04 16:12:39 +0900 |
---|---|---|
committer | Ryota MIBU <r-mibu@cq.jp.nec.com> | 2016-01-13 00:44:35 +0900 |
commit | 5aacaaf9f3fba523264aa7bec7bee5bbc12acdb1 (patch) | |
tree | 2e7e37ec3362cc2aff5d51d66ffa09299271f0ff /tests/consumer.py | |
parent | c1603e905316e88450b2bf7b23e3864205d40e55 (diff) |
add test scenario and sample components
DOCTOR-22
Change-Id: I82cb572fadd057151c55396dd3ab4114539c8fa7
Signed-off-by: Ryota MIBU <r-mibu@cq.jp.nec.com>
(cherry picked from commit 116bee29f8f3d7d4a648569dc441f4fa8487a7c4)
Note: this patch includes the following change:
disable doctor functional test
Change-Id: I3bd62b53651777fe020c3919c415e1f2d7b45164
Signed-off-by: Ryota MIBU <r-mibu@cq.jp.nec.com>
(cherry picked from commit aec51550523c3326b37dfb79680ebd80188c6a56)
Diffstat (limited to 'tests/consumer.py')
-rw-r--r-- | tests/consumer.py | 48 |
1 files changed, 48 insertions, 0 deletions
diff --git a/tests/consumer.py b/tests/consumer.py new file mode 100644 index 00000000..aa6e90e3 --- /dev/null +++ b/tests/consumer.py @@ -0,0 +1,48 @@ +# +# Copyright 2016 NEC Corporation. +# +# Licensed under the Apache License, Version 2.0 (the "License"); you may +# not use this file except in compliance with the License. You may obtain +# a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT +# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the +# License for the specific language governing permissions and limitations +# under the License. + +import argparse +from flask import Flask +from flask import request +import json +import os +import time + + +app = Flask(__name__) + + +@app.route('/failure', methods=['POST']) +def event_posted(): + app.logger.debug('doctor consumer notified at %s' % time.time()) + app.logger.debug('received data = %s' % request.data) + d = json.loads(request.data) + return "OK" + + +def get_args(): + parser = argparse.ArgumentParser(description='Doctor Sample Monitor') + parser.add_argument('port', metavar='PORT', type=int, nargs='?', + help='a port for inspectpr') + return parser.parse_args() + + +def main(): + args = get_args() + app.run(port=args.port, debug=True) + + +if __name__ == '__main__': + main() |