openstack/osprofiler
Code Issues Proposed changes

Don't fail if sqlalchemy driver fails to initialize

Browse Source 
Given that the driver is initialized during the service
startup (eg. like Keystone, Nova, ...) a osprofiler driver failure has
a huge impact on the service (when the driver fails, the whole service
is not usable).
We want to avoid that and just log error/exceptions but keep the
services running.

Change-Id: I5688f10364884a74b7eb44c0c8bda15730ccd424
Closes-Bug: 1819433
This commit is contained in:
Thomas Bechtold
2019-03-11 11:20:19 +01:00
parent da7a8592ae
commit add4794120
1 changed files with 43 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files

80
osprofiler/drivers/sqlalchemy_driver.py
View File

@@ -34,34 +34,40 @@ class SQLAlchemyDriver(base.Driver):
from sqlalchemy import Table, MetaData, Column from sqlalchemy import Table, MetaData, Column
from sqlalchemy import String, JSON, Integer from sqlalchemy import String, JSON, Integer
except ImportError: except ImportError:
raise exc.CommandError( LOG.exception("To use this command, install 'SQLAlchemy'")
"To use this command, you should install 'SQLAlchemy'") else:
self._metadata = MetaData()
self._data_table = Table(
"data", self._metadata,
Column("id", Integer, primary_key=True),
# timestamp - date/time of the trace point
Column("timestamp", String(26), index=True),
# base_id - uuid common for all notifications related to
# one trace
Column("base_id", String(255), index=True),
# parent_id - uuid of parent element in trace
Column("parent_id", String(255), index=True),
# trace_id - uuid of current element in trace
Column("trace_id", String(255), index=True),
Column("project", String(255), index=True),
Column("host", String(255), index=True),
Column("service", String(255), index=True),
# name - trace point name
Column("name", String(255), index=True),
Column("data", JSON)
)
self._engine = create_engine(connection_str) # we don't want to kill any service that does use osprofiler
self._conn = self._engine.connect() try:
self._metadata = MetaData() self._engine = create_engine(connection_str)
self._data_table = Table( self._conn = self._engine.connect()
"data", self._metadata,
Column("id", Integer, primary_key=True),
# timestamp - date/time of the trace point
Column("timestamp", String(26), index=True),
# base_id - uuid common for all notifications related to one trace
Column("base_id", String(255), index=True),
# parent_id - uuid of parent element in trace
Column("parent_id", String(255), index=True),
# trace_id - uuid of current element in trace
Column("trace_id", String(255), index=True),
Column("project", String(255), index=True),
Column("host", String(255), index=True),
Column("service", String(255), index=True),
# name - trace point name
Column("name", String(255), index=True),
Column("data", JSON)
)
# FIXME(toabctl): Not the best idea to create the table on every # FIXME(toabctl): Not the best idea to create the table on every
# startup when using the sqlalchemy driver... # startup when using the sqlalchemy driver...
self._metadata.create_all(self._engine, checkfirst=True) self._metadata.create_all(self._engine, checkfirst=True)
except Exception:
LOG.exception("Failed to create engine/connection and setup "
"intial database tables")
@classmethod @classmethod
def get_name(cls): def get_name(cls):
@@ -79,18 +85,18 @@ class SQLAlchemyDriver(base.Driver):
service = data.pop("service", self.service) service = data.pop("service", self.service)
name = data.pop("name", None) name = data.pop("name", None)
ins = self._data_table.insert().values(
timestamp=timestamp,
base_id=base_id,
parent_id=parent_id,
trace_id=trace_id,
project=project,
service=service,
host=host,
name=name,
data=jsonutils.dumps(data)
)
try: try:
ins = self._data_table.insert().values(
timestamp=timestamp,
base_id=base_id,
parent_id=parent_id,
trace_id=trace_id,
project=project,
service=service,
host=host,
name=name,
data=jsonutils.dumps(data)
)
self._conn.execute(ins) self._conn.execute(ins)
except Exception: except Exception:
LOG.exception("Can not store osprofiler tracepoint {} " LOG.exception("Can not store osprofiler tracepoint {} "