Take a look at my example:
def collectStatsFromDB(self, device):
try:
connection = mysql.connector.connect(host=self.databaseUrl,
database=self.dbName,
user=self.dbUsername,
password=self.dbPasswd)
sql_select_Query = """
select metric from my_table
"""
cursor = connection.cursor()
cursor.execute(sql_select_Query)
record = cursor.fetchone()
if cursor.rowcount > 0:
result = [record[0]]
else:
result = [0]
# report stat counter
device.stat_counter(key='count', value=StatCounterDataPoint(
result[0], result[0], result[0], 1)
)
except Error as e:
logger.exception(e)
finally:
if (connection.is_connected()):
connection.close()
cursor.close()
print("MySQL connection is closed")
Senior Product Manager,
Dynatrace Managed expert
