mirror of
https://github.com/tstack/lnav
synced 2024-11-17 15:29:40 +00:00
165 lines
3.3 KiB
Python
Executable File
165 lines
3.3 KiB
Python
Executable File
#! /usr/bin/env python3
|
|
|
|
import os
|
|
import sys
|
|
import time
|
|
import uuid
|
|
import shutil
|
|
import random
|
|
import datetime
|
|
|
|
SYSLOG_DATE_FMT = "%b %d %H:%M:%S"
|
|
ACCESS_LOG_DATE_FMT = "%d/%b/%Y:%H:%M:%S"
|
|
GENERIC_DATE_FMT = "%Y-%m-%dT%H:%M:%S.%%s"
|
|
|
|
TEST_ADDRESSES = [
|
|
"192.0.2.55",
|
|
#"192.0.2.123",
|
|
"192.0.2.33",
|
|
#"192.0.2.2",
|
|
]
|
|
|
|
TEST_USERNAMES = [
|
|
"bob@example.com",
|
|
"-",
|
|
"-",
|
|
"-",
|
|
"-",
|
|
"-",
|
|
"-",
|
|
]
|
|
|
|
TEST_METHODS = [
|
|
"GET",
|
|
"GET",
|
|
"GET",
|
|
"GET",
|
|
"GET",
|
|
"GET",
|
|
"PUT",
|
|
]
|
|
|
|
TEST_URLS = [
|
|
"/index.html",
|
|
"/index.html",
|
|
"/index.html",
|
|
"/features.html",
|
|
"/images/compass.jpg",
|
|
"/obj/1234",
|
|
"/obj/1235?foo=bar",
|
|
"/obj/1236?search=demo&start=1",
|
|
]
|
|
|
|
TEST_VERSIONS = [
|
|
"HTTP/1.0",
|
|
"HTTP/1.0",
|
|
"HTTP/1.1",
|
|
]
|
|
|
|
TEST_STATUS = [
|
|
200,
|
|
200,
|
|
200,
|
|
200,
|
|
200,
|
|
200,
|
|
200,
|
|
200,
|
|
200,
|
|
200,
|
|
404,
|
|
500
|
|
]
|
|
|
|
TEST_REFERRERS = [
|
|
"-",
|
|
"-",
|
|
"-",
|
|
"-",
|
|
"-",
|
|
"-",
|
|
"http://lnav.org/download.html",
|
|
]
|
|
|
|
TEST_AGENTS = [
|
|
"-",
|
|
"-",
|
|
"-",
|
|
"-",
|
|
"Apache-HttpClient/4.2.3 (java 1.5)",
|
|
"Apache-HttpClient/4.2.3 (java 1.5)",
|
|
"Apache-HttpClient/4.2.3 (java 1.5)",
|
|
"Apache-HttpClient/4.2.3 (java 1.5)",
|
|
"Apache-HttpClient/4.2.3 (java 1.5)",
|
|
]
|
|
|
|
def access_log_msgs():
|
|
while True:
|
|
now = datetime.datetime.now()
|
|
ts = now - datetime.timedelta(seconds=1)
|
|
yield '%s - %s [%s +0000] "%s %s %s" %s %s "%s" "%s"\n' % (
|
|
random.choice(TEST_ADDRESSES),
|
|
random.choice(TEST_USERNAMES),
|
|
ts.strftime(ACCESS_LOG_DATE_FMT),
|
|
random.choice(TEST_METHODS),
|
|
random.choice(TEST_URLS),
|
|
random.choice(TEST_VERSIONS),
|
|
random.choice(TEST_STATUS),
|
|
random.randint(16, 1024 * 1024),
|
|
random.choice(TEST_REFERRERS),
|
|
random.choice(TEST_AGENTS)
|
|
)
|
|
|
|
TEST_PROCS = [
|
|
"server[123]",
|
|
"server[123]",
|
|
"server[123]",
|
|
"server[121]",
|
|
"server[124]",
|
|
"server[123]",
|
|
"worker[61456]",
|
|
"worker[61456]",
|
|
"worker[61457]",
|
|
]
|
|
|
|
TEST_MSGS = [
|
|
"Handling request %s" % uuid.uuid4(),
|
|
"Handling request %s" % uuid.uuid4(),
|
|
"Handling request %s" % uuid.uuid4(),
|
|
"Successfully started helper",
|
|
"Reading from device: /dev/hda",
|
|
"Received packet from %s" % random.choice(TEST_ADDRESSES),
|
|
"Received packet from %s" % random.choice(TEST_ADDRESSES),
|
|
"Received packet from %s" % random.choice(TEST_ADDRESSES),
|
|
]
|
|
|
|
def syslog_msgs():
|
|
while True:
|
|
yield '%s frontend3 %s: %s\n' % (
|
|
datetime.datetime.now().strftime(SYSLOG_DATE_FMT),
|
|
random.choice(TEST_PROCS),
|
|
random.choice(TEST_MSGS),
|
|
)
|
|
|
|
try:
|
|
shutil.rmtree("/tmp/demo")
|
|
os.makedirs("/tmp/demo")
|
|
except OSError:
|
|
pass
|
|
|
|
FILES = [
|
|
("/tmp/demo/access_log", access_log_msgs()),
|
|
("/tmp/demo/messages", syslog_msgs()),
|
|
]
|
|
|
|
while True:
|
|
for fname, gen in FILES:
|
|
for i in range(random.randrange(0, 4)):
|
|
with open(fname, "a+") as fp:
|
|
fp.write(next(gen))
|
|
#if random.uniform(0.0, 1.0) < 0.010:
|
|
# fp.truncate(0)
|
|
time.sleep(random.uniform(0.05, 0.10))
|
|
#if random.uniform(0.0, 1.0) < 0.001:
|
|
# os.remove(fname)
|