src/journal-remote/log-generator.py

   1 #!/usr/bin/python
   2 from __future__ import print_function
   3 import sys
   4 import argparse
   5
   6 PARSER = argparse.ArgumentParser()
   7 PARSER.add_argument('n', type=int)
   8 PARSER.add_argument('--dots', action='store_true')
   9 PARSER.add_argument('--data-size', type=int, default=4000)
  10 PARSER.add_argument('--data-type', choices={'random', 'simple'})
  11 OPTIONS = PARSER.parse_args()
  12
  13 template = """\
  14 __CURSOR=s=6863c726210b4560b7048889d8ada5c5;i=3e931;b=f446871715504074bf7049ef0718fa93;m={m:x};t=4fd05c
  15 __REALTIME_TIMESTAMP={realtime_ts}
  16 __MONOTONIC_TIMESTAMP={monotonic_ts}
  17 _BOOT_ID=f446871715504074bf7049ef0718fa93
  18 _TRANSPORT=syslog
  19 PRIORITY={priority}
  20 SYSLOG_FACILITY={facility}
  21 SYSLOG_IDENTIFIER=/USR/SBIN/CRON
  22 MESSAGE={message}
  23 _UID=0
  24 _GID=0
  25 _MACHINE_ID=69121ca41d12c1b69a7960174c27b618
  26 _HOSTNAME=hostname
  27 SYSLOG_PID=25721
  28 _PID=25721
  29 _SOURCE_REALTIME_TIMESTAMP={source_realtime_ts}
  30 DATA={data}
  31 """
  32
  33 m  = 0x198603b12d7
  34 realtime_ts = 1404101101501873
  35 monotonic_ts = 1753961140951
  36 source_realtime_ts = 1404101101483516
  37 priority = 3
  38 facility = 6
  39
  40 src = open('/dev/urandom', 'rb')
  41
  42 bytes = 0
  43 counter = 0
  44
  45 for i in range(OPTIONS.n):
  46     message = repr(src.read(2000))
  47     if OPTIONS.data_type == 'random':
  48         data = repr(src.read(OPTIONS.data_size))
  49     else:
  50         # keep the pattern non-repeating so we get a different blob every time
  51         data = '{:0{}}'.format(counter, OPTIONS.data_size)
  52         counter += 1
  53
  54     entry = template.format(m=m,
  55                             realtime_ts=realtime_ts,
  56                             monotonic_ts=monotonic_ts,
  57                             source_realtime_ts=source_realtime_ts,
  58                             priority=priority,
  59                             facility=facility,
  60                             message=message,
  61                             data=data)
  62     m += 1
  63     realtime_ts += 1
  64     monotonic_ts += 1
  65     source_realtime_ts += 1
  66
  67     bytes += len(entry)
  68
  69     print(entry)
  70
  71     if OPTIONS.dots:
  72         print('.', file=sys.stderr, end='', flush=True)
  73
  74 if OPTIONS.dots:
  75         print(file=sys.stderr)
  76 print('Wrote {} bytes'.format(bytes), file=sys.stderr)