FLUXON · DEVELOPER DOCS
Development API reference
Browse work_lib functions and types by category and look up APIs used in generated code.
71 / 71 entries
def FLX_LOG(self, level, msg, *args, exc_info=None) -> None
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
level | 미지정 | — | 위치 / 키워드 |
msg | 미지정 | — | 위치 / 키워드 |
*args | 미지정 | — | 가변 위치 |
exc_info | 미지정 | None | 키워드 전용 |
Return type
NoneArgs
level: 로그 레벨 DEBUG, INFO, WARNING, ERROR, CRITICAL msg: 로그 메시지 args: 필요시 기타 인자들 exc_info: 예외 traceback 출력 여부. None이면 현재 except 문맥의 예외가 있을 때만 자동 출력
Returns
없음
work_lib.pyi : 38
def FLX_Return_Error(self, ret_code: int, ret_msg: str='', is_traceback: bool=False, **msg_params) -> NoReturn
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
ret_code | int | — | 위치 / 키워드 |
ret_msg | str | '' | 위치 / 키워드 |
is_traceback | bool | False | 위치 / 키워드 |
**msg_params | 미지정 | — | 가변 키워드 |
Return type
NoReturnArgs
ret_code: 오류 코드 ret_msg: 오류 메시지 (Default: '') is_traceback: True이면 현재 예외 traceback을 로그에 포함하고, False이면 오류 메시지만 기록
Returns
없음
work_lib.pyi : 51
def FLX_Return_Normal(self, _return: Any | None=None, ret_code: int=0, ret_msg: str='', **msg_params) -> NoReturn
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
_return | Any | None | None | 위치 / 키워드 |
ret_code | int | 0 | 위치 / 키워드 |
ret_msg | str | '' | 위치 / 키워드 |
**msg_params | 미지정 | — | 가변 키워드 |
Return type
NoReturnArgs
_return: 정상 리턴할 값 ret_code: 오류 코드 ret_msg: 오류 메시지 (Default: '')
Returns
없음
work_lib.pyi : 63
@property def FLX_Get_Property_CCode(self)
Return type
타입 미지정Returns
국가 코드 리턴
work_lib.pyi : 76
@property def FLX_Get_Property_ComCode(self)
Return type
타입 미지정Returns
회사 코드 리턴
work_lib.pyi : 83
@property def FLX_Get_Property_Default_StorageName(self)
Return type
타입 미지정Returns
storage 이름 반환 : 회사코드_namespace(dev, stg)
work_lib.pyi : 90
def FLX_Get_Agent_Object(self, name: str)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
name | str | — | 위치 / 키워드 |
Return type
타입 미지정Args
name: Agent 이름
Returns
해당 Agent 객체
work_lib.pyi : 96
def FLX_Get_S3_Object(self)
Return type
타입 미지정Returns
해당 S3 객체
work_lib.pyi : 104
def FLX_Get_Data(self, field: str | None=None, convert_type: Any | None=None) -> Any | None
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
field | str | None | None | 위치 / 키워드 |
convert_type | Any | None | None | 위치 / 키워드 |
Return type
Any | NoneArgs
field: 필드명 (None이면 전체 client 요청 DataSet 리턴) convert_type: 변환할 타입 (int, str, bool, float 등)
Returns
필드 값 or None or 전체 client 요청 DataSet
work_lib.pyi : 110
def FLX_Get_PartName(self)
Return type
타입 미지정Returns
서비스 구분명
work_lib.pyi : 121
def FLX_IsTerm_Exit(self) -> None
Return type
Nonework_lib.pyi : 128
def FLX_IsCancel(self)
Return type
타입 미지정Returns
취소이면 True, 아니면 False
work_lib.pyi : 131
def FLX_RedisSync(self) -> redis_sync.Redis
Return type
redis_sync.Redis설명
Return sync Redis client passed as `RedisSync`. Note: Use this for direct Redis access inside run() (thread) where async __redis is unsafe.
work_lib.pyi : 139
def FLX_Get_UUID(self, use_dash: bool=False) -> str
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
use_dash | bool | False | 위치 / 키워드 |
Return type
strArgs
use_dash: True이면 '-' 포함 (default: False)
Returns
uuid
work_lib.pyi : 145
def FLX_WS_Is_Stream(self) -> bool
Return type
boolReturns
bool: req_case 가 ws_work 이면 True
work_lib.pyi : 155
def FLX_WS_Start_Stream(self) -> bool
Return type
bool설명
Gateway가 Redis Stream에 적재한 WebSocket 수신 데이터를 내부 Queue(self.__in_q)로 전달하는 백그라운드 처리를 시작한다.
Returns
bool: 시작했으면 True, 이미 시작되어 있으면 False
work_lib.pyi : 162
def FLX_WS_Recv(self, timeout: float | None=1.0)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
timeout | float | None | 1.0 | 위치 / 키워드 |
Return type
타입 미지정Args
timeout: 대기 시간(초). None이면 무한 대기
Returns
bytes | None: - bytes: 수신 데이터 - None : EOS, cancel, timeout, 종료 신호
work_lib.pyi : 173
def FLX_WS_Recv_Text(self, timeout: float | None=1.0, encoding: str='utf-8') -> str | None
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
timeout | float | None | 1.0 | 위치 / 키워드 |
encoding | str | 'utf-8' | 위치 / 키워드 |
Return type
str | NoneArgs
timeout: 대기 시간(초). None이면 무한 대기 encoding: bytes decode 인코딩
Returns
str | None: 수신 문자열. EOS, cancel, timeout이면 None
work_lib.pyi : 185
def FLX_WS_Recv_Json(self, timeout: float | None=1.0, encoding: str='utf-8')
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
timeout | float | None | 1.0 | 위치 / 키워드 |
encoding | str | 'utf-8' | 위치 / 키워드 |
Return type
타입 미지정Args
timeout: 대기 시간(초). None이면 무한 대기 encoding: bytes decode 인코딩
Returns
dict | list | str | int | float | bool | None: - JSON parse 성공 시 JSON 객체 - EOS, cancel, timeout이면 None
raise
WorkErrorException: JSON parse 실패
work_lib.pyi : 196
def FLX_WS_Send(self, data: Any, ret_code: int=0, ret_msg: str='None') -> bool
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
data | Any | — | 위치 / 키워드 |
ret_code | int | 0 | 위치 / 키워드 |
ret_msg | str | 'None' | 위치 / 키워드 |
Return type
boolArgs
data: dict, list, str, bytes 등 응답 데이터 ret_code: 결과 코드 ret_msg: 결과 메시지
Returns
bool: 전송 성공 여부
work_lib.pyi : 212
def FLX_Common_Module_Load(self, module_name: str)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
module_name | str | — | 위치 / 키워드 |
Return type
타입 미지정우선순위
1. com_code 범위 svc_common 2. req_group 범위 svc_common 3. req_service 범위 svc_common 파일이 변경되면 DynamicModuleLoader가 다음 호출에서 자동 reload한다.
work_lib.pyi : 224
def FLX_Common_Get(self, module_name: str, attr_name: str) -> Any
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
module_name | str | — | 위치 / 키워드 |
attr_name | str | — | 위치 / 키워드 |
Return type
Anywork_lib.pyi : 235
def FLX_Common_Call(self, module_name: str, func_name: str, *args: Any, **kwargs: Any) -> Any
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
module_name | str | — | 위치 / 키워드 |
func_name | str | — | 위치 / 키워드 |
*args | Any | — | 가변 위치 |
**kwargs | Any | — | 가변 키워드 |
Return type
Anywork_lib.pyi : 238
def FLX_ExtLib_Stream_Run(self, case: str, name: str)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
case | str | — | 위치 / 키워드 |
name | str | — | 위치 / 키워드 |
Return type
타입 미지정Args
case: 케이스명 stt 등 (사전에 정의된 값) name: 라이브러리명 google, naver 등 (사전에 정의된 값)
Returns
없음 (오류 종료 : ecode=101)
work_lib.pyi : 241
def FLX_ExtLib_Simple_Run(self, case: str, name: str, req_data: dict)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
case | str | — | 위치 / 키워드 |
name | str | — | 위치 / 키워드 |
req_data | dict | — | 위치 / 키워드 |
Return type
타입 미지정Args
case: 케이스명 mt, 등 (사전에 정의된 값) name: 라이브러리명 google, naver 등 (사전에 정의된 값) req_data: 요청 Data
Returns
없음 (오류 종료 : ecode=101, 102-Library 로딩 실패)
work_lib.pyi : 252
def FLX_Stream_Get_Result(self)
Return type
타입 미지정Returns
결과 Json
work_lib.pyi : 264
def FLX_Stream_Result_Send(self, result: Any, ret_code: int=0, ret_msg: str='', *, final: bool=False)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
result | Any | — | 위치 / 키워드 |
ret_code | int | 0 | 위치 / 키워드 |
ret_msg | str | '' | 위치 / 키워드 |
final | bool | False | 키워드 전용 |
Return type
타입 미지정Args
result: 전송할 결과 Json ret_code: 결과 코드 (Default: 0) ret_msg: 결과 메시지 (Default: '') final: 최종 응답 여부. Redis 내부에서만 사용하며 frontend에는 전달하지 않는다.
Returns
없음
work_lib.pyi : 271
def FLX_Get_InfoRead(self, file_name: str)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
file_name | str | — | 위치 / 키워드 |
Return type
타입 미지정Args
file_name: info 파일명 (확장자 포함)
Returns
텍스트 문자열/JSON 또는 오류
work_lib.pyi : 284
def FLX_Get_DictValue(self, info: dict, field_name: str, default: Any=...)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
info | dict | — | 위치 / 키워드 |
field_name | str | — | 위치 / 키워드 |
default | Any | ... | 위치 / 키워드 |
Return type
타입 미지정설명
- field_name="mongo_db"이면 info["mongo_db"] 값을 반환한다. - field_name="mongo_db.name"이면 info["mongo_db"]["name"] 값을 반환한다. - 함수 내부에서는 current 지역 변수만 이동하므로, 전달받은 원본 info dict는 수정하지 않는다. - 필드가 없거나 중간 경로가 dict가 아닌 경우, default가 지정되어 있으면 그 값을 반환한다. - default를 지정하지 않았으면 internal_error_return(..., ...)로 작업 오류를 발생시킨다.
Args
info: 값을 읽을 dict 객체 field_name: 읽을 필드명 또는 점(.)으로 연결된 경로 default: 필드가 없거나 경로가 잘못된 경우 반환할 기본값
Returns
지정한 필드 값 또는 default 값
work_lib.pyi : 294
def FLX_Get_Value(self, info_name: str | dict, field_names: str | list[str])
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
info_name | str | dict | — | 위치 / 키워드 |
field_names | str | list[str] | — | 위치 / 키워드 |
Return type
타입 미지정설명
- info_name이 문자열이면 svc_info 범위에서 해당 파일을 읽는다. - info_name이 dict이면 해당 dict에서 바로 값을 읽는다. - field_names가 문자열이면 해당 필드 값을 반환한다. - field_names가 list이면 list에 지정된 순서대로 모든 필드 값을 조회하여 list로 반환한다. - 필드가 없거나 경로가 잘못된 경우 internal_error_return(202, ...)로 작업 오류를 발생시킨다.
Args
info_name: svc_info 파일명 또는 dict 객체 field_names: 필드명 또는 필드명 목록
Returns
- field_names가 str이면 지정한 필드 값 - field_names가 list이면 지정한 순서대로 조회한 값 list
work_lib.pyi : 313
def FLX_Get_TemplateRead(self, file_name: str)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
file_name | str | — | 위치 / 키워드 |
Return type
타입 미지정Args
file_name: 템플릿 파일명 (확장자 포함)
Returns
텍스트 문자열/JSON 또는 오류
work_lib.pyi : 332
@staticmethod def FLX_Hash_Password(password: str, iterations: int=200000) -> str
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
password | str | — | 위치 / 키워드 |
iterations | int | 200000 | 위치 / 키워드 |
Return type
strArgs
password: 원문 비밀번호 iterations: PBKDF2 반복 횟수
Returns
pbkdf2_sha256$반복횟수$salt_base64$hash_base64 형식의 문자열
work_lib.pyi : 343
@staticmethod def FLX_Verify_Password(raw_password: str, saved_password: str) -> bool
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
raw_password | str | — | 위치 / 키워드 |
saved_password | str | — | 위치 / 키워드 |
Return type
boolArgs
raw_password: 사용자가 입력한 원문 비밀번호 saved_password: 저장된 비밀번호 해시 문자열
Returns
일치하면 True, 아니면 False
work_lib.pyi : 355
def FLX_Other_Token_Create(self, subject: str, data: dict, ttl_seconds: int | None=None) -> str
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
subject | str | — | 위치 / 키워드 |
data | dict | — | 위치 / 키워드 |
ttl_seconds | int | None | None | 위치 / 키워드 |
Return type
strArgs
subject: 생성하는 토큰의 제목 data: 토큰에 저장하는 dict ttl_seconds:
Returns
token 문자열
work_lib.pyi : 366
def FLX_Other_Token_Update(self, token: str, ttl_seconds: int | None=None, overwrite_data: dict | None=None) -> str
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
token | str | — | 위치 / 키워드 |
ttl_seconds | int | None | None | 위치 / 키워드 |
overwrite_data | dict | None | None | 위치 / 키워드 |
Return type
strArgs
token: 토큰 문자열 ttl_seconds: (옵션) 만료시간 (디폴트:1800) overwrite_data : (옵션) 토큰 저장데이터 변경 (None:변경없음)
Returns
새 토큰 문자열 내부 오류 발생 시: - "ecode":301, "emsg": "token is empty" - "ecode":302, "emsg": "invalid token" - "ecode":303, "emsg": "token payload decode failed" - "ecode":304, "emsg": "token payload must be dict" - "ecode":305, "emsg": "invalid expire_at field" - "ecode":306, "emsg": "token expired" - "ecode":307, "emsg": "invalid subject field"
work_lib.pyi : 378
def FLX_Get_Token_Payload(self, field: str | None=None, token: str | None=None) -> Any
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
field | str | None | None | 위치 / 키워드 |
token | str | None | None | 위치 / 키워드 |
Return type
AnyArgs
field: 토큰에 저장되어 있는 필드의 값을 추출하려면 token: 토큰 문자열, None이면 Auth_Token
Returns
- field가 있으면 토큰에서 필드에 해당하는 값을 리턴 - token만 있으면 토큰 전체의 payload 리턴 - token의 payload(dict) - {'subject': '', 'data': {}, 'insert_at': , 'expire_at': , 'jwt_id': ''} 오류 : - "ecode":301, "emsg": "token is empty" - "ecode":302, "emsg": "invalid token" - "ecode":303, "emsg": "token payload decode failed" - "ecode":304, "emsg": "token payload must be dict" - "ecode":305, "emsg": "invalid expire_at field" - "ecode":306, "emsg": "token expired" - "ecode":308, "emsg": "token is None"
work_lib.pyi : 398
def FLX_Auth_Token_Create(self, subject: str, data: dict, ttl_seconds: int | None=None) -> None
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
subject | str | — | 위치 / 키워드 |
data | dict | — | 위치 / 키워드 |
ttl_seconds | int | None | None | 위치 / 키워드 |
Return type
NoneArgs
subject: 생성하는 토큰의 제목 data: 토큰에 저장하는 dict ttl_seconds:
Returns
없음
work_lib.pyi : 421
def FLX_Auth_Token_Update(self, token: str | None=None, ttl_seconds: int | None=None, overwrite_data: dict | None=None) -> None
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
token | str | None | None | 위치 / 키워드 |
ttl_seconds | int | None | None | 위치 / 키워드 |
overwrite_data | dict | None | None | 위치 / 키워드 |
Return type
NoneArgs
token: 토큰 문자열, None이면 기존 Token을 Update ttl_seconds: (옵션) 만료시간 (디폴트:1800) overwrite_data : (옵션) 토큰 저장데이터 변경 (None:변경없음)
Returns
- 없음 - 갱신된 토큰은 반환하지 않고 self.__flx_auth_token 내부 변수에만 반영한다. 내부 오류 발생 시: - "ecode":301, "emsg": "token is empty" - "ecode":302, "emsg": "invalid token" - "ecode":303, "emsg": "token payload decode failed" - "ecode":304, "emsg": "token payload must be dict" - "ecode":305, "emsg": "invalid expire_at field" - "ecode":306, "emsg": "token expired" - "ecode":307, "emsg": "invalid subject field"
work_lib.pyi : 433
def FLX_Field_Check(self, field_name: str | None=None, convert_type: Any=None, is_exist: bool=True, **kwargs: Any) -> None
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
field_name | str | None | None | 위치 / 키워드 |
convert_type | Any | None | 위치 / 키워드 |
is_exist | bool | True | 위치 / 키워드 |
**kwargs | Any | — | 가변 키워드 |
Return type
None설명
- 검사 대상은 현재 요청 데이터(self.__mw_request_data)이다. - self.__mw_request_data가 dict가 아니면 201 오류로 종료한다. - field_name은 "user_id" 같은 일반 필드명과 "aaas.user_pwd" 같은 점(.) 경로를 모두 지원한다. - is_exist=True이면 field_name이 반드시 존재해야 하며, 없으면 202 오류로 종료한다. - is_exist=False이면 field_name이 없어도 정상 통과한다. - convert_type이 지정되어 있어도 field_name이 없고 is_exist=False이면 타입 변환을 수행하지 않는다. - 일반 필드는 기존 FLX_Type_Convert를 사용하여 변환한다. - 점(.) 경로 필드는 FLX_Field_Check 내부에서 마지막 필드 값을 직접 변환하여 원본 요청 데이터에 재저장한다. - 기존 키워드 호환을 위해 FieldName, Convert_Type, isExist 키워드도 허용한다.
Args
field_name: 검사할 필드명 또는 점(.)으로 연결된 경로 convert_type: 변환할 타입. 예: int, str, bool, float 등. None이면 타입 변환하지 않음 is_exist: True이면 필수 필드로 검사하고, False이면 선택 필드로 검사
Returns
없음
Raises
WorkErrorException: internal_error_return 호출을 통해 작업 오류로 종료 - 321: 요청 데이터 형식 오류 - 322: 필수 항목 없음 또는 필드 경로 오류 - 323: 타입 변환 오류
work_lib.pyi : 454
def FLX_Type_Convert(self, field_name: str, convert_type: Any, data_set: dict | None=None) -> None
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
field_name | str | — | 위치 / 키워드 |
convert_type | Any | — | 위치 / 키워드 |
data_set | dict | None | None | 위치 / 키워드 |
Return type
None설명
-data_set이 None이면 현재 요청 데이터(self.__mw_request_data)를 사용한다. - 검사 대상 데이터가 dict가 아니면 201 오류로 종료한다. - field_name이 데이터셋에 없으면 202 오류로 종료한다. - convert_type이 bool이면 문자열 "true"/"false"를 명확하게 변환한다. - bool 이외의 타입은 convert_type(value) 방식으로 변환한다. - 변환된 값은 check_data_set[field_name]에 다시 저장된다.
Args
field_name: 변환할 필드명 convert_type: 변환할 타입. 예: int, str, bool, float 등 data_set: 검사 및 변환할 데이터셋. None이면 요청 데이터 사용
Returns
없음
Raises
WorkErrorException: internal_error_return 호출을 통해 작업 오류로 종료 - 322~327
work_lib.pyi : 483
def FLX_Query_Load(self, query_num: int, replace_items: dict | None=None) -> str | None
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
query_num | int | — | 위치 / 키워드 |
replace_items | dict | None | None | 위치 / 키워드 |
Return type
str | NoneArgs
query_num: Query 번호 replace_items: 치환할 문자열 set
Returns
Query 문자열 (오류 종료 : ecode=51)
work_lib.pyi : 507
def FLX_Other_Query_Load(self, req_name: str, query_num: int, com_code: str | None=None, req_group: str | None=None, req_service: str | None=None, replace_items: dict | None=None) -> str | None
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
req_name | str | — | 위치 / 키워드 |
query_num | int | — | 위치 / 키워드 |
com_code | str | None | None | 위치 / 키워드 |
req_group | str | None | None | 위치 / 키워드 |
req_service | str | None | None | 위치 / 키워드 |
replace_items | dict | None | None | 위치 / 키워드 |
Return type
str | NoneArgs
req_name: 요청 이름 query_num: Query 번호 com_code: 요청 ID (None이면 현재 작업의 com_code 사용) req_group: 요청 그룹명 (None이면 현재 작업의 req_group 사용) req_service: 요청 서비스명 (None이면 현재 작업의 req_service 사용) replace_items: 치환할 문자열 set
Returns
Query 문자열 (오류 종료 : ecode=52)
work_lib.pyi : 518
def FLX_Mongo_Get_Session(self, db_name: str='')
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
db_name | str | '' | 위치 / 키워드 |
Return type
타입 미지정Args
db_name (str): 풀 이름
Returns
sess: Session 객체
work_lib.pyi : 540
def FLX_Mongo_Release_Session(self, sess) -> None
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
sess | 미지정 | — | 위치 / 키워드 |
Return type
NoneArgs
sess: Session 객체
Returns
None
work_lib.pyi : 551
def FLX_Mongo_ObjectId(self, value: Any)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
value | Any | — | 위치 / 키워드 |
Return type
타입 미지정Args
value: ObjectId로 변환할 값. ObjectId 또는 ObjectId 문자열
Returns
ObjectId: MongoDB 조회 조건 등에 사용할 ObjectId 객체
Raises
WorkErrorException: internal_error_return 호출을 통해 작업 오류로 종료 - 31: ObjectId 변환 오류
work_lib.pyi : 562
def FLX_Mongo_Find(self, sess, database: str, collection: str, query_filter: JsonDict | None=None, *, projection: JsonDict | None=None, sort: Sequence[tuple[str, int]] | None=None, limit: int=0, skip: int=0)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
sess | 미지정 | — | 위치 / 키워드 |
database | str | — | 위치 / 키워드 |
collection | str | — | 위치 / 키워드 |
query_filter | JsonDict | None | None | 위치 / 키워드 |
projection | JsonDict | None | None | 키워드 전용 |
sort | Sequence[tuple[str, int]] | None | None | 키워드 전용 |
limit | int | 0 | 키워드 전용 |
skip | int | 0 | 키워드 전용 |
Return type
타입 미지정Args
sess: Mongo 세션 객체 database (str): 조회 대상 DB 이름 collection (str): collection name query_filter (dict|None): 조회 조건. None이면 전체 조회 projection (dict|None): 반환 필드 선택 (예: {"name": 1, "age": 1}) sort: [("created_at", -1)] limit (int): 최대 반환 개수 (0이면 제한 없음) skip (int): 스킵 개수
Returns
list[dict]: 조회된 문서 리스트 o 문서의 `_id`(ObjectId) 및 날짜/바이너리 타입은 JSON 직렬화 가능한 형태로 변환되어 반환됨 - ObjectId -> 문자열 - datetime/date -> ISO 문자열 - Bytes -> hex 문자열
work_lib.pyi : 577
def FLX_Mongo_FindOne(self, sess, database: str, collection: str, query_filter: JsonDict | None=None, *, projection: JsonDict | None=None, sort: list[tuple[str, int]] | None=None)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
sess | 미지정 | — | 위치 / 키워드 |
database | str | — | 위치 / 키워드 |
collection | str | — | 위치 / 키워드 |
query_filter | JsonDict | None | None | 위치 / 키워드 |
projection | JsonDict | None | None | 키워드 전용 |
sort | list[tuple[str, int]] | None | None | 키워드 전용 |
Return type
타입 미지정Args
sess: Mongo 세션 객체 database (str): 조회 대상 DB 이름 collection (str): 컬렉션 이름 query_filter (dict|None): 조회 조건. None이면 첫 문서 반환(정렬 없음) projection (dict|None): 반환 필드 선택 sort (list[tuple[str, int]]|None): 정렬 조건. 예: [("_id", -1)]
Returns
dict | None: 조회된 문서 1건 또는 없음
work_lib.pyi : 599
def FLX_Mongo_Insert(self, sess, database: str, collection: str, doc: JsonDict | Sequence[JsonDict], *, ordered: bool=True)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
sess | 미지정 | — | 위치 / 키워드 |
database | str | — | 위치 / 키워드 |
collection | str | — | 위치 / 키워드 |
doc | JsonDict | Sequence[JsonDict] | — | 위치 / 키워드 |
ordered | bool | True | 키워드 전용 |
Return type
타입 미지정Args
sess: Mongo 세션 객체 database (str): 대상 DB 이름 collection (str): 컬렉션 이름 doc (dict | Sequence[dict]): 삽입할 문서 또는 문서 목록 o dict이면 insert_one 처리 o list/tuple 등 Sequence[dict]이면 insert_many 처리 ordered (bool): 여러 건 insert 시 True이면 순서대로 처리하고 중간 오류 발생 시 중단 o False이면 가능한 문서는 계속 삽입 시도 o 단건 insert인 경우에는 사용하지 않음
Returns
dict: o 단건 insert: {"inserted_count": 1, "inserted_id": "...", "inserted_ids": ["..."]} o 여러 건 insert: {"inserted_count": n, "inserted_id": None, "inserted_ids": ["...", "..."]}
work_lib.pyi : 615
def FLX_Mongo_Update(self, sess, database: str, collection: str, query_filter: JsonDict, update: JsonDict, *, many: bool=False, upsert: bool=False)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
sess | 미지정 | — | 위치 / 키워드 |
database | str | — | 위치 / 키워드 |
collection | str | — | 위치 / 키워드 |
query_filter | JsonDict | — | 위치 / 키워드 |
update | JsonDict | — | 위치 / 키워드 |
many | bool | False | 키워드 전용 |
upsert | bool | False | 키워드 전용 |
Return type
타입 미지정Args
sess: Mongo 세션 객체 database (str): 대상 DB 이름 collection (str): 컬렉션 이름 query_filter (dict): 대상 문서를 찾기 위한 조건 update (dict): 업데이트 문서(예: {"$set": {...}}) many (bool): False이면 update_one, True이면 update_many 처리 upsert (bool): True이면 조건에 맞는 문서가 없을 때 신규 생성 o many=False이면 조건에 맞는 문서가 여러 건이어도 1건만 수정함 o many=True이면 조건에 맞는 문서를 여러 건 수정함 o many=True, upsert=True이고 조건에 맞는 문서가 없으면 신규 문서는 1건만 생성됨
Returns
dict: matched_count (int): 조건과 매칭된 문서 수 modified_count (int): 실제 수정된 문서 수 upserted_id (str|None): upsert로 신규 생성된 경우 생성된 _id updated (bool): 기존 문서가 실제 변경된 경우 True inserted (bool): upsert로 신규 문서가 생성된 경우 True many (bool): 여러 건 수정 모드 여부
work_lib.pyi : 637
def FLX_Mongo_Delete(self, sess, database: str, collection: str, query_filter: JsonDict, *, many: bool=False)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
sess | 미지정 | — | 위치 / 키워드 |
database | str | — | 위치 / 키워드 |
collection | str | — | 위치 / 키워드 |
query_filter | JsonDict | — | 위치 / 키워드 |
many | bool | False | 키워드 전용 |
Return type
타입 미지정Args
sess: Mongo 세션 객체 database (str): 대상 DB 이름 collection (str): 컬렉션 이름 query_filter (dict): 삭제 대상 조건 many (bool): False이면 delete_one, True이면 delete_many 처리 o many=False이면 조건에 맞는 문서가 여러 건이어도 1건만 삭제함 o many=True이면 조건에 맞는 문서를 여러 건 삭제함
Returns
dict: deleted_count (int): 삭제된 문서 수 many (bool): 여러 건 삭제 모드 여부
work_lib.pyi : 664
def FLX_Mongo_Aggregate(self, sess, database: str, collection: str, pipeline: Sequence[JsonDict], *, allow_disk_use: bool=False)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
sess | 미지정 | — | 위치 / 키워드 |
database | str | — | 위치 / 키워드 |
collection | str | — | 위치 / 키워드 |
pipeline | Sequence[JsonDict] | — | 위치 / 키워드 |
allow_disk_use | bool | False | 키워드 전용 |
Return type
타입 미지정Args
:sess: Mongo 세션 객체 :database (str): 대상 DB 이름 :collection (str): 컬렉션 이름 :pipeline (list[dict]): aggregate :allow_disk_use (bool): 디스크 사용 허용 여부
Returns
list[dict]: 집계 결과 리스트 o 결과 내 ObjectId/datetime 등 BSON 타입은 JSON 직렬화 가능한 형태로 변환되어 반환됨
work_lib.pyi : 684
def FLX_MySql_Get_Session(self, db_name: str='')
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
db_name | str | '' | 위치 / 키워드 |
Return type
타입 미지정return
세션 (오류 종료 : ecode=11 or 12 / 13-Exception)
work_lib.pyi : 701
def FLX_MySql_Select(self, sess, query: str='', data_set: Any=None, is_get_one: bool=False, is_scalar: bool=False)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
sess | 미지정 | — | 위치 / 키워드 |
query | str | '' | 위치 / 키워드 |
data_set | Any | None | 위치 / 키워드 |
is_get_one | bool | False | 위치 / 키워드 |
is_scalar | bool | False | 위치 / 키워드 |
Return type
타입 미지정param
:sess: DB 세션 :query: 실행할 query :data_set: query에 바인딩할 데이터 (None이면 바인딩 없음) :is_get_one: 하나만 리턴할지 여부 (True이면 {} / False이면 list []) :is_scalar: 스칼라 값으로 리턴할지 여부 (True이면 scalar or None / False이면 is_get_one에 따라)
return
조회결과: scalar or 하나만 {} or list [] (오류 종료 : ecode=14)
work_lib.pyi : 710
def FLX_MySql_Execute(self, sess, query: str='', data_set: Any=None, is_get_last_id: bool=False)
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
sess | 미지정 | — | 위치 / 키워드 |
query | str | '' | 위치 / 키워드 |
data_set | Any | None | 위치 / 키워드 |
is_get_last_id | bool | False | 위치 / 키워드 |
Return type
타입 미지정param
:sess: DB 세션 :query: 실행할 query :data_set: query에 바인딩할 데이터 (None이면 바인딩 없음) :is_get_last_id: 마지막 Insert ID를 리턴할지 여부
return
실행결과 : {} or {'last_id':value} (오류 종료 : ecode=15)
work_lib.pyi : 726
def FLX_MySql_Commit(self, sess) -> None
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
sess | 미지정 | — | 위치 / 키워드 |
Return type
Noneparam
:sess: DB 세션
return
없음 (오류 종료 : ecode=16)
work_lib.pyi : 741
def FLX_MySql_Rollback(self, sess) -> None
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
sess | 미지정 | — | 위치 / 키워드 |
Return type
Noneparam
:sess: DB 세션
return
없음 (오류 종료 : ecode=17)
work_lib.pyi : 753
def FLX_MySql_Release_Session(self, sess) -> None
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
sess | 미지정 | — | 위치 / 키워드 |
Return type
Noneparam
:sess: DB 세션
return
없음
work_lib.pyi : 765
def __init__(self, **args) -> None
Parameters
| Name | Type | Default | Passing mode |
|---|---|---|---|
**args | 미지정 | — | 가변 키워드 |
Return type
Nonework_lib.pyi : 37
def FLX_RedisAsync(self) -> aioredis.Redis
Return type
aioredis.Rediswork_lib.pyi : 138
def run(self) -> dict
Return type
dictwork_lib.pyi : 534
@abstractmethod def FLX_Main_Field_Check(self) -> None
Return type
Nonework_lib.pyi : 536
@abstractmethod def FLX_Main_Work_Start(self) -> None
Return type
Nonework_lib.pyi : 538
JsonDict = dict[str, Any]
work_lib.pyi : 6
class ResponseData(TypedDict)
Fields
ret_code: int ret_msg: str result: Any
work_lib.pyi : 11
class ResultData(TypedDict)
Fields
cid: str req_case: str req_mode: str req_ccode: str com_code: str req_group: str req_service: str req_name: str error_code: int error_msg: str response_data: ResponseData
work_lib.pyi : 16
DEBUG: int
work_lib.pyi : 29
INFO: int
work_lib.pyi : 30
WARNING: int
work_lib.pyi : 31
ERROR: int
work_lib.pyi : 32
CRITICAL: int
work_lib.pyi : 33
class FLXWork(metaclass=ABCMeta)
Fields
daemon_ver: Incomplete
work_lib.pyi : 35