|  | 
| 2 | 2 | from flask import Flask, request | 
| 3 | 3 | import structlog | 
| 4 | 4 | import sys | 
| 5 |  | -sys.path.insert(0, '../../..') | 
|  | 5 | + | 
|  | 6 | +sys.path.insert(0, "../../..") | 
| 6 | 7 | from handlers.opentelemetry_structlog.src.exporter import StructlogHandler | 
| 7 | 8 | from opentelemetry.exporter.otlp.proto.grpc._log_exporter import ( | 
| 8 | 9 |     OTLPLogExporter, | 
| 9 | 10 | ) | 
| 10 | 11 | from opentelemetry.sdk._logs import LoggerProvider | 
| 11 | 12 | from opentelemetry.sdk.resources import Resource | 
| 12 | 13 | from opentelemetry._logs import set_logger_provider | 
| 13 |  | -from opentelemetry.sdk._logs.export import BatchLogRecordProcessor | 
| 14 |  | -from opentelemetry.sdk.resources import Resource | 
| 15 | 14 | 
 | 
| 16 | 15 | logger_provider = LoggerProvider( | 
| 17 | 16 |     resource=Resource.create( | 
|  | 
| 23 | 22 | ) | 
| 24 | 23 | set_logger_provider(logger_provider) | 
| 25 | 24 | 
 | 
| 26 |  | -# Replace the standard logging configuration with Loguru | 
| 27 |  | -structlog_handler = StructlogHandler(service_name="flask-structlog-demo", server_hostname="instance-1", exporter=OTLPLogExporter(insecure=True))  | 
|  | 25 | +# Replace the standard logging configuration with structlog | 
|  | 26 | +structlog_handler = StructlogHandler( | 
|  | 27 | +    service_name="flask-structlog-demo", | 
|  | 28 | +    server_hostname="instance-1", | 
|  | 29 | +    exporter=OTLPLogExporter(insecure=True), | 
|  | 30 | +) | 
| 28 | 31 | structlog_handler._logger_provider = logger_provider | 
| 29 |  | -structlog_logger = structlog.wrap_logger(structlog.get_logger(), processors=[structlog_handler])  # Add  StructlogHandler to the logger | 
| 30 |  | - | 
|  | 32 | +structlog_logger = structlog.wrap_logger( | 
|  | 33 | +    structlog.get_logger(), processors=[structlog_handler] | 
|  | 34 | +)  # Add  StructlogHandler to the logger | 
| 31 | 35 | 
 | 
| 32 | 36 | 
 | 
| 33 | 37 | app = Flask(__name__) | 
| 34 | 38 | 
 | 
|  | 39 | + | 
| 35 | 40 | @app.route("/rolldice") | 
| 36 | 41 | def roll_dice(): | 
| 37 |  | -    player = request.args.get('player', default=None, type=str) | 
|  | 42 | +    player = request.args.get("player", default=None, type=str) | 
| 38 | 43 |     result = str(roll()) | 
| 39 | 44 |     if player: | 
| 40 |  | -        structlog_logger.warning("Player %s is rolling the dice: %s", player, result, level="warning") | 
|  | 45 | +        structlog_logger.warning( | 
|  | 46 | +            "Player %s is rolling the dice: %s", player, result, level="warning" | 
|  | 47 | +        ) | 
| 41 | 48 |     else: | 
| 42 |  | -        structlog_logger.warning("Anonymous player is rolling the dice: %s", result, level="warning") | 
|  | 49 | +        structlog_logger.warning( | 
|  | 50 | +            "Anonymous player is rolling the dice: %s", result, level="warning" | 
|  | 51 | +        ) | 
| 43 | 52 |     return result | 
| 44 | 53 | 
 | 
| 45 | 54 | 
 | 
|  | 
0 commit comments