How to find customer schema in APM?

Shubhangi · December 16, 2019, 7:48am

Kibana version: 6.8

Elasticsearch version: 6.8

APM Server version: 6.8

APM Agent language and version: Java 8

Browser version: Firefox 66.0.3 (64-bit)

Original install method (e.g. download page, yum, deb, from source, etc.) and version: binary files from elastic.co

Fresh install or upgraded from other version? fresh

Description of the problem including expected versus actual behavior. Please include screenshots (if relevant):
How to find customer schema in APM? In the database statement we can only see the table in the query. Is there any way to find schema name for a query? It'd help a lot in the analysis!

felixbarny · December 16, 2019, 12:37pm

How can the schema be retrieved? Via https://docs.oracle.com/javase/8/docs/api/java/sql/Connection.html#getSchema--?

Shubhangi · December 17, 2019, 6:23am

How do I integrate it with ELK APM? Do I have to run a script, add a field or ingest a pipeline?
Thanks.

felixbarny · December 17, 2019, 8:32am

If the schema is within your DB query, you can use an ingest processor to extract it. If it's not available there, we'd need to add some logic to the agent to capture it.

Shubhangi · December 18, 2019, 6:26am

It is not in the query.

Can you please specify and elaborate on what kind of logic I can use and how?

felixbarny · December 18, 2019, 8:46am

This requires changes in the within the agent, it's nothing you can do within your application.

Can you verify that Connection#getSchema returns the expected schema?

If so, we could make a change here to also capture the schema:

github.com

elastic/apm-agent-java/blob/a2d6063d0a2cd7f90caf1d28682ca6bdfc3d9609/apm-agent-plugins/apm-jdbc-plugin/src/main/java/co/elastic/apm/agent/jdbc/helper/JdbcHelperImpl.java#L121-L131


private ConnectionMetaData getConnectionMetaData(Connection connection) throws SQLException {
    ConnectionMetaData connectionMetaData = metaDataMap.get(connection);
    if (connectionMetaData == null) {
        final DatabaseMetaData metaData = connection.getMetaData();
        String dbVendor = getDbVendor(metaData.getURL());
        connectionMetaData = new ConnectionMetaData(dbVendor, metaData.getUserName());
        metaDataMap.put(connection, connectionMetaData);
    }
    return connectionMetaData;


}

However, it also requires changes in the Intake API so that the APM Server recognizes and correctly indexes that field.

system · January 8, 2020, 4:46am

This topic was automatically closed 20 days after the last reply. New replies are no longer allowed.