3DS平台业务层的数据查询SDK

These details have not been verified by PyPI

Project description

D3SDK

D3SDK是3DS系统提供的数据开发包（以下简称SDK），用于简化Python里访问各类数据库的操作。

一、安装

1.1 安装SDK

安装SDK最新版本：

pip install -U d3sdk

二、使用SDK

1、查询报警组列表

调用SDK代码示例：

from d3sdk.d3_dataframe_db import D3DataFrameDB
from d3sdk.model.device_failure_record import DeviceFailureRecord

k2a_host = '192.168.132.167'
k2a_port = 443
k2a_user = 'zhangsan'
k2a_basic_token = '0c475ffd8960c17046b531e2xxx'

k2a_url = f'k2assets+3ds://{k2a_user}:{k2a_basic_token}@{k2a_host}:{k2a_port}'
db = D3DataFrameDB(k2a_url)
result = db.getDeviceFailureRecords(
                                 devices=['T0000000002'],
                                #  earliestAlarmTimeBegin='2024-06-29 04:45:27',
                                #  earliestAlarmTimeEnd='2024-06-29 19:45:27',
                                #  latestAlarmTimeBegin='2024-06-29 04:45:27',
                                #  latestAlarmTimeEnd='2024-06-29 19:45:27',
                                #  alarmTimeBegin='2024-06-29 04:45:27',
                                #  alarmTimeEnd='2024-06-29 19:45:27',
                                 alarmTypes=['failure'],
                                #  alarmCodes=[''],
                                #  alarmLevels=[''],
                                #  alarmStatus=[''],
                                 description='电流',
                                 desc=True,
                                 diagnosticModuleTypeNames=['工况与环境'],
                                 limit=2)
for record in result:
    print(f"classType: {type(record)}")
    print(f"alarmGroupCode: {record.alarmGroupCode}")
    print(f"deviceName: {record.deviceName}")
    print(f"deviceCode: {record.deviceCode}")
    print(f"alarmGroupName: {record.alarmGroupName}")
    print(f"alarmCode: {record.alarmCode}")
    print(f"alarmType: {record.alarmType}")
    print(f"description: {record.description}")
    print(f"earliestAlarmTime: {record.earliestAlarmTime}")
    print(f"diagnosticModules: ")
    for diagnosticModule in record.diagnosticModules:
        print(f"  {diagnosticModule}")
    print("-" * 100)

运行结果示例：

classType: <class 'd3sdk.model.device_failure_record.DeviceFailureRecord'>
alarmGroupCode: AG0000114480
deviceName: 岳阳1#机组
deviceCode: T0000000002
alarmGroupName: 三相电流不平衡度超过限值
alarmCode: FM801908
alarmType: failure
description: 三相电流不平衡度超过限值
earliestAlarmTime: 2024-06-30 13:37:20
diagnosticModules: 
  DiagnosticModule(diagnosticModuleCode=QLJ00006, diagnosticModuleName=工况与环境, diagnosticModuleTypeCode=QLJ00006, diagnosticModuleTypeName=工况与环境, typeOfDiagnosticModuleType=部件部套)
----------------------------------------------------------------------------------------------------
classType: <class 'd3sdk.model.device_failure_record.DeviceFailureRecord'>
alarmGroupCode: AG0000114275
deviceCode: T0000000002
alarmGroupName: 三相电流不平衡度超过限值
alarmCode: FM801908
alarmType: failure
description: 三相电流不平衡度超过限值
earliestAlarmTime: 2024-06-30 13:26:14
diagnosticModules: 
  DiagnosticModule(diagnosticModuleCode=QLJ00006, diagnosticModuleName=工况与环境, diagnosticModuleTypeCode=QLJ00006, diagnosticModuleTypeName=工况与环境, typeOfDiagnosticModuleType=部件部套)
----------------------------------------------------------------------------------------------------

2、根据报警组编号查询报警编码、类型及其原因和建议

调用SDK代码示例：

from d3sdk.d3_dataframe_db import D3DataFrameDB
from d3sdk.model.alarm_group_detail import AlarmGroupDetail

k2a_host = '192.168.132.167'
k2a_port = 443
k2a_user = 'zhangsan'
k2a_basic_token = '0c475ffd8960c17046b531e2xxx'

