Skip to content

Commit

Permalink
Adding the localhost setup steps
Browse files Browse the repository at this point in the history
  • Loading branch information
balasiddhartha committed Dec 7, 2024
1 parent c719036 commit 134464a
Showing 1 changed file with 161 additions and 0 deletions.
161 changes: 161 additions & 0 deletions data/docs/logs-management/send-logs/zap-to-signoz.mdx
Original file line number Diff line number Diff line change
Expand Up @@ -193,4 +193,165 @@ For looking at logs, login into signoz cloud and navigate into logs tab to view

</TabItem>



<TabItem value="self-host" label="Self-Host" default>

### Requirements

- Go Modules: Ensure your project is using the following Go modules.

```bash
go get go.opentelemetry.io/contrib/bridges/otelzap
go get go.opentelemetry.io/otel/exporters/otlp/otlplog/otlploghttp
go get go.uber.org/zap
```

We import the required packages:

- `otelzap`: The bridge for Zap logger to work with OpenTelemetry.
- `otlploghttp`: The OTLP exporter for logs over HTTP.
- `zap`: The high-performance logging library.

### Define Endpoint and Access Token

You need to provide

- `otlpEndpoint`: The URL of your SigNoz Cloud OTLP collector endpoint.

```go
otlpEndpoint := "<signoz-client-url>" // For local this is usually 0.0.0.0:4318
```

### Create Exporter

```go
ctx := context.Background()
exporter, err := otlploghttp.New(ctx,
otlploghttp.WithEndpoint(otlpEndpoint),
otlploghttp.WithInsecure(),
)
if err != nil {
fmt.Println(err)
}
```

Here, we create an OTLP HTTP exporter. This is responsible for exporting log records to an OTLP endpoint (like the OpenTelemetry collector).

### Log Processor

```go
processor := log.NewBatchProcessor(exporter)
```

A batch processor is used to efficiently group and export log records. The processor ensures that log records are buffered and sent in batches to the OTLP endpoint.

### Logger Provider

```go
provider := log.NewLoggerProvider(
log.WithProcessor(processor),
)

defer func() {
err := provider.Shutdown(context.Background())
if err != nil {
fmt.Println(err)
}
}()
```

The `LoggerProvider` serves as the core log provider, which connects the log pipeline (processor) to the Zap logger. This ensures that logs generated by your application will pass through OpenTelemetry’s logging mechanisms.

It's important to properly shut down the `LoggerProvider` to ensure that no logs are left unprocessed before the application exits.

Zap Logger Initialisation

```go
logger := zap.New(otelzap.NewCore("my/pkg/name", otelzap.WithLoggerProvider(provider)))
defer logger.Sync()
```

We initialise a Zap logger, but instead of using Zap’s native logging core, we create an OpenTelemetry-based core (`otelzap.NewCore`). This core connects Zap’s logging functionality to the OpenTelemetry log pipeline, ensuring logs are exported.

- `"my/pkg/name"`: Specifies the package name or source of the logs, useful for debugging.
- `otelzap.WithLoggerProvider(provider)`: Connects the previously created OpenTelemetry `LoggerProvider`.

### Logging Messages

```go
logger.Info("something really cool")
```

The `logger.Info` method logs messages. In this example, instead of writing logs to standard output, they are sent to the OTLP endpoint.

### Trace With Context

```go
logger.Info("setting context", zap.Any("context", ctx))
```

You can include the context for more contextual tracing of the log messages

logging.go

```go
package logging

import (
"context"
"fmt"

"go.opentelemetry.io/contrib/bridges/otelzap"
"go.opentelemetry.io/otel/exporters/otlp/otlplog/otlploghttp"
"go.opentelemetry.io/otel/sdk/log"
"go.uber.org/zap"
)

func Example() {

otlpEndpoint := "<signoz-client-url>" // For local instance, this is usually 0.0.0.0:4318
ctx := context.Background()

// Create an exporter that will emit log records.
exporter, err := otlploghttp.New(ctx,
otlploghttp.WithEndpoint(otlpEndpoint),
otlploghttp.WithInsecure(),
)
if err != nil {
fmt.Println(err)
}
// Create a log record processor pipeline.
processor := log.NewBatchProcessor(exporter)

// Create a logger provider.
// You can pass this instance directly when creating a log bridge.
provider := log.NewLoggerProvider(
log.WithProcessor(processor),
)

defer func() {
err := provider.Shutdown(context.Background())
if err != nil {
fmt.Println(err)
}
}()

// Initialize a zap logger with the otelzap bridge core.
logger := zap.New(otelzap.NewCore("my/pkg/name", otelzap.WithLoggerProvider(provider)))
defer logger.Sync()

// You can now use your logger in your code.
logger.Info("something really cool")

// You can set context for trace correlation using zap.Any or zap.Reflect
logger.Info("setting context", zap.Any("context", ctx))

logger.Info("Hello from Zap logger!")
}

```

</TabItem>

</Tabs>

0 comments on commit 134464a

Please sign in to comment.