Django objects.update_or_create - PullRequest
       1

Django objects.update_or_create

0 голосов
/ 18 февраля 2019

у меня есть period_task, работающий в сельдерее, который запрашивает последние цены на криптовалюту, но по какой-то причине, каждый раз, когда я хочу отобразить данные, я не получаю обновленные записи, я просто получаю новые, а старые записи по какой-то причине сохраняются.

tasks.py

@periodic_task(run_every=(crontab(minute='*/1')), name="Update Crypto rate(s)", ignore_result=True)
def get_exchange_rate():
    api_url = "https://api.coinmarketcap.com/v1/ticker/"
    try:
        exchange_rates = requests.get(api_url).json()
        for exchange_rate in exchange_rates:
            CryptoPrices.objects.update_or_create(key=exchange_rate['id'],
                                                  symbol=exchange_rate['symbol'],
                                                  market_cap_usd=round(float(exchange_rate['market_cap_usd']), 3),
                                                  volume_usd_24h=round(float(exchange_rate['24h_volume_usd']), 3),
                                                  defaults={'value': round(float(exchange_rate['price_usd']), 3)}
                                                  )
        logger.info("Crypto exchange rate(s) updated successfully.")
    except Exception as e:
        print(e)

models.py

class CryptoPrices(models.Model):
    key = models.CharField(max_length=255)
    value = models.CharField(max_length=255)
    symbol = models.CharField(max_length=255)
    volume_usd_24h = models.CharField(max_length=255)
    market_cap_usd = models.CharField(max_length=255)

views.py

def crypto_ticker(request):
        list_prices = CryptoPrices.objects.get_queryset().order_by('pk')
        paginator = Paginator(list_prices, 100)  # Show 100 prices per page
        page = request.GET.get('page')
        price = paginator.get_page(page)
        return render(request, 'crypto_ticker.html', {'price': price})

template.html:

{% extends 'base.html' %}
{% load readmore %}

{% block breadcrumbs %}
    {{ block.super }} » <a href="{% url 'post_list' %}">Posts </a> »
    <a href="{% url 'crypto_ticker' %}">Crypto ticker</a>
{% endblock %}


{% block content %}

    <!DOCTYPE html>
    <html>
    <head>
        <title>Crypto ticker</title>
    </head>

    <body>
    <h1 class="center">Crypto ticker</h1>
    <hr class="hr-style">
    <div class="center">
        <h4>{{ prices }} Here you can find all frequently asked questions <br>
            if you still have still have any open points, please contact the <a href="#">support</a>.</h4>
    </div>
    <br>
    <div class="paginator">
        <span>
         {% if price.has_previous %}
            <a href="?page=1">&laquo; First <a> |</a></a>
            <a href="?page={{ price.previous_page_number }}">Previous</a>
        {% endif %}

        {% if price.has_next %}
            <span> Crypto prices - Page {{ price.number }} of {{ price.paginator.num_pages }}.</span>
            <a href="?page={{ price.next_page_number }}">Next<a> |</a></a>
            <a href="?page={{ price.paginator.num_pages }}">Last &raquo;</a>
        {% endif %}
       </span>
   </div>
    <table class="table centercontentfloat class-three-box">
        <thead>
            <tr style="font-size: small">
                <th>Ranking</th>
                <th>Symbol</th>
                <th>Name</th>
                <th>Price</th>
                <th>Market Cap (USD)</th>
                <th>24 hrs. Volume (USD)</th>
            </tr>
        </thead>
        <tbody>
        {% for price in price %}
            <tr style="font-size: small">
                <td>{{ price.id }}</td>
                <td>{{ price.symbol }}</td>
                <td>{{ price.key }}</td>
                <td>{{ price.value }} $</td>
                <td style="font-size: small">{{ price.market_cap_usd }} $</td>
                <td style="font-size: small">{{ price.volume_usd_24h }} $</td>
            </tr>
            {% endfor %}
        </tbody>
    </table>
    <div class="paginator">
        <span>
            {% if price.has_previous %}
            <a href="?page=1">&laquo; First <a> |</a></a>
            <a href="?page={{ price.previous_page_number }}">Previous</a>
        {% endif %}

        {% if price.has_next %}
            <span> Crypto prices - Page {{ price.number }} of {{ price.paginator.num_pages }}.</span>
            <a href="?page={{ price.next_page_number }}">Next<a> |</a></a>
            <a href="?page={{ price.paginator.num_pages }}">Last &raquo;</a>
        {% endif %}
       </span>
    </div>
{% endblock %}

Есть ли какая-нибудь заметная причина, по которой записи, которые я беру из api coinmarketcap, сохраняются / отображаются дважды?

если я пролистываю страницы, я получаю что-то вроде этого:

Цены на шифрование - Страница 1 из 21. Следующая |Последняя »Рейтинг Символ Название Цена Рыночная капитализация (USD) 24 часа.Объем (USD) 1 BTC биткойн 3795,6465 $ 66594617840,0 $ 8296474984,64 $ 2 ETH ethereum 143,9996 $ 15106822040,0 $ 5043716023,22 $

и на второй странице:

«Первая |Предыдущая Crypto цены - Страница 2 из 22. Следующая |Последняя »Рейтинг Символ Название Цена Рыночная капитализация (USD) 24 часа.Объем (USD) 101 BTC биткойн 3798.3016 $ 66641201438.0 $ 8304474934.43 $ 102 ETH ethereum 144.0825 $ 15115524904.0 $ 5048205218.98 $

, и я не ожидаю, что BTC также находится на второй странице, только один раз на первой странице?!?

Действительно, если я перейду по страницам, записи не обновляются, они сохраняются одна за другой после каждого запуска period_task

С уважением

Ответы [ 2 ]

0 голосов
/ 18 февраля 2019

Вы неправильно понимаете, как работает update_or_create.Это то, что документы говорят:

Метод update_or_create пытается извлечь объект из базы данных на основе заданного kwargs.Если совпадение найдено, оно обновляет поля, переданные в словаре defaults.

Таким образом, в kwargs вы передаете только те значения, которые необходимы для совпадения, а не обновления.Вероятно, пропуск id или symbol должен быть единственным kwargs, который вам нужен.Все параметры, которые вы хотите обновить, необходимо передать в defaults.

CryptoPrices.objects.update_or_create(
    key=exchange_rate['id'],
    symbol=exchange_rate['symbol'],
    defaults=dict(
        market_cap_usd=round(float(exchange_rate['market_cap_usd']), 3),
        volume_usd_24h=round(float(exchange_rate['24h_volume_usd']), 3),
        value= round(float(exchange_rate['price_usd']), 3))
)
0 голосов
/ 18 февраля 2019

Вы используете все поля в запросе для существующих экземпляров.Вам нужно просто использовать уникальные там, а остальные в defaults dict.

CryptoPrices.objects.update_or_create(
   key=exchange_rate['id'],
   symbol=exchange_rate['symbol'],
   defaults={             
       "market_cap_usd": round(float(exchange_rate['market_cap_usd']), 3),
       "volume_usd_24h": round(float(exchange_rate['24h_volume_usd']), 3),
       "value": round(float(exchange_rate['price_usd']), 3)
    })
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...