reading_client can not get core-data data

[yqhsmile]

get_readings_by_device_and_resource：can get core-data data
get_readings_by_device_and_resource_by_client：can not get core-data data

level=ERROR ts=2026-05-27 13:20:54,458 app=app-collaborative-control source=logger.py:155 msg=error processing message in pipeline default-pipeline for envelope f6f14972-73e4-4cbe-a20f-339faaa73583: failed to parse the response body -> 'id'

`
import json
import uuid
import requests
from typing import Optional, Dict, Any, Tuple
from app_functions_sdk_py.contracts import errors
from app_functions_sdk_py.contracts.clients.utils.common import convert_any_to_dict
from app_functions_sdk_py.contracts.dtos.event import Event
from app_functions_sdk_py.interfaces import AppFunctionContext

class CoreDataGetter:
"""EdgeX 数据获取器"""

def __init__(self, reading_client, base_url: str = "http://localhost:59880"):
    """
    初始化数据获取器
    
    :param base_url: EdgeX Core Data 服务地址
    """
    self.reading_client = reading_client
    self.base_url = base_url

def get_readings(self, ctx: AppFunctionContext, data: Any) -> Tuple[bool, Any]:
    """
    获取读数
    
    :param ctx: 应用函数上下文
    :param data: 输入数据（包含设备名称和资源名称）
    :return: 包含读数数据的字典
    """
    if data is None:
        return False, errors.new_common_edgex(errors.ErrKind.CONTRACT_INVALID, "CoreDataGetter: No Data Received")

    if isinstance(data, Event) is False:
        return False, errors.new_common_edgex(
            errors.ErrKind.CONTRACT_INVALID,
            f"CoreDataGetter: type received is not an Event " f"in pipeline '{ctx.pipeline_id()}'",
        )
    
    event_id = data.id
    ctx.logger().info(f"CoreDataGetter: log event_id: '{event_id}'")

    # readings = self.get_readings_by_device_and_resource(
    #     ctx,
    #     device_name="CoalFlowMeter1",
    #     resource_name="FlowRate1",
    #     offset=0,
    #     limit=20,
    #     start=None,
    #     end=None
    # )
    # ctx.logger().info(f"CoreDataGetter: log readings: {readings}")
    ctx.logger().info(f"################################################")

    import time
    current_time = time.time()
    query_ns = int(10 * 60 * 1e9)
    start_time = int(current_time * 1000000000 - query_ns)
    end_time = int(current_time * 1000000000 )

    readings_by_client = self.get_readings_by_device_and_resource_by_client(
        ctx,
        device_name="CoalFlowMeter1",
        resource_name="FlowRate1",
        offset=0,
        limit=20,
        start=start_time,
        end=end_time
    )
    ctx.logger().info(f"CoreDataGetter: log readings_by_client: {readings_by_client}")
    ctx.logger().info(f"################################################")


    return True, data

def get_readings_by_device_and_resource_by_client(
    self, 
    ctx: AppFunctionContext,
    device_name: str, 
    resource_name: str,
    offset: Optional[int] = None,
    limit: Optional[int] = None,
    start: Optional[int] = None,
    end: Optional[int] = None
) -> Dict[str, Any]:

    context_dict = {
        'X-Correlation-ID': str(uuid.uuid4()),
        'correlation-id': str(uuid.uuid4()) 
    }

    data = self.reading_client.readings_by_device_name_and_resource_name_and_time_range(
        ctx=context_dict,
        device_name=device_name,
        resource_name=resource_name,
        offset=offset,
        limit=limit,
        start=start,
        end=end
    )

    # ctx.logger().info(f"CoreDataGetter: log data: {data}")
    return data



def get_readings_by_device_and_resource(
    self, 
    ctx: AppFunctionContext,
    device_name: str, 
    resource_name: str,
    offset: Optional[int] = None,
    limit: Optional[int] = None,
    start: Optional[int] = None,
    end: Optional[int] = None
) -> Dict[str, Any]:
    """
    通过设备名称和资源名称获取读数
    
    :param device_name: 设备名称（如 CoalFlowMeter1）
    :param resource_name: 资源名称（如 FlowRate1）
    :param offset: 偏移量（用于分页）
    :param limit: 返回数据条数限制
    :param start: 开始时间戳（纳秒）
    :param end: 结束时间戳（纳秒）
    :return: 包含读数数据的字典
    """
    try:
        url = f"{self.base_url}/api/v3/reading/device/name/{device_name}/resourceName/{resource_name}"
        
        params = {}
        if limit:
            params["limit"] = limit
        if start:
            params["start"] = start
        if end:
            params["end"] = end
        if offset:
            params["offset"] = offset
        
        response = requests.get(url, params=params)
        response.raise_for_status()

        # ctx.logger().info(f"CoreDataGetter: log response: {response.json()}")
        
        return {
            "success": True,
            "status_code": response.status_code,
            "device_name": device_name,
            "resource_name": resource_name,
            "data": response.json()
        }
    
    except requests.exceptions.RequestException as e:
        return {
            "success": False,
            "error": str(e),
            "device_name": device_name,
            "resource_name": resource_name
        }
`