k2a_url = f'k2assets+3ds://{k2a_user}:{k2a_basic_token}@{k2a_host}:{k2a_port}'
db = D3DataFrameDB(k2a_url, debug=False)
alarmDetails = db.getAlarmDetails(alarmGroupCode='AG0000121409')
for alarmDetail in alarmDetails:
    print(f"classType: {type(alarmDetail)}")
    print(f"alarmCode: {alarmDetail.alarmCode}")
    print(f"alarmType: {alarmDetail.alarmType}")
    print(f"causes: ")
    for cause in alarmDetail.causes:
        print(f"  code: {cause.code}")
        print(f"  displayName: {cause.displayName}")
        print(f"  description: {cause.description}")
        print(f"  suggestions: ")
        for suggestion in cause.suggestions:
            print(f"    {suggestion}")
        print()
    print("-" * 100)

运行结果示例：

classType: <class 'd3sdk.model.alarm_group_detail.AlarmDetail'>
alarmCode: FM800412
alarmType: failure
causes: 
  code: RS800001
  displayName: 定子绕组温度持续动态超限原因
  description: 定子冷却水异常；线棒内部堵塞或结垢。
  suggestions: 
    Suggestion(code='JY800001', displayName='定子绕组温度持续动态超限处理建议', description='检查定子冷却水流量、压力与温度等是否异常，检查机组三相负载是否平衡。')
    Suggestion(code='JY800004', displayName='定子绕组温度超限报警处理建议', description='检查冷却水流量、压力与温度等是否正常，检查发电机是否过载，检查绝缘过热、局部放电装置数据是否正常，降负荷运行至报警信号解除，若温度继续升高，应尽快停机检查。')

----------------------------------------------------------------------------------------------------

3、查询某个征兆的原因及其建议

调用SDK代码示例：

from d3sdk.d3_dataframe_db import D3DataFrameDB
from d3sdk.model.alarm_group_detail import AlarmGroupDetail

k2a_host = '192.168.132.167'
k2a_port = 443
k2a_user = 'zhangsan'
k2a_basic_token = '0c475ffd8960c17046b531e2xxx'

k2a_url = f'k2assets+3ds://{k2a_user}:{k2a_basic_token}@{k2a_host}:{k2a_port}'
db = D3DataFrameDB(k2a_url, debug=True)
result = db.getSymptomCauses('SP800511')

for cause in result:
    print(f"classType: {type(cause)}")
    print(f"code: {cause.code}")
    print(f"displayName: {cause.displayName}")
    print(f"description: {cause.description}")
    print(f"suggestions: ")
    for suggestion in cause.suggestions:
        print(f"    {suggestion}")
    print("-" * 100)

运行结果示例：

classType: <class 'd3sdk.model.alarm_group_detail.Cause'>
code: RS800065
displayName: 定子冷却水进水温度超上限原因
description: 发电机定子冷却水进水温度偏大。
suggestions: 
    Suggestion(code='JY800065', displayName='定子冷却水进水温度超上限处理建议', description='检查定子冷却水系统，降低进水温度，并监控发电机定子线棒温度。')
----------------------------------------------------------------------------------------------------
classType: <class 'd3sdk.model.alarm_group_detail.Cause'>
code: RS800067
displayName: 定子冷却水进水压力超上限原因
description: 发电机定子冷却水进水压力偏大。
suggestions: 
    Suggestion(code='JY800067', displayName='定子冷却水进水压力超上限处理建议', description='暂无。')
----------------------------------------------------------------------------------------------------
classType: <class 'd3sdk.model.alarm_group_detail.Cause'>
code: RS800069
displayName: 定子冷却水进水流量超上限原因
description: 发电机定子冷却水进水流量偏大。
suggestions: 
    Suggestion(code='JY800069', displayName='定子冷却水进水流量超上限处理建议', description='暂无。')
----------------------------------------------------------------------------------------------------

4、查询某个失效的原因及其建议

调用SDK代码示例：

from d3sdk.d3_dataframe_db import D3DataFrameDB
from d3sdk.model.alarm_group_detail import AlarmGroupDetail

k2a_host = '192.168.132.167'
k2a_port = 443
k2a_user = 'zhangsan'
k2a_basic_token = '0c475ffd8960c17046b531e2xxx'

