import os
import sys

project_dir = os.path.abspath(os.getcwd())
sys.path.append(project_dir)

from autotrading.db.mongodb import mongodb_handler
from autotrading.machine.coinone_machine import CoinOneMachine
from autotrading.scheduler.coiner import Coiner

from celery import Celery

app = Celery('get_coin_info', backend='redis://localhost:6379/0', broker='redis://localhost:6379/0')


# app = Celery('get_coin_info', broker='redis://guest@localhost//')


@app.task
def get_coin_info():
    machine = CoinOneMachine()
    coiner = Coiner(machine)

    # result_etc = coiner.get_filled_orders(currency_pair="etc_krw")
    result_eth = coiner.get_filled_orders(currency_pair="eth")
    result_btc = coiner.get_filled_orders(currency_pair="btc")
    # result_xrp = coiner.get_filled_orders(currency_pair="xrp")

    mongodb = mongodb_handler.MongoDbHandler("local", "coiner", "price_info")
    result_list = result_eth + result_btc
    ids = mongodb.insert_items(result_list)

d3b95f70f886f3b5222f584ea4abe08db2433fc4
<mask token>


@app.task
def get_coin_info():
    machine = CoinOneMachine()
    coiner = Coiner(machine)
    result_eth = coiner.get_filled_orders(currency_pair='eth')
    result_btc = coiner.get_filled_orders(currency_pair='btc')
    mongodb = mongodb_handler.MongoDbHandler('local', 'coiner', 'price_info')
    result_list = result_eth + result_btc
    ids = mongodb.insert_items(result_list)

<mask token>
sys.path.append(project_dir)
<mask token>


@app.task
def get_coin_info():
    machine = CoinOneMachine()
    coiner = Coiner(machine)
    result_eth = coiner.get_filled_orders(currency_pair='eth')
    result_btc = coiner.get_filled_orders(currency_pair='btc')
    mongodb = mongodb_handler.MongoDbHandler('local', 'coiner', 'price_info')
    result_list = result_eth + result_btc
    ids = mongodb.insert_items(result_list)

<mask token>
project_dir = os.path.abspath(os.getcwd())
sys.path.append(project_dir)
<mask token>
app = Celery('get_coin_info', backend='redis://localhost:6379/0', broker=
    'redis://localhost:6379/0')


@app.task
def get_coin_info():
    machine = CoinOneMachine()
    coiner = Coiner(machine)
    result_eth = coiner.get_filled_orders(currency_pair='eth')
    result_btc = coiner.get_filled_orders(currency_pair='btc')
    mongodb = mongodb_handler.MongoDbHandler('local', 'coiner', 'price_info')
    result_list = result_eth + result_btc
    ids = mongodb.insert_items(result_list)

import os
import sys
project_dir = os.path.abspath(os.getcwd())
sys.path.append(project_dir)
from autotrading.db.mongodb import mongodb_handler
from autotrading.machine.coinone_machine import CoinOneMachine
from autotrading.scheduler.coiner import Coiner
from celery import Celery
app = Celery('get_coin_info', backend='redis://localhost:6379/0', broker=
    'redis://localhost:6379/0')


@app.task
def get_coin_info():
    machine = CoinOneMachine()
    coiner = Coiner(machine)
    result_eth = coiner.get_filled_orders(currency_pair='eth')
    result_btc = coiner.get_filled_orders(currency_pair='btc')
    mongodb = mongodb_handler.MongoDbHandler('local', 'coiner', 'price_info')
    result_list = result_eth + result_btc
    ids = mongodb.insert_items(result_list)

import os
import sys

project_dir = os.path.abspath(os.getcwd())
sys.path.append(project_dir)

from autotrading.db.mongodb import mongodb_handler
from autotrading.machine.coinone_machine import CoinOneMachine
from autotrading.scheduler.coiner import Coiner

from celery import Celery

app = Celery('get_coin_info', backend='redis://localhost:6379/0', broker='redis://localhost:6379/0')


# app = Celery('get_coin_info', broker='redis://guest@localhost//')


@app.task
def get_coin_info():
    machine = CoinOneMachine()
    coiner = Coiner(machine)

    # result_etc = coiner.get_filled_orders(currency_pair="etc_krw")
    result_eth = coiner.get_filled_orders(currency_pair="eth")
    result_btc = coiner.get_filled_orders(currency_pair="btc")
    # result_xrp = coiner.get_filled_orders(currency_pair="xrp")

    mongodb = mongodb_handler.MongoDbHandler("local", "coiner", "price_info")
    result_list = result_eth + result_btc
    ids = mongodb.insert_items(result_list)
