|
| 1 | +#!/usr/bin/env python |
| 2 | +""" |
| 3 | +Export all discovery assets with a specific optional score to CSV format |
| 4 | +
|
| 5 | +Run: |
| 6 | +
|
| 7 | +$ python3 discovery_assets_to_csv.py -s <OPTIONAL_SCORE> -o <OUTPUT_FILE_PATH> |
| 8 | +
|
| 9 | +""" |
| 10 | +import argparse |
| 11 | +import requests |
| 12 | +import csv |
| 13 | +from urllib.parse import urljoin, quote |
| 14 | +from datetime import datetime |
| 15 | + |
| 16 | +# Define the JWT or it will be asked when you run the script |
| 17 | +jwt_token = None |
| 18 | + |
| 19 | +api_base_url = 'https://api.probely.com' |
| 20 | +discovery_assets_endpoint = urljoin(api_base_url, "discovery/assets/?length=10000&page=1&ordering=-last_seen&{score_str}") |
| 21 | + |
| 22 | +def map_risk(probely_risk): |
| 23 | + if probely_risk == 10: |
| 24 | + return 'Low' |
| 25 | + elif probely_risk == 20: |
| 26 | + return 'Normal' |
| 27 | + elif probely_risk == 30: |
| 28 | + return 'High' |
| 29 | + else: |
| 30 | + return 'NA' |
| 31 | + |
| 32 | +def main(): |
| 33 | + parser = argparse.ArgumentParser() |
| 34 | + parser.add_argument('-s', '--score', help='Score', required=False, choices=[ |
| 35 | + 'A+', 'A', 'B', 'C', 'D', 'E', 'F', 'R', 'NA']) |
| 36 | + parser.add_argument('-o', '--output', help='Output CSV file', type=argparse.FileType('w'), required=True) |
| 37 | + args = parser.parse_args() |
| 38 | + |
| 39 | + if jwt_token is None: |
| 40 | + token = input("API Token:") |
| 41 | + else: |
| 42 | + token = jwt_token |
| 43 | + |
| 44 | + if token is None or token == '': |
| 45 | + print('Error: JWT is required') |
| 46 | + return |
| 47 | + headers = {'Authorization': "JWT {}".format(token)} |
| 48 | + |
| 49 | + score_str = f'score={quote(args.score)}' |
| 50 | + if args.score is None: |
| 51 | + score_str = '' |
| 52 | + |
| 53 | + response_assets = requests.get( |
| 54 | + discovery_assets_endpoint.format(score_str=score_str), |
| 55 | + headers=headers |
| 56 | + ) |
| 57 | + response_assets.raise_for_status() |
| 58 | + assets_res = response_assets.json()['results'] |
| 59 | + |
| 60 | + csv_writer = csv.writer( |
| 61 | + args.output, delimiter=",", quotechar='"', quoting=csv.QUOTE_ALL |
| 62 | + ) |
| 63 | + row = ['ID', 'Name', 'URL', 'Type', 'Last Seen', 'Risk', 'Score', 'State'] |
| 64 | + csv_writer.writerow(row) |
| 65 | + for asset in assets_res: |
| 66 | + row = [ |
| 67 | + asset['id'], |
| 68 | + asset['name'], |
| 69 | + asset['url'], |
| 70 | + asset['type'], |
| 71 | + datetime.strptime(asset['last_seen'], "%Y-%m-%dT%H:%M:%SZ").strftime("%Y-%m-%d %H:%M:%S"), |
| 72 | + map_risk(asset['risk']), |
| 73 | + asset['score'], |
| 74 | + asset['state'], |
| 75 | + ] |
| 76 | + csv_writer.writerow(row) |
| 77 | + |
| 78 | + print('Done') |
| 79 | + |
| 80 | +if __name__ == '__main__': |
| 81 | + main() |
0 commit comments