\u524d\u56de\u306fPython\u306e\u30ed\u30b0\u306e\u57fa\u672c\u7684\u306a\u8003\u3048\u65b9\u306b\u3064\u3044\u3066\u89e3\u8aac\u3057\u307e\u3057\u305f\u3002\u4eca\u56de\u306f\u8ab2\u984c\u306e\u30b9\u30af\u30ea\u30d7\u30c8\u3067\u306e\u5b9f\u88c5\u4f8b\u3092\u898b\u3066\u307f\u307e\u3057\u3087\u3046\u3002<\/p>\n
\u8ab2\u984c\u306e\u30b9\u30af\u30ea\u30d7\u30c8\u3092\u5b9f\u884c\u3059\u308b\u3068\u30d5\u30a1\u30a4\u30eb\u306b\u30ed\u30b0\u51fa\u529b\u3055\u308c\u308b\u3088\u3046\u306b\u3059\u308b\u305f\u3081\u3001\u8a2d\u5b9a\u30d5\u30a1\u30a4\u30eb\u306esettings.py\u306b\u4ee5\u4e0b\u306e\u3088\u3046\u306b\u30ed\u30b0\u306e\u8a2d\u5b9a\u3092\u8ffd\u8a18\u3057\u307e\u3059\u3002<\/p>\n
\r\n# settings.py\r\nimport os\r\nimport logging.config\r\n\r\n# \u95be\u5024\r\nTHRESHOLD = 100\r\n\r\n# \u30ed\u30b0\u30d5\u30a1\u30a4\u30eb\u51fa\u529b\u5148\u30c7\u30a3\u30ec\u30af\u30c8\u30ea\r\nLOG_DIR = "."\r\n\r\n# \u30ed\u30b0\u30d5\u30a1\u30a4\u30eb\r\nLOG_FILE = os.path.join(LOG_DIR, "aggregate.log")\r\n\r\n# \u30ed\u30b0\u30d5\u30a9\u30fc\u30de\u30c3\u30c8\r\nLOG_FORMAT = '%(asctime)s %(name)s %(levelname)s %(message)s'\r\n\r\n# \u51fa\u529b\u3059\u308b\u30ec\u30d9\u30eb\r\nLOG_LEVEL = logging.INFO\r\n\r\n# \u30d5\u30a1\u30a4\u30eb\u51fa\u529b\u30cf\u30f3\u30c9\u30e9\r\nFILE_HANDLER = logging.FileHandler(LOG_FILE, encoding='utf-8')\r\n\r\n# \u30ed\u30b0\u8a2d\u5b9a\r\nlogging.basicConfig(level=LOG_LEVEL, format=LOG_FORMAT, handlers=[FILE_HANDLER])\r\n\r\n<\/pre>\n\u30ed\u30b0\u306f\u30ab\u30ec\u30f3\u30c8\u30c7\u30a3\u30ec\u30af\u30c8\u30ea\u76f4\u4e0b\u306baggregate.log\u3068\u3044\u3046\u540d\u524d\u3067\u51fa\u529b\u3059\u308b\u3053\u3068\u306b\u3057\u307e\u3059\u3002
\n\u307e\u305f\u3001\u4eca\u56de\u306e\u30b9\u30af\u30ea\u30d7\u30c8\u3067\u306f\u30ed\u30b0\u3092\u30b3\u30f3\u30bd\u30fc\u30eb\u306b\u8868\u793a\u3055\u305b\u308b\u3068\u7d50\u679c\u30e1\u30c3\u30bb\u30fc\u30b8\u304c\u57cb\u3082\u308c\u3066\u3057\u307e\u3046\u305f\u3081\u3001\u30b3\u30f3\u30bd\u30fc\u30eb\u51fa\u529b\u30cf\u30f3\u30c9\u30e9\u306f\u8a2d\u5b9a\u3057\u3066\u3044\u307e\u305b\u3093\u3002\u30b3\u30f3\u30bd\u30fc\u30eb\u306b\u3082\u8868\u793a\u3055\u305b\u308b\u5834\u5408\u306f\u4ee5\u4e0b\u306e\u3088\u3046\u306b\u8a18\u8ff0\u3057\u307e\u3059\u3002<\/p>\n\r\nSTREAM_HANDLER = logging.StreamHandler()\r\nlogging.basicConfig(level=LOG_LEVEL, format=LOG_FORMAT, handlers=[FILE_HANDLER, STREAM_HANDLER])\r\n<\/pre>\n\u4eca\u56de\u306f\u6700\u4f4e\u9650\u3001\u958b\u59cb\u7d42\u4e86\u3084\u3069\u3053\u306e\u51e6\u7406\u307e\u3067\u304a\u3053\u306a\u3063\u305f\u306e\u304b\u304c\u308f\u304b\u308b\u3088\u3046\u306bmain.py\u306b\u4ee5\u4e0b\u306e\u51fa\u529b\u3092\u5b9f\u88c5\u3059\u308b\u3053\u3068\u306b\u3057\u307e\u3059\u3002<\/p>\n
\r\n# main.py\r\nfrom settings import THRESHOLD\r\nfrom argparse import ArgumentParser\r\nfrom input_data import file2list\r\nfrom aggregate import aggregate\r\nfrom output_data import output_result\r\nfrom logging import getLogger\r\n\r\n# \u30b3\u30de\u30f3\u30c9\u30e9\u30a4\u30f3\u5f15\u6570\u8a2d\u5b9a\r\nparser = ArgumentParser()\r\nparser.add_argument("input_file_path", help="\u30c7\u30fc\u30bf\u30d5\u30a1\u30a4\u30eb\u306e\u30d1\u30b9\u3092\u6307\u5b9a\u3057\u3066\u304f\u3060\u3055\u3044\u3002")\r\nargs = parser.parse_args()\r\n\r\nlogger = getLogger(__name__)\r\n\r\n\r\ndef main():\r\n """ \u30e1\u30a4\u30f3\u51e6\u7406 """\r\n\r\n logger.info("\u51e6\u7406\u958b\u59cb")\r\n\r\n # \u5165\u529b\u30c7\u30fc\u30bf\u691c\u8a3c\u30fb\u53d6\u5f97\r\n logger.info("\u5165\u529b\u30c7\u30fc\u30bf\u53d6\u5f97")\r\n data_list = file2list(args.input_file_path)\r\n\r\n # \u96c6\u8a08\u51e6\u7406\r\n logger.info("\u96c6\u8a08\u51e6\u7406\u5b9f\u884c")\r\n result_count = aggregate(data_list, THRESHOLD)\r\n\r\n # \u51fa\u529b\u51e6\u7406\r\n logger.info("\u7d50\u679c\u51fa\u529b")\r\n output_result(result_count)\r\n\r\n logger.info("\u51e6\u7406\u7d42\u4e86")\r\n\r\n\r\nif __name__ == '__main__':\r\n main()\r\n\r\n\r\n<\/pre>\n