import pymysql
import os
import syslog

host = os.environ['DB_HOST']
user = os.environ['DB_USER']
password = os.environ['DB_PASSWORD']
db = os.environ['DB_DATABASE']

syslog.openlog(facility=syslog.LOG_USER)
syslog.syslog("Inserting new business data into database.")

connection = pymysql.connect(host=host,
                             user=user,
                             password=password,
                             db=db,
                             cursorclass=pymysql.cursors.DictCursor)

try:
    with connection.cursor() as cursor:
        # Create a new record
        sql = "CALL insert_data({0})".format(1)
        cursor.execute(sql)

    # connection is not autocommit by default. So you must commit to save
    # your changes.
    connection.commit()

finally:
    connection.close()

import pymysql
import os
import syslog

host = os.environ['DB_HOST']
user = os.environ['DB_USER']
password = os.environ['DB_PASSWORD']
db = os.environ['DB_DATABASE']

syslog.openlog(logoption=syslog.LOG_PID, facility=syslog.LOG_USER)
syslog.syslog("Inserting new business data into database.")

connection = pymysql.connect(host=host,
                             user=user,
                             password=password,
                             db=db,
                             cursorclass=pymysql.cursors.DictCursor)

try:
    with connection.cursor() as cursor:
        # Create a new record
        sql = "CALL insert_data({0})".format(1)
        cursor.execute(sql)

    # connection is not autocommit by default. So you must commit to save
    # your changes.
    connection.commit()

finally:
    connection.close()

Set flag to log process id in syslog
Set flag to log process id in syslog

  import pymysql
  import os
  import syslog
  
  host = os.environ['DB_HOST']
  user = os.environ['DB_USER']
  password = os.environ['DB_PASSWORD']
  db = os.environ['DB_DATABASE']
  
- syslog.openlog(facility=syslog.LOG_USER)
+ syslog.openlog(logoption=syslog.LOG_PID, facility=syslog.LOG_USER)
  syslog.syslog("Inserting new business data into database.")
  
  connection = pymysql.connect(host=host,
                               user=user,
                               password=password,
                               db=db,
                               cursorclass=pymysql.cursors.DictCursor)
  
  try:
      with connection.cursor() as cursor:
          # Create a new record
          sql = "CALL insert_data({0})".format(1)
          cursor.execute(sql)
  
      # connection is not autocommit by default. So you must commit to save
      # your changes.
      connection.commit()
  
  finally:
      connection.close()
  
Set flag to log process id in syslog
## Code Before:
import pymysql
import os
import syslog

host = os.environ['DB_HOST']
user = os.environ['DB_USER']
password = os.environ['DB_PASSWORD']
db = os.environ['DB_DATABASE']

syslog.openlog(facility=syslog.LOG_USER)
syslog.syslog("Inserting new business data into database.")

connection = pymysql.connect(host=host,
                             user=user,
                             password=password,
                             db=db,
                             cursorclass=pymysql.cursors.DictCursor)

try:
    with connection.cursor() as cursor:
        # Create a new record
        sql = "CALL insert_data({0})".format(1)
        cursor.execute(sql)

    # connection is not autocommit by default. So you must commit to save
    # your changes.
    connection.commit()

finally:
    connection.close()

## Instruction:
Set flag to log process id in syslog
## Code After:
import pymysql
import os
import syslog

host = os.environ['DB_HOST']
user = os.environ['DB_USER']
password = os.environ['DB_PASSWORD']
db = os.environ['DB_DATABASE']

syslog.openlog(logoption=syslog.LOG_PID, facility=syslog.LOG_USER)
syslog.syslog("Inserting new business data into database.")

connection = pymysql.connect(host=host,
                             user=user,
                             password=password,
                             db=db,
                             cursorclass=pymysql.cursors.DictCursor)

try:
    with connection.cursor() as cursor:
        # Create a new record
        sql = "CALL insert_data({0})".format(1)
        cursor.execute(sql)

    # connection is not autocommit by default. So you must commit to save
    # your changes.
    connection.commit()

finally:
    connection.close()
