forex_data

• forex_data_aggregator package
  • Subpackages
    • forex_data.config package
      • Submodules
      • forex_data.config.config_file module
      • Module contents
    • forex_data.data_management package
      • Submodules
      • forex_data.data_management.common module
      • forex_data.data_management.database module
      • forex_data.data_management.historicaldata module
      • forex_data.data_management.realtimedata module
      • Module contents
  • Module contents
    • read_config_file()
    • read_config_string()
    • read_config_folder()
    • HistoricalManagerDB
      • HistoricalManagerDB.config
      • HistoricalManagerDB.data_type
      • HistoricalManagerDB.engine
      • HistoricalManagerDB.data_path
      • HistoricalManagerDB.db_files_year_partitioning
      • HistoricalManagerDB.volume_data
      • HistoricalManagerDB.ssl_verify
      • HistoricalManagerDB.polars_gpu_engine
      • HistoricalManagerDB.connector_id
      • HistoricalManagerDB.max_discrepancy_with_now
      • HistoricalManagerDB.__init__()
      • HistoricalManagerDB.get_source_connectors()
      • HistoricalManagerDB.clear_database()
      • HistoricalManagerDB.add_timeframe()
      • HistoricalManagerDB.get_data()
      • HistoricalManagerDB.get_data_window()
      • HistoricalManagerDB.plot()
      • HistoricalManagerDB.close()
    • COLUMN_NAME
      • COLUMN_NAME.TIMESTAMP
      • COLUMN_NAME.OPEN
      • COLUMN_NAME.HIGH
      • COLUMN_NAME.LOW
      • COLUMN_NAME.CLOSE
      • COLUMN_NAME.ASK
      • COLUMN_NAME.BID
      • COLUMN_NAME.VOLUME
      • COLUMN_NAME.ASK_VOLUME
      • COLUMN_NAME.BID_VOLUME
      • COLUMN_NAME.VWMP
      • COLUMN_NAME.VWMP_AVG
      • COLUMN_NAME.P_VALUE
      • COLUMN_NAME.TRANSACTIONS
      • COLUMN_NAME.OTC
      • COLUMN_NAME.VWAP
    • YearMonthList
      • YearMonthList.__init__()
      • YearMonthList.add_month()
      • YearMonthList.remove()
      • YearMonthList.append()
      • YearMonthList.extend()
    • NormalizedDict
      • NormalizedDict.__init__()
      • NormalizedDict.get()
      • NormalizedDict.setdefault()
      • NormalizedDict.update()
    • DATA_FILE_COLUMN_INDEX
      • DATA_FILE_COLUMN_INDEX.TIMESTAMP
    • DEFAULT_PATHS
      • DEFAULT_PATHS.BASE_PATH
      • DEFAULT_PATHS.HIST_DATA_FOLDER
      • DEFAULT_PATHS.REALTIME_DATA_FOLDER
    • SQL_COMPARISON_OPERATORS
      • SQL_COMPARISON_OPERATORS.GREATER_THAN
      • SQL_COMPARISON_OPERATORS.LESS_THAN
      • SQL_COMPARISON_OPERATORS.GREATER_THAN_OR_EQUAL
      • SQL_COMPARISON_OPERATORS.LESS_THAN_OR_EQUAL
      • SQL_COMPARISON_OPERATORS.EQUAL
      • SQL_COMPARISON_OPERATORS.NOT_EQUAL
    • SQL_CONDITION_AGGREGATION_MODES
      • SQL_CONDITION_AGGREGATION_MODES.AND
      • SQL_CONDITION_AGGREGATION_MODES.OR
    • empty_dataframe()
    • is_empty_dataframe()
    • shape_dataframe()
    • get_dataframe_column()
    • get_dataframe_row()
    • get_dataframe_element()
    • get_attrs_names()
    • any_date_to_datetime64()
    • get_db_key_elements()
    • check_timeframe_str()
    • DatabaseConnector
      • DatabaseConnector.data_path
      • DatabaseConnector.data_type
      • DatabaseConnector.engine
      • DatabaseConnector.polars_gpu_engine
      • DatabaseConnector.__init__()
      • DatabaseConnector.connect()
      • DatabaseConnector.check_connection()
      • DatabaseConnector.write_data()
      • DatabaseConnector.read_data()
      • DatabaseConnector.read_data_year()
      • DatabaseConnector.read_data_window()
      • DatabaseConnector.read_last_timestamp()
      • DatabaseConnector.get_tickers_list()
      • DatabaseConnector.get_ticker_keys()
      • DatabaseConnector.get_ticker_timeframes_list()
      • DatabaseConnector.get_ticker_years_list()
      • DatabaseConnector.create_tickers_years_dict()
      • DatabaseConnector.save_tickers_years_info()
      • DatabaseConnector.add_tickers_years_info_to_file()
      • DatabaseConnector.clear_tickers_years_info()
      • DatabaseConnector.clear_database()
      • DatabaseConnector.load_tickers_years_info()
    • LocalDBConnector
      • LocalDBConnector.__init__()
      • LocalDBConnector.write_data()
      • LocalDBConnector.read_data()
      • LocalDBConnector.read_data_year()
      • LocalDBConnector.read_data_window()
      • LocalDBConnector.read_last_timestamp()
    • TwelveDataConnector
      • TwelveDataConnector.api_key
      • TwelveDataConnector.plan
      • TwelveDataConnector.tier
      • TwelveDataConnector.__init__()
      • TwelveDataConnector.chunk_size
      • TwelveDataConnector.max_requests_per_minute
      • TwelveDataConnector.get_realtime_price()
      • TwelveDataConnector.get_data()
      • TwelveDataConnector.get_recent_data()
    • DukascopyConnector
      • DukascopyConnector.ssl_verify
      • DukascopyConnector.__init__()
      • DukascopyConnector.connect()
      • DukascopyConnector.check_connection()
      • DukascopyConnector.get_available_tickers()
      • DukascopyConnector.download_month_raw()
      • DukascopyConnector.get_recent_data()
    • concat_data()
    • validator_dir_path()
    • TickerNotFoundError
    • TickerDataNotFoundError
    • TickerDataBadTypeException
    • TickerDataInvalidException
    • get_histdata_tickers()
    • POLARS_DTYPE_DICT
      • POLARS_DTYPE_DICT.TICK_DTYPE
      • POLARS_DTYPE_DICT.TF_DTYPE
      • POLARS_DTYPE_DICT.TIME_TICK_DTYPE
      • POLARS_DTYPE_DICT.TIME_TF_DTYPE
    • business_days_data()
    • random_date_between()