1

我使用 Python-CAN 库编写了一个 Python 脚本，该库以 1 秒的速率记录接收到的 CAN 消息 5 分钟，然后将所有消息记录到文件中并退出。计算机有一个连接到 CAN 总线的 CAN 模块。（总线上的另一个设备是引擎）我使用 SocketCAN 接口与它通信。

这台计算机连接的测试引擎系统正在以我认为 250kb 的波特率发送大约 114 条消息。我预计每 1 秒会在文件中记录 114 条消息，但我看到的却是大约一半。（约 65 条消息）

引擎的 ECU 是否有可能设置为 500kb 波特率，这就是为什么我没有得到我期望的计数？如果波特率不匹配，我认为不会有通信，但我没有对系统的物理访问权限，因为我是通过 OTA 更新远程发送脚本而不是自己运行它。（该设备是无头的，但设置为在启动时运行脚本）我只看到生成的日志文件。

这是python代码：

（注意，我有代码将接收到的消息解析为包含的信号，但我没有在此处包含此代码，因为它发生在最后，并且不相关）

class logging:

    def __init__(self):
        #Dictionary to hold received CAN messages
        self.message_Dict = {}

        #List to hold queued dictionaries
        self.message_Queue = []

        #A "filters" object is also created here, but I did not include it
        #I have verified the filters are correct on my test system

    def main(self):

        #Record the current time
        currentTime = datetime.datetime.now()

        #Record the overall start time
        startTime = datetime.datetime.now()

        #Record the iteration start time
        lastIterationStartTime = currentTime

        #Create the CanBus that will be used to send and receive CAN msgs from the MCU
        canbus = can.interfaces.socketcan.SocketcanBus(channel='can0', bitrate=250000)
        #These filters are setup correctly, because all the messages come through
        #on my test system, but I did not include them here
        canbus.set_filters(self.Filters)

        # Creating Listener filters and notifier
        listener = can.Listener()

        #Main loop
        while 1:        

            #create a variable to hold received data
            msg2 = canbus.recv()

            #Record the current time
            currentTime = datetime.datetime.now()

            #If a valid message is detected
            if(msg2 != None):
               if(len(msg2.data) > 0):
                   try:                                
                       #Save the message data into a queue (will be processed later)
                       self.message_Dict[msg2.arbitration_id] = msg2.data

                   except:
                       print("Error in storing CAN message")

            #If 1 second has passed since the last iteration, 
            #add the dictionary to a new spot in the queue
            if((currentTime - lastIterationStartTime) >= datetime.timedelta(seconds=1)):

                #Add the dictionary with messages into the queue for later processing
                messageDict_Copy = self.message_Dict.copy()
                self.message_Queue.append(messageDict_Copy)

                print("Number of messages in dictionary: " + str(len(self.message_Dict)) + " 
                   Number of reports in queue: " + str(len(self.message_Queue)))

                #Clear the dictionary for new messages for every iteration
                self.message_Dict.clear()

                #Record the reset time
                lastIterationStartTime = datetime.datetime.now()
            
            #Once 5 minutes of data has been recorded, write to the file
            if((currentTime - startTime) > datetime.timedelta(minutes=5)):
                
                #Here is where I write the data to a file. This is too long to include

                #Clear the queue
                self.message_Queue = []

                #Clear the dictionary for new messages for every iteration
                self.message_Dict.clear()

#When the script is run, execute the Main method
if __name__ == '__main__':  
    mainClass = logging()
    mainClass.main()

我感谢您的任何想法或意见。谢谢

4

1 回答 1

1

根据我的经验，大多数引擎的 ECU 通常使用 250kb，但最新的使用 500kb。我建议你也试试两者。

此外，如果消息已发送，它们只会到达公共汽车，这看起来很愚蠢，但例如卡车，如果您不踩加速器，则不会出现与加速器相关的消息。因此，也许您需要检查所有组件是否按预期使用。can-utils的库有一个“Can sniffer”，它也可以帮助你。

我建议您使用“can-utils”来帮助您。它是一个强大的分析工具。

您是否尝试循环波特率？也许也可以帮助找到另一个。

于 2021-12-09T12:05:44.453 回答