Показатели Cadence Activity не выдаются ⇐ JAVA
-
Гость
Показатели Cadence Activity не выдаются
В моем клиенте cadence у меня есть переменные службы рабочего процесса и клиента рабочего процесса, которые могут передавать метрики в мою область.
this.workflowService = новый WorkflowServiceTChannel(cadenceHost, cadencePort, новый WorkflowServiceTChannel.ClientOptions.Builder() .setMetricsScope(this.metricsScope) .строить()); this.workflowClient = WorkflowClient.newInstance(this.workflowService, домен, новый WorkflowClientOptions.Builder() .setDataConverter(конвертер данных) .setMetricsScope(this.metricsScope) .строить()); this.completionClient = workflowClient.newActivityCompletionClient(); Я могу видеть такие показатели, как workflow-endtoend-latency. Я также могу видеть показатели для activity-task-completed, поскольку они создаются при вызове клиента завершения.
Я аналогичным образом создаю своих рабочих, используя параметры рабочих с той же областью метрик, однако я не вижу никаких activity-endtoend-latency, activity-execution-latency и т. д. Я могу видеть запланированную задержку активности и показатели, связанные с опросом активности.
Это код для создания моих рабочих
WorkerOptions workerOptions = новый WorkerOptions.Builder() .setDataConverter(конвертер данных) .setWorkflowPollerOptions(новый PollerOptions.Builder() .setPollThreadCount(pollerThreadCount) .строить()) .setActivityPollerOptions(новый PollerOptions.Builder() .setPollThreadCount(pollerThreadCount) .строить()) .setMaxConcurrentWorkflowExecutionSize(concurrentExecutionSize) .setMaxConcurrentActivityExecutionSize(concurrentExecutionSize) .setMaxConcurrentLocalActivityExecutionSize(concurrentExecutionSize) .setMetricsScope(this.metricsScope) .строить(); Рабочий рабочий = Factory.newWorker(taskList, workerOptions); и так я начинаю свою деятельность
ActivityOptions ActivityOptions = новый ActivityOptions.Builder() .setRetryOptions(retryOptions) .setTaskList(список задач) .setStartToCloseTimeout(Duration.ofSeconds(timeoutSeconds)) .setScheduleToCloseTimeout(Duration.ofSeconds(timeoutSeconds)) .строить(); Заглушка ActivityStub = Workflow.newUntypedActivityStub(activityOptions); заглушка.execute(имя_активности, Object.class, args); Как мне заставить моего клиента также отправлять мне показатели задержки выполнения действий?
В моем клиенте cadence у меня есть переменные службы рабочего процесса и клиента рабочего процесса, которые могут передавать метрики в мою область.
this.workflowService = новый WorkflowServiceTChannel(cadenceHost, cadencePort, новый WorkflowServiceTChannel.ClientOptions.Builder() .setMetricsScope(this.metricsScope) .строить()); this.workflowClient = WorkflowClient.newInstance(this.workflowService, домен, новый WorkflowClientOptions.Builder() .setDataConverter(конвертер данных) .setMetricsScope(this.metricsScope) .строить()); this.completionClient = workflowClient.newActivityCompletionClient(); Я могу видеть такие показатели, как workflow-endtoend-latency. Я также могу видеть показатели для activity-task-completed, поскольку они создаются при вызове клиента завершения.
Я аналогичным образом создаю своих рабочих, используя параметры рабочих с той же областью метрик, однако я не вижу никаких activity-endtoend-latency, activity-execution-latency и т. д. Я могу видеть запланированную задержку активности и показатели, связанные с опросом активности.
Это код для создания моих рабочих
WorkerOptions workerOptions = новый WorkerOptions.Builder() .setDataConverter(конвертер данных) .setWorkflowPollerOptions(новый PollerOptions.Builder() .setPollThreadCount(pollerThreadCount) .строить()) .setActivityPollerOptions(новый PollerOptions.Builder() .setPollThreadCount(pollerThreadCount) .строить()) .setMaxConcurrentWorkflowExecutionSize(concurrentExecutionSize) .setMaxConcurrentActivityExecutionSize(concurrentExecutionSize) .setMaxConcurrentLocalActivityExecutionSize(concurrentExecutionSize) .setMetricsScope(this.metricsScope) .строить(); Рабочий рабочий = Factory.newWorker(taskList, workerOptions); и так я начинаю свою деятельность
ActivityOptions ActivityOptions = новый ActivityOptions.Builder() .setRetryOptions(retryOptions) .setTaskList(список задач) .setStartToCloseTimeout(Duration.ofSeconds(timeoutSeconds)) .setScheduleToCloseTimeout(Duration.ofSeconds(timeoutSeconds)) .строить(); Заглушка ActivityStub = Workflow.newUntypedActivityStub(activityOptions); заглушка.execute(имя_активности, Object.class, args); Как мне заставить моего клиента также отправлять мне показатели задержки выполнения действий?
Мобильная версия