k2a_url = f'k2assets+3ds://{k2a_user}:{k2a_basic_token}@{k2a_host}:{k2a_port}'
db = D3DataFrameDB(k2a_url, debug=True)
result = db.getFailureCauses('FM800412')

for cause in result:
    print(f"classType: {type(cause)}")
    print(f"code: {cause.code}")
    print(f"displayName: {cause.displayName}")
    print(f"description: {cause.description}")
    print(f"suggestions: ")
    for suggestion in cause.suggestions:
        print(f"  {suggestion}")
    print("-" * 100)

运行结果示例：

classType: <class 'd3sdk.model.alarm_group_detail.Cause'>
code: RS800001
displayName: 定子绕组温度持续动态超限原因
description: 定子冷却水异常；线棒内部堵塞或结垢。
suggestions: 
  Suggestion(code='JY800001', displayName='定子绕组温度持续动态超限处理建议', description='检查定子冷却水流量、压力与温度等是否异常，检查机组三相负载是否平衡。')
  Suggestion(code='JY800004', displayName='定子绕组温度超限报警处理建议', description='检查冷却水流量、压力与温度等是否正常，检查发电机是否过载，检查绝缘过热、局部放电装置数据是否正常，降负荷运行至报警信号解除，若温度继续升高，应尽快停机检查。')
----------------------------------------------------------------------------------------------------

5、查询机组的测点列表（通过机组找到数据分组的量测及其映射到的repo和repoColumn）

调用SDK代码示例：

from d3sdk.d3_dataframe_db import D3DataFrameDB
from d3sdk.model.alarm_group_detail import AlarmGroupDetail

k2a_host = '192.168.132.167'
k2a_port = 443
k2a_user = 'zhangsan'
k2a_basic_token = '0c475ffd8960c17046b531e2xxx'

k2a_url = f'k2assets+3ds://{k2a_user}:{k2a_basic_token}@{k2a_host}:{k2a_port}'
db = D3DataFrameDB(k2a_url, debug=True)
result = db.getInstanceMeasurements(devices=['T0000000002'])
for instanceMeasurement in result:
    print(f"  {instanceMeasurement}")

运行结果示例：

InstanceMeasurement(deviceCode=T0000000002, measurement=Steam.Turbine.10LAB11CP101, repoCode=YY_GN_unit1_thermo_raw, repoColumn=10LAB11CP101)
InstanceMeasurement(deviceCode=T0000000002, measurement=Steam.Turbine.10LAB11CT301, repoCode=YY_GN_unit1_thermo_raw, repoColumn=10LAB11CT301)
InstanceMeasurement(deviceCode=T0000000002, measurement=Steam.Turbine.10LAB31CP101, repoCode=YY_GN_unit1_thermo_raw, repoColumn=10LAB31CP101)
InstanceMeasurement(deviceCode=T0000000002, measurement=Steam.Turbine.10LAB31CP102, repoCode=YY_GN_unit1_thermo_raw, repoColumn=10LAB31CP102)
InstanceMeasurement(deviceCode=T0000000002, measurement=Steam.Turbine.10LAB31CT301, repoCode=YY_GN_unit1_thermo_raw, repoColumn=10LAB31CT301)
InstanceMeasurement(deviceCode=T0000000002, measurement=Steam.Turbine.10LAB51CT301, repoCode=YY_GN_unit1_thermo_raw, repoColumn=10LAB51CT301)
more ...

6、获取机组测诊断依据测点列表（业务对象-报警诊断依据配置的量测，及其映射到的repo和repoColumn）

调用SDK代码示例：

from d3sdk.d3_dataframe_db import D3DataFrameDB
from d3sdk.model.alarm_group_detail import AlarmGroupDetail

k2a_host = '192.168.132.167'
k2a_port = 443
k2a_user = 'zhangsan'
k2a_basic_token = '0c475ffd8960c17046b531e2xxx'

k2a_url = f'k2assets+3ds://{k2a_user}:{k2a_basic_token}@{k2a_host}:{k2a_port}'
db = D3DataFrameDB(k2a_url, debug=True)
result = db.getInstanceMeasurementsFilter(device='T0000000002', alarms=['diagnosticModule800412'])
for instanceMeasurement in result:
    print(f"  {instanceMeasurement}")

