|
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