Можем ли мы отредактировать endpoints.py и добавить в него новые функции в airflow? - PullRequest
1 голос
/ 01 октября 2019

У меня есть новые функции, и я хочу вызывать их через api / экспериментальный / route_name

У меня есть функция ниже, и я хочу интегрировать ее с потоком воздуха, чтобы всякий раз, когда я вызываю api / экспериментальный / api_userDetailдетали появляются.

Я включил функцию в файл [endpoints.py]. По какой-то причине он не отображается на сервере и сообщает об ошибке 404. Было бы здорово, если бы я нашел какой-нибудь способ сделать это.

def returnFromVariable(key_name):
    return Variable.get(key_name,deserialize_json=True)

@api_experimental.route('/api_userDetail',methods=['GET'])
def userDetailApi():
    get_element_config_name="user_credential"
    return jsonify(returnFromVariable(get_element_config_name))```

The output is the data returned.

1 Ответ

2 голосов
/ 01 октября 2019

На самом деле все работает. У меня было две версии airflow, одна из которых работала на python2, а другая на python3, поэтому мне пришлось внести изменения в python3, и это сработало для меня. Вышеупомянутые вещи, которые я написал, работали. Чтобы добавить новые функции, просто перейдите по адресу www / api / эксперимент, а затем добавьте API в файл и перезапустите веб-сервер, на котором он будет работать.

...