forked from open-telemetry/opentelemetry-python-contrib
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Refactored sitecustomize and added tests
- Loading branch information
1 parent
edafb0a
commit 2a97615
Showing
4 changed files
with
426 additions
and
110 deletions.
There are no files selected for viewing
123 changes: 123 additions & 0 deletions
123
...telemetry-instrumentation/src/opentelemetry/instrumentation/auto_instrumentation/_load.py
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,123 @@ | ||
| # Copyright The OpenTelemetry Authors | ||
| # | ||
| # Licensed under the Apache License, Version 2.0 (the "License"); | ||
| # you may not use this file except in compliance with the License. | ||
| # You may obtain a copy of the License at | ||
| # | ||
| # http://www.apache.org/licenses/LICENSE-2.0 | ||
| # | ||
| # Unless required by applicable law or agreed to in writing, software | ||
| # distributed under the License is distributed on an "AS IS" BASIS, | ||
| # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| # See the License for the specific language governing permissions and | ||
| # limitations under the License. | ||
|
|
||
| from logging import getLogger | ||
| from os import environ | ||
|
|
||
| from pkg_resources import iter_entry_points | ||
|
|
||
| from opentelemetry.instrumentation.dependencies import ( | ||
| get_dist_dependency_conflicts, | ||
| ) | ||
| from opentelemetry.instrumentation.distro import BaseDistro, DefaultDistro | ||
| from opentelemetry.instrumentation.environment_variables import ( | ||
| OTEL_PYTHON_CONFIGURATOR, | ||
| OTEL_PYTHON_DISABLED_INSTRUMENTATIONS, | ||
| OTEL_PYTHON_DISTRO, | ||
| ) | ||
| from opentelemetry.instrumentation.version import __version__ | ||
|
|
||
| logger = getLogger(__name__) | ||
|
|
||
|
|
||
| def _load_distros() -> BaseDistro: | ||
| distro_name = environ.get(OTEL_PYTHON_DISTRO, None) | ||
| for entry_point in iter_entry_points("opentelemetry_distro"): | ||
| try: | ||
| if distro_name is None or distro_name == entry_point.name: | ||
| distro = entry_point.load()() | ||
| if not isinstance(distro, BaseDistro): | ||
| logger.debug( | ||
| "%s is not an OpenTelemetry Distro. Skipping", | ||
| entry_point.name, | ||
| ) | ||
| continue | ||
| logger.debug( | ||
| "Distribution %s will be configured", entry_point.name | ||
| ) | ||
| return distro | ||
| except Exception as exc: # pylint: disable=broad-except | ||
| logger.exception( | ||
| "Distribution %s configuration failed", entry_point.name | ||
| ) | ||
| raise exc | ||
| return DefaultDistro() | ||
|
|
||
|
|
||
| def _load_instrumentors(distro): | ||
| package_to_exclude = environ.get(OTEL_PYTHON_DISABLED_INSTRUMENTATIONS, []) | ||
| if isinstance(package_to_exclude, str): | ||
| package_to_exclude = package_to_exclude.split(",") | ||
| # to handle users entering "requests , flask" or "requests, flask" with spaces | ||
| package_to_exclude = [x.strip() for x in package_to_exclude] | ||
|
|
||
| for entry_point in iter_entry_points("opentelemetry_pre_instrument"): | ||
| entry_point.load()() | ||
|
|
||
| for entry_point in iter_entry_points("opentelemetry_instrumentor"): | ||
| if entry_point.name in package_to_exclude: | ||
| logger.debug( | ||
| "Instrumentation skipped for library %s", entry_point.name | ||
| ) | ||
| continue | ||
|
|
||
| try: | ||
| conflict = get_dist_dependency_conflicts(entry_point.dist) | ||
| if conflict: | ||
| logger.debug( | ||
| "Skipping instrumentation %s: %s", | ||
| entry_point.name, | ||
| conflict, | ||
| ) | ||
| continue | ||
|
|
||
| # tell instrumentation to not run dep checks again as we already did it above | ||
| distro.load_instrumentor(entry_point, skip_dep_check=True) | ||
| logger.debug("Instrumented %s", entry_point.name) | ||
| except Exception as exc: # pylint: disable=broad-except | ||
| logger.exception("Instrumenting of %s failed", entry_point.name) | ||
| raise exc | ||
|
|
||
| for entry_point in iter_entry_points("opentelemetry_post_instrument"): | ||
| entry_point.load()() | ||
|
|
||
|
|
||
| def _load_configurators(): | ||
| configurator_name = environ.get(OTEL_PYTHON_CONFIGURATOR, None) | ||
| configured = None | ||
| for entry_point in iter_entry_points("opentelemetry_configurator"): | ||
| if configured is not None: | ||
| logger.warning( | ||
| "Configuration of %s not loaded, %s already loaded", | ||
| entry_point.name, | ||
| configured, | ||
| ) | ||
| continue | ||
| try: | ||
| if ( | ||
| configurator_name is None | ||
| or configurator_name == entry_point.name | ||
| ): | ||
| entry_point.load()().configure(auto_instrumentation_version=__version__) # type: ignore | ||
| configured = entry_point.name | ||
| else: | ||
| logger.warning( | ||
| "Configuration of %s not loaded because %s is set by %s", | ||
| entry_point.name, | ||
| configurator_name, | ||
| OTEL_PYTHON_CONFIGURATOR, | ||
| ) | ||
| except Exception as exc: # pylint: disable=broad-except | ||
| logger.exception("Configuration of %s failed", entry_point.name) | ||
| raise exc |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.