运行结果示例：

InstanceMeasurement(deviceCode=T0000000002, measurement=Steam.Turbine.10LAB11CP101, repoCode=YY_GN_unit1_thermo_raw, repoColumn=10LAB11CP101)
InstanceMeasurement(deviceCode=T0000000002, measurement=Steam.Turbine.10LAB11CT301, repoCode=YY_GN_unit1_thermo_raw, repoColumn=10LAB11CT301)
InstanceMeasurement(deviceCode=T0000000002, measurement=Steam.Turbine.10LAB31CP101, repoCode=YY_GN_unit1_thermo_raw, repoColumn=10LAB31CP101)
InstanceMeasurement(deviceCode=T0000000002, measurement=Steam.Turbine.10LAB31CP102, repoCode=YY_GN_unit1_thermo_raw, repoColumn=10LAB31CP102)
InstanceMeasurement(deviceCode=T0000000002, measurement=Steam.Turbine.10LAB31CT301, repoCode=YY_GN_unit1_thermo_raw, repoColumn=10LAB31CT301)
InstanceMeasurement(deviceCode=T0000000002, measurement=Steam.Turbine.10LAB51CT301, repoCode=YY_GN_unit1_thermo_raw, repoColumn=10LAB51CT301)
more ...

7、查询机组征兆的信息（描述、关键字和诊断模块）

调用SDK代码示例：

from d3sdk.d3_dataframe_db import D3DataFrameDB

k2a_host = '192.168.132.167'
k2a_port = 443
k2a_user = 'zhangsan'
k2a_basic_token = '0c475ffd8960c17046b531e2xxx'

k2a_url = f'k2assets+3ds://{k2a_user}:{k2a_basic_token}@{k2a_host}:{k2a_port}'
db = D3DataFrameDB(k2a_url, debug=False)
result = db.getDeviceSymptomInfo(device='T0000000002', symptomCode='SP800511')
print(f"征兆信息: {result}")

运行结果示例：

征兆信息: {DeviceSymptom(code=SP800511, name=11号定子线棒出水温度运行值持续动态超限, description=11号定子线棒出水温度运行值持续动态超限, diagnosticModules=[DiagnosticModule(diagnosticModuleCode=QLJ00008, diagnosticModuleName=定子绕组温度, diagnosticModuleTypeCode=QLJ00008, diagnosticModuleTypeName=定子绕组温度, typeOfDiagnosticModuleType=部件部套)])}

8、查询机组失效的信息（描述、关键字和诊断模块）

调用SDK代码示例：

from d3sdk.d3_dataframe_db import D3DataFrameDB

k2a_host = '192.168.132.167'
k2a_port = 443
k2a_user = 'zhangsan'
k2a_basic_token = '0c475ffd8960c17046b531e2xxx'

k2a_url = f'k2assets+3ds://{k2a_user}:{k2a_basic_token}@{k2a_host}:{k2a_port}'
db = D3DataFrameDB(k2a_url, debug=False)
result = db.getDeviceFailureInfo(device='T0000000002', failureCode='FM800412')
print(f"失效信息: {result}")

运行结果示例：

失效信息: {DeviceFailure(code=FM800412, name=12号定子线棒层间温度运行值持续动态超限, description=12号定子线棒层间温度运行值持续动态超限, diagnosticModules=[DiagnosticModule(diagnosticModuleCode=QLJ00001, diagnosticModuleName=定子, diagnosticModuleTypeCode=QLJ00001, diagnosticModuleTypeName=定子, typeOfDiagnosticModuleType=部件部套), DiagnosticModule(diagnosticModuleCode=QLJ00008, diagnosticModuleName=定子绕组温度, diagnosticModuleTypeCode=QLJ00008, diagnosticModuleTypeName=定子绕组温度, typeOfDiagnosticModuleType=部件部套)])}

9、根据机组和征兆描述、关键字、部位等限制条件反查符合条件的征兆编码

调用SDK代码示例：

from d3sdk.d3_dataframe_db import D3DataFrameDB

k2a_host = '192.168.132.167'
k2a_port = 443
k2a_user = 'zhangsan'
k2a_basic_token = '0c475ffd8960c17046b531e2xxx'

