From a1c2d458de0ea0eec02583d46a8838a1bb158940 Mon Sep 17 00:00:00 2001 From: James Tanner Date: Tue, 17 Nov 2020 17:48:13 -0500 Subject: [PATCH] get a csv of playbook_on_stats event data --- awx/main/analytics/collectors.py | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) diff --git a/awx/main/analytics/collectors.py b/awx/main/analytics/collectors.py index 0f51ad179a..db58395a63 100644 --- a/awx/main/analytics/collectors.py +++ b/awx/main/analytics/collectors.py @@ -309,6 +309,25 @@ def events_table(since, full_path, until, **kwargs): return _copy_table(table='events', query=events_query, path=full_path) +@register('events_table_playbook_stats', '1.1', format='csv', description=_('playbook on stats records'), expensive=True) +def events_table_playbook_stats(since, full_path, until, **kwargs): + events_query = '''COPY (SELECT main_jobevent.id, + main_jobevent.created, + main_jobevent.uuid, + main_jobevent.parent_uuid, + main_jobevent.event, + main_jobevent.failed, + main_jobevent.changed, + main_jobevent.playbook, + main_jobevent.job_id, + main_jobevent.event_data + FROM main_jobevent + WHERE (main_jobevent.created > '{}' AND main_jobevent.created <= '{}' AND event='playbook_on_stats') + ORDER BY main_jobevent.id ASC) TO STDOUT WITH CSV HEADER + '''.format(since.isoformat(),until.isoformat()) + return _copy_table(table='events_playbook_stats', query=events_query, path=full_path) + + @register('unified_jobs_table', '1.1', format='csv', description=_('Data on jobs run'), expensive=True) def unified_jobs_table(since, full_path, until, **kwargs): unified_job_query = '''COPY (SELECT main_unifiedjob.id,