Обновил отправку тегов с массива на построчный формат
This commit is contained in:
@@ -22,14 +22,32 @@ function assertRegisterCount(values: number[]): void {
|
||||
}
|
||||
|
||||
async function postMetrics(metrics: MappedMetric[]): Promise<void> {
|
||||
const response = await postCloudIngest(metrics)
|
||||
const errors: Error[] = []
|
||||
|
||||
if (!response.ok) {
|
||||
const text = await response.text()
|
||||
throw new Error(text)
|
||||
for (const metric of metrics) {
|
||||
try {
|
||||
const response = await postCloudIngest(metric)
|
||||
|
||||
if (!response.ok) {
|
||||
const text = await response.text()
|
||||
throw new Error(text || `${response.status} ${response.statusText}`)
|
||||
}
|
||||
} catch (error) {
|
||||
const message = error instanceof Error ? error.message : String(error)
|
||||
errors.push(new Error(`${metric.tag}: ${message}`))
|
||||
console.error('edge5.modbus.v2.metric.failed', metric.tag, message)
|
||||
}
|
||||
}
|
||||
|
||||
console.log('edge5.modbus.v2.posted', { count: metrics.length })
|
||||
console.log('edge5.modbus.v2.posted', {
|
||||
total: metrics.length,
|
||||
succeeded: metrics.length - errors.length,
|
||||
failed: errors.length,
|
||||
})
|
||||
|
||||
if (errors.length) {
|
||||
throw new Error(`Failed to post ${errors.length}/${metrics.length} edge5 modbus v2 metrics`)
|
||||
}
|
||||
}
|
||||
|
||||
export const handleEdge5ModbusV2: TopicHandler = async (topic, payload) => {
|
||||
|
||||
Reference in New Issue
Block a user