Как запускать задачи для Fabric непосредственно из Python, занимаясь исключениями и выводами?

Question

Я хотел бы запустить мои существующие задачи fabfile без cli непосредственно из Python. Как я могу уловить «выполнение» исключений и захватить вывод для ведения журнала, если происходят какие-либо исключения?

@roles(['localhost']) 
def my_sudo_task(): 
    sudo('ls -l /root/') 

from fabfile import my_sudo_task 
from fabric.tasks import execute 

execute(my_sudo_task) 

вот моя точная проблема:

try: 
    # is there a way to leave out stderr and capture it somehow? 
    with settings(hide('stdout', 'stderr', 'aborts', 'warnings', 'running')): 
     execute(my_sudo_task) 
except Exception as e: # doesnt catch error 
    print ('ERROR') 
    raise 
except: 
    print ('ERROR') # catches but lacks the error message that i can log 

Answer 1

Вы должны обрабатывать ошибки, исследуя результирующие коды внутри задачи. Исключения не будут достаточно описательными.

from fabric.api import * 

@roles(['localhost']) 
def my_sudo_task(): 
    with settings(warn_only=True): 
     result = sudo('ls -l /root/') 

    if result.return_code == 0: 
     [do something...] 
    elif result.return_code == 1: 
     [do something...] 
    else: 
     [do something else...] 



from fabfile import my_sudo_task 
from fabric.tasks import execute 

execute(my_sudo_task) 

См. Раздел учебника по failure handling.

Answer 2

Следующая решить мой вопрос

try: 
    with settings(hide('stdout', 'stderr', 'aborts', 'warnings', 'running')): 
     execute(my_sudo_task) 
except SystemExit as e: 
    print (e.message) 

, потому что 'казнить' технически не сгенерирует исключение

issubclass(SystemExit, Exception) = False 

Answer 3

Исключения NetworkError и CommandTimeout определены в модуле fabric.exceptions. Вызов execute() возвращает словарь того, что возвращается выполняемой им задачей с именами хостов в качестве ключей. Если встречается исключение, оно также будет храниться в словаре. Вы можете проверить атрибут «сообщение» исключения для строкового описания проблемы. См. Следующий пример:

>>> from fabric.api import run, execute 
>>> from fabric.context_managers import quiet 
>>> from fabric.state import env 
>>> env.skip_bad_hosts = True 
>>> env.warn_only = True 
>>> def task_a(): 
... return run('pwd') 
... 
>>> with quiet(): 
... a = execute(task_a,hosts=['badhost']) 
... 
>>> a 
{'badhost': NetworkError(Name lookup failed for badhost) => gaierror(8, 'nodename nor servname provided, or not known')} 
>>> type(a['badhost']) 
<class 'fabric.exceptions.NetworkError'> 
>>> a['badhost'].message 
'Name lookup failed for badhost'