错误信息KeyError: 'amount'
时间: 2024-06-06 20:05:48 浏览: 12
这个错误意味着你正在尝试访问一个字典中不存在的键。通常情况下,这是由于拼写错误或尝试访问不存在的键所致。例如,如果你有一个字典叫做 `my_dict`,它包含键值对 `{'name': 'John', 'age': 30}`,如果你尝试访问 `my_dict['amount']`,你会收到一个 KeyError,因为 `amount` 键不存在于字典中。请检查你的代码并确保你正在访问正确的键。
相关问题
Traceback (most recent call last): File "C:\Users\14493\Desktop\pythonProject1\azhe.py", line 73, in <module> x_undersampling=undersampling_data[['type','amount','oldbalanceOrg','newbalanceOrig','oldbalanceDest','newbalanceDest']] File "C:\Users\14493\Desktop\pythonProject1\venv\lib\site-packages\pandas\core\frame.py", line 3767, in __getitem__ indexer = self.columns._get_indexer_strict(key, "columns")[1] File "C:\Users\14493\Desktop\pythonProject1\venv\lib\site-packages\pandas\core\indexes\base.py", line 5876, in _get_indexer_strict self._raise_if_missing(keyarr, indexer, axis_name) File "C:\Users\14493\Desktop\pythonProject1\venv\lib\site-packages\pandas\core\indexes\base.py", line 5938, in _raise_if_missing raise KeyError(f"{not_found} not in index") KeyError: "['type'] not in index"
这是一个 KeyError 错误,意味着你在尝试对一个不存在的列进行索引。在你的代码中,你试图使用 `undersampling_data[['type','amount','oldbalanceOrg','newbalanceOrig','oldbalanceDest','newbalanceDest']]` 来索引一个名为 `type` 的列,但是 `undersampling_data` 数据框中不存在 `type` 这个列。你需要检查一下你的数据框中是否存在名为 `type` 的列,或者使用适当的列名来进行索引。
from __future__ import print_function import sys from pyspark import SparkContext from pyspark.streaming import StreamingContext if __name__ == "__main__": if len(sys.argv) != 3: print("Usage: network_wordcount.py <hostname> <port>", file=sys.stderr) exit(-1) sc = SparkContext(appName="LoanAmountStreaming") ssc = StreamingContext(sc, 1) # 创建输入DStream lines = ssc.socketTextStream("localhost", 9999) # 创建输入DStream # 解析每个JSON对象 提取数据 data = lines.map(json.loads) customer_amounts = data.map(lambda obj: (obj["name"], obj["amount"])) # 求和 customer_totals = customer_amounts.reduceByKey(lambda a,b: a + b) # 打印 customer_totals.pprint() # 启动StreamingContext ssc.start() ssc.awaitTermination() 2023-06-09 09:19:17 WARN NativeCodeLoader:60 - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable Setting default log level to "WARN". To adjust logging level use sc.setLogLevel(newLevel). For SparkR, use setLogLevel(newLevel). Traceback (most recent call last): File "ex3.py", line 24, in <module> data = lines.map(json.loads) NameError: name 'json' is not defined
这段代码是一个使用 Spark Streaming 实现的网络单词计数程序,与之前的程序唯一不同的是在解析每个 JSON 对象时需要使用 json 库中的 loads() 方法对字符串进行解析,但是在代码中没有正确导入 json 库,所以会抛出 "NameError: name 'json' is not defined" 错误。要解决这个问题,应该在开头导入 json 库,可以在第一行添加 "import json" 即可。
相关推荐
![docx](https://img-home.csdnimg.cn/images/20210720083331.png)
![.zip](https://img-home.csdnimg.cn/images/20210720083646.png)
![.zip](https://img-home.csdnimg.cn/images/20210720083646.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)