Threading Nornir with Netbox inventory about nornir HOT 3 CLOSED

    forti_devices = nr.filter(F(platform=FORTI_PLATFORM))  # Filter for Fortinet devices
    forti_devices.run(task=backup_with_fortiapi,
                    state_commands=state_commands.get("forti_commands"),
                    output_path=directory_path, 
                    credentials=credentials)

def backup_with_fortiapi(task, state_commands: dict, output_path: str, credentials: str):

    device = str(task.host)    # hostname
    if not credentials.get(device):
        logging.error(f"Couldn't find {device}'s credentials, Skipping to next device")
        return False
    
    ip = task.host.hostname
    filename = f"{output_path}{device}"
    port = "443"    # default port
    if credentials.get(device).get("port"): port = credentials.get(device).get("port")    # use different port if needed
    fortinet_device = APIDevice(host=ip, port=port, ssl_verify=False) 
    config_response = fortinet_device.api_request(path="/api/v2/monitor/system/config/backup",        # obtain config
                                        method="GET",
                                        headers={'Authorization': f'Bearer {credentials.get(device).get("token")}'},
                                        params={"scope": "global"})
    if config_response:
        write_text(data=config_response.text, file=f"{filename}_config.txt")
        logging.info(f"{ip} - Performed Configuration Backup")
    device_state = {}     
    for key, api_path in state_commands.items():       # loop through device state commands
        logging.info(f"{ip} - Executing FortiAPI for '{api_path}'...")
        response = fortinet_device.api_request(path=api_path,
                                    method="GET",
                                    headers={'Authorization': f'Bearer {credentials.get(device).get("token")}'})
        if response:
            device_state[key] = response.json().get("results")      # example: {"interfaces": {...}}    

    if device_state:
        write_to_json(data=device_state, json_file=f"{filename}_state.json")
        logging.info(f"{ip} - Performed Device State Backup")