k2a_url = f'k2assets+3ds://{k2a_user}:{k2a_basic_token}@{k2a_host}:{k2a_port}'
db = D3DataFrameDB(k2a_url, debug=False)
result = db.getDeviceSymptoms(
    device='T0000000002', 
    symptomDescription='超限', 
    diagnosticModuleName='定子绕组温度', 
    keywords='温度'
)
print(f"符合条件的征兆: {result}")

运行结果示例：

符合条件的征兆: {dict_values([DeviceSymptom(code=SP800511, name=11号定子线棒出水温度运行值持续动态超限, description=11号定子线棒出水温度运行值持续动态超限, diagnosticModules=[DiagnosticModule(diagnosticModuleCode=QLJ00008, diagnosticModuleName=定子绕组温度, diagnosticModuleTypeCode=QLJ00008, diagnosticModuleTypeName=定子绕组温度, typeOfDiagnosticModuleType=部件部套)])])}

10、根据机组和失效描述、关键字、部位等限制条件反查符合条件的失效编码

调用SDK代码示例：

from d3sdk.d3_dataframe_db import D3DataFrameDB

k2a_host = '192.168.132.167'
k2a_port = 443
k2a_user = 'zhangsan'
k2a_basic_token = '0c475ffd8960c17046b531e2xxx'

k2a_url = f'k2assets+3ds://{k2a_user}:{k2a_basic_token}@{k2a_host}:{k2a_port}'
db = D3DataFrameDB(k2a_url, debug=False)
result = db.getDeviceFailures(
    device='T0000000002', 
    failureDescription='超限', 
    diagnosticModuleName='定子', 
    keywords='温度'
)
print(f"符合条件的失效: {result}")

运行结果示例：

符合条件的失效: {dict_values([DeviceFailure(code=FM800412, name=12号定子线棒层间温度运行值持续动态超限, description=12号定子线棒层间温度运行值持续动态超限, diagnosticModules=[DiagnosticModule(diagnosticModuleCode=QLJ00001, diagnosticModuleName=定子, diagnosticModuleTypeCode=QLJ00001, diagnosticModuleTypeName=定子, typeOfDiagnosticModuleType=部件部套)])])}

11、根据设备、部位编码反查所关联的征兆、失效

调用SDK代码示例：

from d3sdk.d3_dataframe_db import D3DataFrameDB

k2a_host = '192.168.132.167'
k2a_port = 443
k2a_user = 'zhangsan'
k2a_basic_token = '0c475ffd8960c17046b531e2xxx'

k2a_url = f'k2assets+3ds://{k2a_user}:{k2a_basic_token}@{k2a_host}:{k2a_port}'
db = D3DataFrameDB(k2a_url, debug=True)
result = db.getDeviceSymptomsAndFailures(
    device='T0000000002', 
    diagnosticModuleName='定子绕组温度'
)
print(f"关联的征兆和失效: {result}")

运行结果示例：

关联的征兆和失效: {dict_values([AlarmType(code=FM801413, name=13号上层线棒异常过热, description=13号上层线棒异常过热, keywords=定子绕组温度，线棒空心线堵塞, type=failure)])}

12、查询所有诊断模块实例

调用SDK代码示例：

from d3sdk.d3_dataframe_db import D3DataFrameDB
from d3sdk.pgrepo_dataframe_db import PgRepoDataFrameDB

k2a_host = '192.168.132.167'
k2a_port = 443
k2a_user = 'zhangsan'
k2a_basic_token = '0c475ffd8960c17046b531e2xxx'

k2a_url = f'k2assets+3ds://{k2a_user}:{k2a_basic_token}@{k2a_host}:{k2a_port}'
db = D3DataFrameDB(k2a_url, debug=True, pgPort=5432)
repoDB = PgRepoDataFrameDB(k2a_url, debug=False, pgPort=15432)
# 查询所有诊断模块实例
result = db.getDiagnosticModuleInstances()
# 打印结果
for diagnosticModuleInstance in result:
    print(f"  {diagnosticModuleInstance}")
    # 查看最新健康度
    healthScore = repoDB.getLatestHealthScore(deviceCode=diagnosticModuleInstance.deviceCode, healthCode=diagnosticModuleInstance.healthCode)
    print(f"  healthScore: {healthScore}")

