IKuznetsov: Новая страница: «В следующем примере конфигурации показано, как настроить экземпляр '''Collector''' для преобра...»

2025-10-08T21:00:17Z

Новая страница: «В следующем примере конфигурации показано, как настроить экземпляр '''Collector''' для преобра...»

Новая страница

В следующем примере конфигурации показано, как настроить экземпляр '''Collector''' для преобразования и обработки запросов '''OTLP''' перед их пересылкой в Ключ-АСТРОМ.

Используя процессоры, показанные в этом примере (<code>filter</code>и <code>transform</code>), можно оптимизировать запросы перед их отправкой в Ключ-АСТРОМ и исключить данные, которые могут быть нерелевантными для вашего варианта использования, а также сократить расходы на выставление счетов.

== Предустановка ==

* Один из следующих дистрибутивов '''Collector''' с процессорами [https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/v0.136.0/processor/transformprocessor преобразования] и [https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/v0.136.0/processor/filterprocessor фильтрации]
** [[Collector Ключ-АСТРОМ|'''Collector''' Ключ-АСТРОМ]]
** [[Collector Ключ-АСТРОМ|OpenTelemetry Contrib]]
** [[Collector Ключ-АСТРОМ|Пользовательская версия Builder]]
* [[Экспорт с помощью OTLP|URL-адрес конечной точки API Ключ-АСТРОМ]], на которую следует экспортировать данные.
* [[Экспорт с помощью OTLP|Токен API]] с соответствующей областью доступа (требуется только для '''SaaS''' и АктивногоШлюза)

Информацию о настройке '''Collector''' с использованием указанной ниже конфигурации см. в разделах [[Развертывание Collector|Развертывание коллектора]] и [[Настройка Collector|Конфигурация коллектора]].

== Демо конфигурация ==
{| class="wikitable"
|receivers:

otlp:

protocols:

grpc:

endpoint: 0.0.0.0:4317

http:

endpoint: 0.0.0.0:4318

processors:

transform:

trace_statements:

- context: resource

statements:

# Only keep a certain set of resource attributes

- keep_matching_keys(attributes, "^(aaa|bbb|ccc).*")

- context: span

statements:

# Only keep a certain set of span attributes

- keep_matching_keys(attributes, "(^xyz.pqr$)|(^(aaa|bbb|ccc).*)")

# Set a static key

- set(attributes["svc.marker"], "purchasing")

# Delete a specific key

- delete_key(attributes, "message")

# Rewrite a key

- set(attributes["purchase.id"], ConvertCase(attributes["purchase.id"], "upper"))

# Apply regex replacement

- replace_pattern(name, "^.*(DataSubmission-\d+).*$", "$$1")

metric_statements:

- context: metric

statements:

# Rename all metrics containing '_bad' suffix in their name with `_invalid`

- replace_pattern(name, "(.*)_bad$", "$${1}_invalid")

filter:

error_mode: ignore

traces:

span:

# Filter spans with resource attributes matching the provided regular expression

- IsMatch(resource.attributes["k8s.pod.name"], "^my-pod-name.*")

metrics:

metric:

# Filter metrics which contain at least one data point with a "bad.metric" attribute

- 'HasAttrKeyOnDatapoint("bad.metric")'

logs:

log_record:

# Filter logs with resource attributes matching the configured names

- resource.attributes["service.name"] == "service1"

- resource.attributes["service.name"] == "service2"

exporters:

otlphttp:

endpoint: ${env:DT_ENDPOINT}

headers:

Authorization: "Api-Token ${env:DT_API_TOKEN}"

service:

pipelines:

traces:

receivers: [otlp]

processors: [filter,transform]

exporters: [otlphttp]

metrics:

receivers: [otlp]

processors: [filter]

exporters: [otlphttp]

logs:

receivers: [otlp]

processors: [filter]

exporters: [otlphttp]
|}

== Компоненты ==
Для нашей конфигурации мы настраиваем следующие компоненты.

=== Приемник ===
В разделе <code>receivers</code>мы указываем стандартный <code>otlp</code>приемник как активный компонент приемника для нашего экземпляра Collector.

Это сделано для демонстрации. Вы можете указать здесь любой другой допустимый получатель (например, <code>zipkin</code>).

=== Процессор ===

==== Преобразование ====
В разделе <code>processors</code> мы указываем [https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/v0.136.0/processor/transformprocessor процессор <code>transform</code>] с набором различных операторов модификации атрибутов. <code>context</code> указывает область, к которой должны применяться операторы (в данном случае для атрибутов ресурсов <code>resource</code>, для атрибутов диапазона <code>span</code> и для метрик <code>metric</code>).

Более подробную информацию об отдельных параметрах конфигурации см . в [https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.136.0/processor/transformprocessor/README.md документации OpenTelemetry процессора преобразования]

