Functions
def	create_analog_map ()

def	__create_conn__ ()

def	__query_cu_info__ (conn)

def	__write_analog_map_rows__ (filename, rows)

Variables
	LOGGER = logging.getLogger(__name__)

	DATABASE_HOST = os.environ['DATABASE_HOST']

	DATABASE_PORT = os.environ['DATABASE_PORT']

	DATABASE_NAME = os.environ['DATABASE_NAME']

	DATABASE_USER = os.environ['DATABASE_USER']

	DATABASE_PASSWORD = os.environ['DATABASE_PASSWORD']

string	DB_URL

	MAP_DIR = os.environ.get('ANALOG_MAP_DIR', '/home/httpd/homecu/stats')

	UID = pwd.getpwnam('www-data').pw_uid

Detailed Description

Generate map.txt for analog stats parsing

Function Documentation

◆ __create_conn__()

def generate_analog_map.__create_conn__ ( )

Create Database connection

Definition at line 42 of file generate_analog_map.py.

 def __create_conn__():
     '''Create Database connection'''
     return psycopg2.connect(DB_URL)
 
 

◆ __query_cu_info__()

def generate_analog_map.__query_cu_info__ ( conn )

Query cuinfo for username and urls

Definition at line 47 of file generate_analog_map.py.

 def __query_cu_info__(conn):
     '''Query cuinfo for username and urls'''
     assert conn
     with conn.cursor() as cur:
         cur.execute('SELECT user_name, web_host FROM cuinfo;')
         return cur.fetchall()
 
 

◆ __write_analog_map_rows__()

def generate_analog_map.__write_analog_map_rows__	(	filename,
		rows
	)

Write map.txt with provided rows

Definition at line 55 of file generate_analog_map.py.

 def __write_analog_map_rows__(filename, rows):
     '''Write map.txt with provided rows'''
     with open(filename, 'w') as map_file:
         for (user_name, web_host) in rows:
             map_file.write('%s:%s %s' % (user_name.upper(),
                                          user_name.lower(),
                                          urlparse(web_host).hostname))
         # write EOF \n
         map_file.write(os.linesep)
     return filename
 

◆ create_analog_map()

def generate_analog_map.create_analog_map ( )

Query DB and create analog map.txt

Definition at line 32 of file generate_analog_map.py.

 def create_analog_map():
     '''Query DB and create analog map.txt'''
     if not os.path.exists(MAP_DIR):
         os.makedirs(MAP_DIR)
     map_filename = os.path.join(MAP_DIR, 'map.txt')
     with __create_conn__() as conn:
         compose(partial(__write_analog_map_rows__, map_filename),
                 __query_cu_info__)(conn)
 
 

Variable Documentation

◆ DB_URL

string generate_analog_map.DB_URL

Initial value:

 =  'postgresql://%s:%s@%s:%s/%s' % (DATABASE_USER,
                                           DATABASE_PASSWORD,
                                           DATABASE_HOST,
                                           DATABASE_PORT,
                                           DATABASE_NAME)

Definition at line 23 of file generate_analog_map.py.

Functions

Variables