运行结果示例：

DiagnosticModuleInstance(diagnosticModuleCode=ND00009, diagnosticModuleName=1#核能发电机, parentDiagnosticModuleCode=ND00001, deviceCode=N0000000001, deviceName=1#核能发电机, diagnosticModuleTypeCode=ND00002, diagnosticModuleTypeName=核能发电机, diagnosticModuleType=机组, healthCode=ND00002)
  healthScore: None

  DiagnosticModuleInstance(diagnosticModuleCode=T0000000002, diagnosticModuleName=1000MW汽轮发电机, parentDiagnosticModuleCode=YY0000000001, deviceCode=T0000000002, deviceName=岳阳1#机组, diagnosticModuleTypeCode=T0000000002, diagnosticModuleTypeName=1000MW汽轮发电机, diagnosticModuleType=机组, healthCode=T0000000002)
  healthScore: HealthScore(timestamp=2024-12-18 23:36:50, deviceCode=T0000000002, score=97.0313, healthyCode=T0000000002)

  DiagnosticModuleInstance(diagnosticModuleCode=GZB00001_1, diagnosticModuleName=1#水轮发电机组, parentDiagnosticModuleCode=GZB00000, deviceCode=GZB_JZ_01, deviceName=1#机组, diagnosticModuleTypeCode=GZB00001, diagnosticModuleTypeName=水轮发电机组, diagnosticModuleType=机组, healthCode=GZB00001)
  healthScore: HealthScore(timestamp=2025-06-19 16:59:22, deviceCode=GZB_JZ_01, score=99.0, healthyCode=GZB00001)

13、查询最新健康度（先通过诊断模块实例查询到诊断模块实例，再通过诊断模块实例查询最新健康度）

调用SDK代码示例：

from d3sdk.pgrepo_dataframe_db import PgRepoDataFrameDB

k2a_host = '192.168.132.167'
k2a_port = 443
k2a_user = 'zhangsan'
k2a_basic_token = '0c475ffd8960c17046b531e2xxx'

k2a_url = f'k2assets+3ds://{k2a_user}:{k2a_basic_token}@{k2a_host}:{k2a_port}'

repoDB = PgRepoDataFrameDB(k2a_url, debug=False, pgPort=15432)
result = repoDB.getLatestHealthScore(deviceCode='T0000000002', healthCode='QLJ00010')
# 打印结果
print(f"  {result}")

运行结果示例：

HealthScore(timestamp=2024-12-18 23:36:50, deviceCode=T0000000002, score=94.0, healthyCode=QLJ00010)

14、查询健康度记录

调用SDK代码示例：

from d3sdk.pgrepo_dataframe_db import PgRepoDataFrameDB

k2a_host = '192.168.132.167'
k2a_port = 443
k2a_user = 'zhangsan'
k2a_basic_token = '0c475ffd8960c17046b531e2xxx'

k2a_url = f'k2assets+3ds://{k2a_user}:{k2a_basic_token}@{k2a_host}:{k2a_port}'

repoDB = PgRepoDataFrameDB(k2a_url, debug=False, pgPort=15432)
result = repoDB.getHealthScoreRecords(
    deviceCode='T0000000002', 
    healthCode='QLJ00010', 
    startTime='2024-01-01 00:00:00', 
    endTime='2024-12-31 23:59:59'
)
# 打印结果
print(f"Found {len(result)} health score records:")
for record in result[:5]:  # 只打印前5条记录
    print(f"  {record}")

运行结果示例：

Found 1000 health score records:
  HealthScore(timestamp=2024-12-18 23:36:50, deviceCode=T0000000002, score=94.0, healthyCode=QLJ00010)
  HealthScore(timestamp=2024-12-18 22:36:50, deviceCode=T0000000002, score=93.5, healthyCode=QLJ00010)
  HealthScore(timestamp=2024-12-18 21:36:50, deviceCode=T0000000002, score=95.2, healthyCode=QLJ00010)
  HealthScore(timestamp=2024-12-18 20:36:50, deviceCode=T0000000002, score=96.1, healthyCode=QLJ00010)
  HealthScore(timestamp=2024-12-18 19:36:50, deviceCode=T0000000002, score=94.8, healthyCode=QLJ00010)

15、查询报警数量

调用SDK代码示例：

from d3sdk.d3_dataframe_db import D3DataFrameDB

k2a_host = '192.168.132.167'
k2a_port = 443
k2a_user = 'zhangsan'
k2a_basic_token = '0c475ffd8960c17046b531e2xxx'

k2a_url = f'k2assets+3ds://{k2a_user}:{k2a_basic_token}@{k2a_host}:{k2a_port}'
db = D3DataFrameDB(k2a_url, debug=False)

# 查询设备的所有报警数量
total_count = db.getDeviceFailureRecordsCount(devices=['T0000000002'])
print(f"设备 T0000000002 总报警数量: {total_count}")

# 查询带时间范围和其他条件的报警数量
filtered_count = db.getDeviceFailureRecordsCount(
    devices=['T0000000002'],
    alarmTimeBegin='2025-02-28 04:45:27',
    alarmTimeEnd='2025-03-29 19:45:27',
    alarmTypes=['failure'],
    description='电流',
    diagnosticModuleTypeNames=['工况与环境']
)
print(f"符合条件的报警数量: {filtered_count}")

运行结果示例：

设备 T0000000002 总报警数量: 12739
符合条件的报警数量: 5

16、根据报警组编码查询报警项记录

调用SDK代码示例：

from d3sdk.d3_dataframe_db import D3DataFrameDB

k2a_host = '192.168.132.167'
k2a_port = 443
k2a_user = 'zhangsan'
k2a_basic_token = '0c475ffd8960c17046b531e2xxx'

k2a_url = f'k2assets+3ds://{k2a_user}:{k2a_basic_token}@{k2a_host}:{k2a_port}'
db = D3DataFrameDB(k2a_url, debug=False)

# 使用一个可能有数据的报警组编码进行测试
result = db.getAlarmItemRecords(
    alarmGroupCode='AG0000121415',
    #limit=1,
    desc=False
)
# 如果result不为空，则遍历打印每条记录的evidence字段
if not result.empty:
    print(f"\n查询到的报警项记录数量: {len(result)}")
    print(f"DataFrame 列: {list(result.columns)}")
    # 遍历DataFrame的每一行
    for idx, row in result.iterrows():
        print(f"k_ts: {row['k_ts']}")
        print(f"k_device: {row['k_device']}")
        print(f"code: {row['code']}")
        print(f"name: {row['name']}")
        print(f"describe: {row['describe']}")
        print(f"level: {row['level']}")
        print(f"evidence: {row['evidence']}")
        print("-" * 100)
else:
    print("未查询到数据")

运行结果示例：

查询到的报警项记录数量: 22
DataFrame 列: ['k_device', 'code', 'k_ts', 'name', 'describe', 'level', 'evidence']
k_ts: 1741933976000
k_device: T0000000002
code: FM800412
name: 12号定子线棒层间温度运行值持续动态超限
describe: 12号定子线棒层间温度运行值持续动态超限
level: 注意
evidence: 2025-03-14 14:32:56,[1号定子线棒层间温度]持续动态超限(5.00),阈值5.00
----------------------------------------------------------------------------------------------------
k_ts: 1741934123000
k_device: T0000000002
code: FM800412
name: 12号定子线棒层间温度运行值持续动态超限
describe: 12号定子线棒层间温度运行值持续动态超限
level: 注意
evidence: 2025-03-14 14:35:23,[1号定子线棒层间温度]持续动态超限(5.00),阈值5.00
----------------------------------------------------------------------------------------------------
k_ts: 1741934141000
k_device: T0000000002
code: FM800412
name: 12号定子线棒层间温度运行值持续动态超限
describe: 12号定子线棒层间温度运行值持续动态超限
level: 注意
evidence: 2025-03-14 14:35:41,[1号定子线棒层间温度]持续动态超限(5.00),阈值5.00
----------------------------------------------------------------------------------------------------
k_ts: 1741934162000
k_device: T0000000002
code: FM800412
name: 12号定子线棒层间温度运行值持续动态超限
describe: 12号定子线棒层间温度运行值持续动态超限
level: 注意
evidence: 2025-03-14 14:36:02,[1号定子线棒层间温度]持续动态超限(5.00),阈值5.00
----------------------------------------------------------------------------------------------------
k_ts: 1741934188000
k_device: T0000000002
code: FM800412
name: 12号定子线棒层间温度运行值持续动态超限
describe: 12号定子线棒层间温度运行值持续动态超限
level: 注意
evidence: 2025-03-14 14:36:28,[1号定子线棒层间温度]持续动态超限(5.00),阈值5.00
----------------------------------------------------------------------------------------------------

Project details

These details have not been verified by PyPI

Development Status
- 3 - Alpha
Intended Audience
- Developers
Operating System
- OS Independent
Programming Language
Topic
- Software Development :: Libraries

Release history Release notifications | RSS feed

This version

0.1.29

Dec 12, 2025

0.1.28

Nov 12, 2025

0.1.27

Nov 11, 2025

0.1.26

Oct 23, 2025

0.1.25

Oct 22, 2025

0.1.24

Aug 19, 2025

0.1.23

May 8, 2025

0.1.22

Apr 7, 2025

0.1.21

Apr 7, 2025

0.1.20

Apr 7, 2025

0.1.19

Apr 7, 2025

0.1.18

Dec 2, 2024

0.1.17

Nov 25, 2024

0.1.16

Nov 25, 2024

0.1.15

Nov 22, 2024

0.1.14

Nov 18, 2024

0.1.13

Nov 18, 2024

0.1.12

Nov 13, 2024

0.1.11

Nov 13, 2024

0.1.10

Nov 12, 2024

0.1.9

Nov 1, 2024

0.1.8

Nov 1, 2024

0.1.7

Oct 30, 2024

0.1.6

Oct 29, 2024

0.1.5

Oct 28, 2024

0.1.4

Oct 28, 2024

0.1.2

Oct 25, 2024

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distributions

No source distribution files available for this release.See tutorial on generating distribution archives.

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

The dropdown lists show the available interpreters, ABIs, and platforms. Enable javascript to be able to filter the list of wheel files.

d3sdk-0.1.29-py3-none-any.whl (24.4 kB view details)

Uploaded Dec 12, 2025 Python 3

File details

Details for the file d3sdk-0.1.29-py3-none-any.whl.

File metadata

Download URL: d3sdk-0.1.29-py3-none-any.whl
Upload date: Dec 12, 2025
Size: 24.4 kB
Tags: Python 3
Uploaded using Trusted Publishing? No
Uploaded via: twine/6.1.0 CPython/3.8.18

File hashes

Hashes for d3sdk-0.1.29-py3-none-any.whl
Algorithm	Hash digest
SHA256	`f96d8c14a6b9e5e85128db5d020d5636dbae62024fae28389ce427ead2a30294`
MD5	`0437b37cd56b2fb94c1951eab17f6061`
BLAKE2b-256	`a542352e428e0d13b2af95ec3e2ec4faa864552e93b406731892026ba6d54617`

See more details on using hashes here.

d3sdk 0.1.29

Navigation

Verified details

Maintainers

Unverified details

Meta

Classifiers

Project description

D3SDK

一、安装

1.1 安装SDK

二、使用SDK

1、查询报警组列表

2、根据报警组编号查询报警编码、类型及其原因和建议

3、查询某个征兆的原因及其建议

4、查询某个失效的原因及其建议

5、查询机组的测点列表（通过机组找到数据分组的量测及其映射到的repo和repoColumn）

6、获取机组测诊断依据测点列表（业务对象-报警诊断依据配置的量测，及其映射到的repo和repoColumn）

7、查询机组征兆的信息（描述、关键字和诊断模块）

8、查询机组失效的信息（描述、关键字和诊断模块）

9、根据机组和征兆描述、关键字、部位等限制条件反查符合条件的征兆编码

10、根据机组和失效描述、关键字、部位等限制条件反查符合条件的失效编码

11、根据设备、部位编码反查所关联的征兆、失效

12、查询所有诊断模块实例

13、查询最新健康度（先通过诊断模块实例查询到诊断模块实例，再通过诊断模块实例查询最新健康度）

14、查询健康度记录

15、查询报警数量

16、根据报警组编码查询报警项记录

Project details

Verified details

Maintainers

Unverified details

Meta

Classifiers

Release history Release notifications | RSS feed

Download files

Source Distributions

Built Distribution

File details

File metadata

File hashes