Skip to content

Latest commit

 

History

History

azureblobreceiver

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
testdata
testdata
 
 
Makefile
Makefile
 
 
README.md
README.md
 
 
blobclient.go
blobclient.go
 
 
blobclient_test.go
blobclient_test.go
 
 
blobeventhandler.go
blobeventhandler.go
 
 
blobeventhandler_test.go
blobeventhandler_test.go
 
 
config.go
config.go
 
 
config_test.go
config_test.go
 
 
factory.go
factory.go
 
 
factory_test.go
factory_test.go
 
 
go.mod
go.mod
 
 
go.sum
go.sum
 
 
mock_blobclient.go
mock_blobclient.go
 
 
mock_logsdataconsumer.go
mock_logsdataconsumer.go
 
 
mock_tracesddataconsumer.go
mock_tracesddataconsumer.go
 
 
receiver.go
receiver.go
 
 
receiver_test.go
receiver_test.go
 
 

README.md

Azure Blob Receiver

Status
Stability development
Supported pipeline types logs,traces
Distributions [contrib]

This receiver reads logs and trace data from Azure Blob Storage.

Configuration

The following settings are required:

  • connection_string: (no default): Azure Blob Storage connection key, which can be found in the Azure Blob Storage resource on the Azure Portal.
  • event_hub: endpoint: (no default): Azure Event Hub endpoint triggering on the Blob Create event

The following settings can be optionally configured:

  • logs: container_name: (default = "logs"): Name of the blob container with the logs
  • traces: container_name: (default = "traces"): Name of the blob container with the traces

Example:

receivers:
  azureblob:
    connection_string: DefaultEndpointsProtocol=https;AccountName=accountName;AccountKey=+idLkHYcL0MUWIKYHm2j4Q==;EndpointSuffix=core.windows.net
    event_hub:
      endpoint: Endpoint=sb:https://oteldata.servicebus.windows.net/;SharedAccessKeyName=otelhubbpollicy;SharedAccessKey=mPJVubIK5dJ6mLfZo1ucsdkLysLSQ6N7kddvsIcmoEs=;EntityPath=otellhub

The receiver subscribes on the events published by Azure Blob Storage and handled by Azure Event Hub. When it receives Blob Create event, it reads the logs or traces from a corresponding blob and deletes it after processing.