오류모음집 (25) 썸네일형 리스트형 aiokafka.errors.IllegalStateError: IllegalStateError: Subscription to topics, partitions and pattern are mutually exclusive 발생 경위: consumer에서 특정 partition을 소모하려고 할때 발생 코드는 다음과 같다 @handle_kafka_errors async def initialize(self) -> None: """Kafka 소비자 및 생산자 연결 초기화""" if self.consumer_topic: self.consumer = AIOKafkaConsumer( self.conuser_topic, bootstrap_servers=self.bootstrap_servers, group_id=self.group_id, auto_offset_reset="lates.. TypeError: 'ThreadPoolExecutor' object does not support the asynchronous context manager protocol 발생 경위 : 비동기 함수에 ThreadPool 올림# fmt: offasync def coin_present_websocket(connection_class: connection) -> None: """두 개의 코인 웹소켓을 동시에 실행.""" async with ThreadPoolExecutor(max_workers=2) as executor: loop = asyncio.get_running_loop() # 클라이언트 클래스를 매개변수로 전달하여 작업 실행 korea_task = loop.run_in_executor( executor, asyncio.run, run_coin_websocket(connection_class, "BTC.. RuntimeError: There is no current event loop in thread 'ThreadPoolExecutor-1_0'. 발생 경위 : 비동기 함수 3개와 함께 다음과 같이 실행 시 발생하였음 async def crawl_and_insert(target: str, count: int, driver_class, source: str) -> None: loop = asyncio.get_running_loop() with ThreadPoolExecutor(max_workers=3) as executor: # run_in_executor를 통해 크롤링을 비동기적으로 실행 data_list = await loop.run_in_executor( executor, lambda: driver_class(target=target, count=count).news_collector() .. ValueError: Cannot convert column into bool: please use '&' for 'and', '|' for 'or', '~' for 'not' when building DataFrame boolean expressions. def convert_value_na_to_null(value): if value is None or (value == "") or (value.upper() == "NA"): return None else: return int(value) udf_convert_value_na_to_null = udf(convert_string_na_to_null, IntegerType()) converted_df3 = ( converted_df2. withColumn("year", convert_string_na_to_null(col("year"))). withColumn("month", convert_string_na_to_null(col("month"))). withColumn("dayofmonth", conver.. WARN package: Truncated the string representation of a plan since it was too large. This behavior can be adjusted by setting 'spark.sql.debug.maxToStringFields'. 대처 방안 경고문에서 볼 수 있듯이 표시하려는 데이터의 양이 너무 커서 성능상 저하가 일어날 수 있기에 중간이 끊음 이걸 조절하는 conf config("spark.sql.debug.maxToStringFields", int(~~)") 조절하면 됨 기본값은 200으로 알 고 있음 CommandError: "Project-Directory" already exists. Overlaying a project into an existing directory won't replace conflicting files. 발생 경위 docker-compose 설정 후에 마운트를 진행하지 않고 docker-compose run "directory" django-admin startproject "project name" 진행 해결 방안 docker-compose up 해서 동기화 시킬것 1번이 안되면 container image를 내리고 compose 해볼것 django.core.exceptions.ImproperlyConfigured: The SECRET_KEY setting must not be empty. 발생 원인 django SECRET_KEY 를 .env 에 관리하는 차원에서 os.getenv("SECRECT_KEY") 을 하여 실행하였으나 가져오지 못하여 다음과 같은 오류가 생겼음 내가 생각할때는 env 를 못가지고 오는거같음 대처방안 이렇게 load_doenv 라이브러리 이용해서 env file를 불러오면 끝..! django.core.exceptions.ImproperlyConfigured: Cannot import 'appname'. Check that 'app.appname.apps.AppnameConfig.name' is correct. 나의 django directory 구조는 다음과 같다 발단 경위 django applicaton을 apps file에 이관하고 INSTALLED_APPS에 등록할 때 해당 오류가 발생 대처 방안 자신의 등록한 application apps.py에 name을 해당 파일 경로에 맞춰서 작성을 하고 해야 함 사진 첨부 이전 1 2 3 4 다음
