Revision 58430
Added by Sandro La Bruzzo almost 4 years ago
modules/dataciteExporter/app.py | ||
---|---|---|
1 | 1 |
from flask import Flask |
2 | 2 |
from flask import jsonify, request |
3 | 3 |
from eu.dnetlib.exporter.ScrollResult import ScrollResult |
4 |
from eu.dnetlib.exporter.dataciteExporter import is_available |
|
4 | 5 |
|
5 | 6 |
app = Flask(__name__) |
6 | 7 |
|
... | ... | |
34 | 35 |
return jsonify([]) |
35 | 36 |
|
36 | 37 |
|
38 |
@app.route("/status") |
|
39 |
def get_status(): |
|
40 |
try: |
|
41 |
if is_available() : |
|
42 |
return jsonify(dict(status = 'OK')) |
|
43 |
return jsonify(dict(status = 'FAIL')) |
|
44 |
|
|
45 |
|
|
46 |
|
|
47 |
|
|
37 | 48 |
if __name__ == '__main__': |
38 | 49 |
print("Starting flask") |
39 | 50 |
app.run(host='0.0.0.0', debug=False) |
modules/dataciteExporter/eu/dnetlib/exporter/dataciteExporter.py | ||
---|---|---|
64 | 64 |
yield result |
65 | 65 |
|
66 | 66 |
|
67 |
def is_available(): |
|
68 |
es = Elasticsearch(hosts=['192.168.100.70','192.168.100.71','192.168.100.72', '192.168.100.73'], timeout=1000) |
|
69 |
s = Search(using=es, index='datacite').query(Q('match', attributes__isActive=True)) |
|
70 |
return s.count() >0 |
|
71 |
|
|
72 |
|
|
73 |
|
|
74 |
|
Also available in: Unified diff
added status