В приведенном выше примере конфигурации используются следующие операторы:
{| class="wikitable"
!Значение
!Описание
|-
|<code>[https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.136.0/pkg/ottl/ottlfuncs/README.md#keep_matching_keys keep_matching_keys]</code>
|Оценивает имена ключей атрибутов и сохраняет только те, имена которых соответствуют заданным регулярным выражениям <code><nowiki>^(aaa|bbb|ccc).*</nowiki></code> для атрибутов ресурсов и <code><nowiki>(^xyz.pqr$)|(^(aaa|bbb|ccc).*)</nowiki></code> для атрибутов диапазона.
|-
|<code>[https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.136.0/pkg/ottl/ottlfuncs/README.md#set set]</code>
|Добавляет/изменяет следующие два атрибута '''span''':

* <code>svc.marker</code>, со статическим значением <code>purchasing</code>
* <code>purchase.id</code>, преобразуя его значение в верхний регистр, используя <code>[https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.136.0/pkg/ottl/ottlfuncs/README.md#convertcase ConvertCase]</code>
|-
|<code>[https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.136.0/pkg/ottl/ottlfuncs/README.md#delete_key delete_key]</code>
|Удаляет атрибуты с именем <code>message</code>.
|-
|<code>[https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.136.0/pkg/ottl/ottlfuncs/README.md#replace_pattern replace_pattern]</code>
|Сопоставляет строку с заданным регулярным выражением и выполняет замену строки во всех соответствующих записях.

В нашем примере мы сначала используем его для трассировки, чтобы сопоставить имя с регулярным выражением <code>^.*(DataSubmission-\d+).*$</code>, и заменяем его содержимое первой группой захвата (<code>$$1</code>) нашего выражения. По сути, это означает, что мы ищем строки <code>DataSubmission</code> с суффиксом, содержащим число, и, если найдено, сохраняем только значение найденного совпадения.

Мы также используем функцию для метрик с регулярным выражением <code>(.*)_bad$</code>, чтобы изменить суффикс <code>_bad</code> на <code>_invalid</code>.
|}

==== Фильтр ====
Кроме того, мы также настраиваем экземпляр [https://github.com/open-telemetry/opentelemetry-collector-contrib/tree/v0.136.0/processor/filterprocessor процессора <code>filter</code>] для фильтрации сигнала на основе следующих критериев:
{| class="wikitable"
!Сигнал
!Описание
|-
|Трассировки
|Используется для сопоставления имени атрибутов ресурса с регулярным выражением <code>[https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.136.0/pkg/ottl/ottlfuncs/README.md#ismatch IsMatch]</code>, отбрасывая интервалы с атрибутами, имена которых начинаются с <code>^my-pod-name.*my-pod-name</code>.
|-
|Метрики
|Используется для оценки наличия <code>[https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.136.0/processor/filterprocessor/README.md#HasAttrKeyOnDatapoint HasAttrKeyOnDatapoint]</code> у точек данных атрибутов с именем <code>bad.metric</code>.
|-
|Логи
|Использует строгое строковое соответствие атрибута ресурса <code>service.name</code> строкам <code>service1</code> и <code>service2</code>.
|}
Более подробную информацию об отдельных параметрах конфигурации см. в [https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.136.0/processor/filterprocessor/README.md документации OpenTelemetry фильтр-процессора].

=== Экспортер ===
В разделе <code>exporters</code> мы указываем [https://github.com/open-telemetry/opentelemetry-collector/tree/v0.136.0/exporter/otlphttpexporter экспортер <code>otlphttp</code>] по умолчанию и настраиваем его с помощью URL-адреса нашего API Ключ-АСТРОМ и требуемого токена аутентификации.

Для этой цели мы устанавливаем следующие две переменные среды и ссылаемся на них в значениях конфигурации для <code>endpoint</code> и <code>Authorization</code>.

* <code>DT_ENDPOINT</code> содержит базовый URL-адрес конечной точки API Ключ-АСТРОМ (например, <code><nowiki>https://{your-environment-id}.live.dynatrace.com/api/v2/otlp</nowiki></code>)
* <code>DT_API_TOKEN</code> содержит токен API

=== Сервисные контейнеры ===
В разделе <code>service</code> мы собираем объекты приемника, процессора и экспортера в контейнер трассировок, который принимает трассировки '''OTLP''' на настроенных конечных точках и преобразует атрибуты трассировок в соответствии с настроенными правилами, а затем пересылает все в Ключ-АСТРОМ с помощью экспортера.

Преобразование и фильтрация - История изменений

IKuznetsov: Новая страница: «В следующем примере конфигурации показано, как настроить экземпляр '''Collector''' для преобра...»