mirror of
https://github.com/guezoloic/millesima_projetS6.git
synced 2026-03-29 03:23:47 +00:00
Compare commits
18 Commits
version_de
...
123c43aa05
| Author | SHA1 | Date | |
|---|---|---|---|
| 123c43aa05 | |||
| a163e7687f | |||
| 0f6eb856c6 | |||
| d62145e250 | |||
| 829c303e78 | |||
| b584f9a301 | |||
| 547c7ec4c1 | |||
| 0aa765d6a0 | |||
| 8a357abe86 | |||
|
|
2f5af5aabf | ||
| a33b484dea | |||
| dd430b9861 | |||
| 011bb6a689 | |||
| 96dbaaaaf6 | |||
| ed86e588f7 | |||
|
|
0182bbbf20 | ||
| 9f1ff1ef7b | |||
|
|
8cae082344 |
24
.github/workflows/python-app.yml
vendored
24
.github/workflows/python-app.yml
vendored
@@ -10,30 +10,36 @@ on:
|
|||||||
branches: ["main"]
|
branches: ["main"]
|
||||||
|
|
||||||
permissions:
|
permissions:
|
||||||
contents: read
|
contents: write
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
build:
|
build:
|
||||||
|
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v4
|
- uses: actions/checkout@v4
|
||||||
|
|
||||||
- name: Set up Python 3.10
|
- name: Set up Python 3.10
|
||||||
uses: actions/setup-python@v3
|
uses: actions/setup-python@v4
|
||||||
with:
|
with:
|
||||||
python-version: "3.10"
|
python-version: "3.10"
|
||||||
- name: Install dependencies
|
|
||||||
|
- name: install dependencies
|
||||||
run: |
|
run: |
|
||||||
python -m pip install --upgrade pip
|
python -m pip install --upgrade pip
|
||||||
pip install flake8 pytest
|
pip install ".[test,doc]"
|
||||||
if [ -f requirements.txt ]; then pip install -r requirements.txt; fi
|
|
||||||
- name: Lint with flake8
|
- name: Lint with flake8
|
||||||
run: |
|
run: |
|
||||||
# stop the build if there are Python syntax errors or undefined names
|
|
||||||
flake8 . --count --select=E9,F63,F7,F82 --show-source --statistics
|
flake8 . --count --select=E9,F63,F7,F82 --show-source --statistics
|
||||||
# exit-zero treats all errors as warnings. The GitHub editor is 127 chars wide
|
|
||||||
flake8 . --count --exit-zero --max-complexity=10 --max-line-length=127 --statistics
|
flake8 . --count --exit-zero --max-complexity=10 --max-line-length=127 --statistics
|
||||||
|
|
||||||
- name: Test with pytest
|
- name: Test with pytest
|
||||||
|
run: pytest
|
||||||
|
|
||||||
|
- name: Deploy Doc
|
||||||
|
if: github.event_name == 'push' && github.ref == 'refs/heads/main'
|
||||||
run: |
|
run: |
|
||||||
pytest
|
git config user.name github-actions
|
||||||
|
git config user.email github-actions@github.com
|
||||||
|
mkdocs gh-deploy --force
|
||||||
|
|||||||
2
.gitignore
vendored
2
.gitignore
vendored
@@ -205,3 +205,5 @@ cython_debug/
|
|||||||
marimo/_static/
|
marimo/_static/
|
||||||
marimo/_lsp/
|
marimo/_lsp/
|
||||||
__marimo__/
|
__marimo__/
|
||||||
|
|
||||||
|
*.csv
|
||||||
1
docs/index.md
Normal file
1
docs/index.md
Normal file
@@ -0,0 +1 @@
|
|||||||
|
# Millesima
|
||||||
3
docs/scraper.md
Normal file
3
docs/scraper.md
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
# Scraper
|
||||||
|
|
||||||
|
::: scraper.Scraper
|
||||||
4
docs/scraperdata.md
Normal file
4
docs/scraperdata.md
Normal file
@@ -0,0 +1,4 @@
|
|||||||
|
|
||||||
|
# _ScraperData
|
||||||
|
|
||||||
|
::: scraper._ScraperData
|
||||||
14
mkdocs.yml
Normal file
14
mkdocs.yml
Normal file
@@ -0,0 +1,14 @@
|
|||||||
|
site_name: "Projet Millesima S6"
|
||||||
|
|
||||||
|
theme:
|
||||||
|
name: "material"
|
||||||
|
|
||||||
|
plugins:
|
||||||
|
- search
|
||||||
|
- mkdocstrings
|
||||||
|
|
||||||
|
markdown_extensions:
|
||||||
|
- admonition
|
||||||
|
- pymdownx.details
|
||||||
|
- pymdownx.superfences
|
||||||
|
- pymdownx.tabbed
|
||||||
12
pyproject.toml
Normal file
12
pyproject.toml
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
[project]
|
||||||
|
name = "projet-millesima-s6"
|
||||||
|
version = "0.1.0"
|
||||||
|
dependencies = ["requests==2.32.5", "beautifulsoup4==4.14.3", "pandas==2.3.3"]
|
||||||
|
|
||||||
|
[project.optional-dependencies]
|
||||||
|
test = ["pytest==8.4.2", "requests-mock==1.12.1", "flake8==7.3.0"]
|
||||||
|
doc = ["mkdocs<2.0.0", "mkdocs-material==9.6.23", "mkdocstrings[python]"]
|
||||||
|
|
||||||
|
[build-system]
|
||||||
|
requires = ["setuptools", "wheel"]
|
||||||
|
build-backend = "setuptools.build_meta"
|
||||||
@@ -1,3 +0,0 @@
|
|||||||
requests>=2.32.5
|
|
||||||
requests-mock>=1.12.1
|
|
||||||
beautifulsoup4>=4.14.3
|
|
||||||
Binary file not shown.
20
src/main.py
Executable file
20
src/main.py
Executable file
@@ -0,0 +1,20 @@
|
|||||||
|
#!/usr/bin/env python3
|
||||||
|
|
||||||
|
from os import getcwd
|
||||||
|
from os.path import normpath, join
|
||||||
|
from sys import argv
|
||||||
|
from pandas import read_csv, DataFrame
|
||||||
|
|
||||||
|
def main() -> None:
|
||||||
|
if len(argv) != 2:
|
||||||
|
raise ValueError(f"{argv[0]} <filename.csv>")
|
||||||
|
|
||||||
|
path: str = normpath(join(getcwd(), argv[1]))
|
||||||
|
db: DataFrame = read_csv(path)
|
||||||
|
print(db.all())
|
||||||
|
|
||||||
|
if __name__ == "__main__":
|
||||||
|
try:
|
||||||
|
main()
|
||||||
|
except Exception as e:
|
||||||
|
print(f"ERREUR: {e}")
|
||||||
193
main.py → src/scraper.py
Normal file → Executable file
193
main.py → src/scraper.py
Normal file → Executable file
@@ -1,19 +1,36 @@
|
|||||||
|
#!/usr/bin/env python3
|
||||||
|
|
||||||
|
from sys import argv
|
||||||
from typing import cast
|
from typing import cast
|
||||||
from requests import Response, Session
|
from requests import HTTPError, Response, Session
|
||||||
from bs4 import BeautifulSoup, Tag
|
from bs4 import BeautifulSoup, Tag
|
||||||
from collections import OrderedDict
|
from collections import OrderedDict
|
||||||
from json import loads
|
from json import JSONDecodeError, loads
|
||||||
|
|
||||||
|
|
||||||
class _ScraperData:
|
class _ScraperData:
|
||||||
|
"""
|
||||||
|
Conteneur de données spécialisé pour extraire les informations des dictionnaires JSON.
|
||||||
|
|
||||||
|
Cette classe agit comme une interface simplifiée au-dessus du dictionnaire brut
|
||||||
|
renvoyé par la balise __NEXT_DATA__ du site Millesima.
|
||||||
|
"""
|
||||||
|
|
||||||
def __init__(self, data: dict[str, object]) -> None:
|
def __init__(self, data: dict[str, object]) -> None:
|
||||||
|
"""
|
||||||
|
Initialise le conteneur avec un dictionnaire de données.
|
||||||
|
|
||||||
|
Args:
|
||||||
|
data (dict[str, object]): Le dictionnaire JSON brut extrait de la page.
|
||||||
|
"""
|
||||||
self._data: dict[str, object] = data
|
self._data: dict[str, object] = data
|
||||||
|
|
||||||
def _getcontent(self) -> dict[str, object] | None:
|
def _getcontent(self) -> dict[str, object] | None:
|
||||||
"""_summary_
|
"""
|
||||||
|
Navigue dans l'arborescence Redux pour atteindre le contenu du produit.
|
||||||
|
|
||||||
Returns:
|
Returns:
|
||||||
dict[str, object]: _description_
|
dict[str, object] | None: Le dictionnaire du produit ou None si la structure diffère.
|
||||||
"""
|
"""
|
||||||
current_data: dict[str, object] = self._data
|
current_data: dict[str, object] = self._data
|
||||||
for key in ["initialReduxState", "product", "content"]:
|
for key in ["initialReduxState", "product", "content"]:
|
||||||
@@ -25,10 +42,11 @@ class _ScraperData:
|
|||||||
return current_data
|
return current_data
|
||||||
|
|
||||||
def _getattributes(self) -> dict[str, object] | None:
|
def _getattributes(self) -> dict[str, object] | None:
|
||||||
"""_summary_
|
"""
|
||||||
|
Extrait les attributs techniques (notes, appellations, etc.) du produit.
|
||||||
|
|
||||||
Returns:
|
Returns:
|
||||||
dict[str, object]: _description_
|
dict[str, object] | None: Les attributs du vin ou None.
|
||||||
"""
|
"""
|
||||||
current_data: object = self._getcontent()
|
current_data: object = self._getcontent()
|
||||||
if current_data is None:
|
if current_data is None:
|
||||||
@@ -37,9 +55,13 @@ class _ScraperData:
|
|||||||
|
|
||||||
def prix(self) -> float | None:
|
def prix(self) -> float | None:
|
||||||
"""
|
"""
|
||||||
Retourne le prix unitaire d'une bouteille (75cl).
|
Calcule le prix unitaire d'une bouteille (standardisée à 75cl).
|
||||||
|
|
||||||
Si aucun prix n'est disponible, retourne None.
|
Le site vend souvent par caisses (6, 12 bouteilles) ou formats (Magnum).
|
||||||
|
Cette méthode normalise le prix pour obtenir celui d'une seule unité.
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
float | None: Le prix calculé arrondi à 2 décimales, ou None.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
content = self._getcontent()
|
content = self._getcontent()
|
||||||
@@ -55,7 +77,6 @@ class _ScraperData:
|
|||||||
prix_calcule: float | None = None
|
prix_calcule: float | None = None
|
||||||
|
|
||||||
for item in items:
|
for item in items:
|
||||||
|
|
||||||
if not isinstance(item, dict):
|
if not isinstance(item, dict):
|
||||||
continue
|
continue
|
||||||
|
|
||||||
@@ -82,10 +103,11 @@ class _ScraperData:
|
|||||||
return prix_calcule
|
return prix_calcule
|
||||||
|
|
||||||
def appellation(self) -> str | None:
|
def appellation(self) -> str | None:
|
||||||
"""_summary_
|
"""
|
||||||
|
Extrait le nom de l'appellation du vin.
|
||||||
|
|
||||||
Returns:
|
Returns:
|
||||||
str: _description_
|
str | None: Le nom (ex: 'Pauillac') ou None.
|
||||||
"""
|
"""
|
||||||
attrs: dict[str, object] | None = self._getattributes()
|
attrs: dict[str, object] | None = self._getattributes()
|
||||||
|
|
||||||
@@ -96,13 +118,16 @@ class _ScraperData:
|
|||||||
return None
|
return None
|
||||||
|
|
||||||
def _getcritiques(self, name: str) -> str | None:
|
def _getcritiques(self, name: str) -> str | None:
|
||||||
"""_summary_
|
"""
|
||||||
|
Méthode générique pour parser les notes des critiques (Parker, Suckling, etc.).
|
||||||
|
|
||||||
|
Gère les notes simples ("95") et les plages de notes ("95-97") en faisant la moyenne.
|
||||||
|
|
||||||
Args:
|
Args:
|
||||||
name (str): _description_
|
name (str): La clé de l'attribut dans le JSON (ex: 'note_rp').
|
||||||
|
|
||||||
Returns:
|
Returns:
|
||||||
str | None: _description_
|
str | None: La note formatée en chaîne de caractères ou None.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
current_value: dict[str, object] | None = self._getattributes()
|
current_value: dict[str, object] | None = self._getattributes()
|
||||||
@@ -114,59 +139,79 @@ class _ScraperData:
|
|||||||
return None
|
return None
|
||||||
|
|
||||||
val = cast(str, app_dict.get("value")).rstrip("+").split("-")
|
val = cast(str, app_dict.get("value")).rstrip("+").split("-")
|
||||||
if len(val) > 1:
|
if len(val) > 1 and val[1] != "":
|
||||||
val[0] = str((int(val[0]) + int(val[1])) / 2)
|
val[0] = str(round((float(val[0]) + float(val[1])) / 2, 1))
|
||||||
|
|
||||||
return val[0]
|
return val[0]
|
||||||
return None
|
return None
|
||||||
|
|
||||||
def parker(self) -> str | None:
|
def parker(self) -> str | None:
|
||||||
|
"""Note Robert Parker."""
|
||||||
return self._getcritiques("note_rp")
|
return self._getcritiques("note_rp")
|
||||||
|
|
||||||
def robinson(self) -> str | None:
|
def robinson(self) -> str | None:
|
||||||
|
"""Note Jancis Robinson."""
|
||||||
return self._getcritiques("note_jr")
|
return self._getcritiques("note_jr")
|
||||||
|
|
||||||
def suckling(self) -> str | None:
|
def suckling(self) -> str | None:
|
||||||
|
"""Note James Suckling."""
|
||||||
return self._getcritiques("note_js")
|
return self._getcritiques("note_js")
|
||||||
|
|
||||||
def getdata(self) -> dict[str, object]:
|
def getdata(self) -> dict[str, object]:
|
||||||
|
"""Retourne le dictionnaire de données complet."""
|
||||||
return self._data
|
return self._data
|
||||||
|
|
||||||
def informations(self) -> str:
|
def informations(self) -> str:
|
||||||
"""
|
"""
|
||||||
Retourne toutes les informations sous la forme :
|
Agrège les données clés pour l'export CSV.
|
||||||
"Appelation,Parker,J.Robinson,J.Suckling,Prix"
|
|
||||||
|
Returns:
|
||||||
|
str: Ligne formatée : "Appellation,Parker,Robinson,Suckling,Prix".
|
||||||
"""
|
"""
|
||||||
|
|
||||||
appellation = self.appellation()
|
appellation = self.appellation()
|
||||||
parker = self.parker()
|
parker = self.parker()
|
||||||
robinson = self.robinson()
|
robinson = self.robinson()
|
||||||
suckling = self.suckling()
|
suckling = self.suckling()
|
||||||
try:
|
|
||||||
prix = self.prix()
|
prix = self.prix()
|
||||||
except ValueError:
|
|
||||||
prix = None
|
|
||||||
|
|
||||||
return f"{appellation},{parker},{robinson},{suckling},{prix}"
|
return f"{appellation},{parker},{robinson},{suckling},{prix}"
|
||||||
|
|
||||||
|
|
||||||
class Scraper:
|
class Scraper:
|
||||||
"""
|
"""
|
||||||
Scraper est une classe qui permet de gerer
|
Client HTTP optimisé pour le scraping de millesima.fr.
|
||||||
de façon dynamique des requetes uniquement
|
|
||||||
sur le serveur https de Millesima
|
Gère la session persistante, les headers de navigation et un cache double
|
||||||
|
pour optimiser les performances et la discrétion.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
def __init__(self) -> None:
|
def __init__(self) -> None:
|
||||||
"""
|
"""
|
||||||
Initialise la session de scraping.
|
Initialise l'infrastructure de navigation:
|
||||||
|
|
||||||
|
- créer une session pour éviter de faire un handshake pour chaque requête
|
||||||
|
- ajout d'un header pour éviter le blocage de l'accès au site
|
||||||
|
- ajout d'un système de cache
|
||||||
"""
|
"""
|
||||||
self._url: str = "https://www.millesima.fr/"
|
self._url: str = "https://www.millesima.fr/"
|
||||||
# Très utile pour éviter de renvoyer toujours les mêmes handshake
|
# Très utile pour éviter de renvoyer toujours les mêmes handshake
|
||||||
# TCP et d'avoir toujours une connexion constante avec le server
|
# TCP et d'avoir toujours une connexion constante avec le server
|
||||||
self._session: Session = Session()
|
self._session: Session = Session()
|
||||||
|
# Crée une "fausse carte d'identité" pour éviter que le site nous
|
||||||
|
# bloque car on serait des robots
|
||||||
|
self._session.headers.update(
|
||||||
|
{
|
||||||
|
"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) \
|
||||||
|
AppleWebKit/537.36 (KHTML, like Gecko) \
|
||||||
|
Chrome/122.0.0.0 Safari/537.36",
|
||||||
|
"Accept-Language": "fr-FR,fr;q=0.9,en;q=0.8",
|
||||||
|
}
|
||||||
|
)
|
||||||
# Système de cache pour éviter de solliciter le serveur inutilement
|
# Système de cache pour éviter de solliciter le serveur inutilement
|
||||||
|
# utilise pour _request
|
||||||
self._latest_request: tuple[(str, Response)] | None = None
|
self._latest_request: tuple[(str, Response)] | None = None
|
||||||
|
# utilise pour getsoup
|
||||||
self._latest_soups: OrderedDict[str, BeautifulSoup] = OrderedDict[
|
self._latest_soups: OrderedDict[str, BeautifulSoup] = OrderedDict[
|
||||||
str, BeautifulSoup
|
str, BeautifulSoup
|
||||||
]()
|
]()
|
||||||
@@ -181,11 +226,12 @@ class Scraper:
|
|||||||
Returns:
|
Returns:
|
||||||
Response: L'objet réponse de la requête.
|
Response: L'objet réponse de la requête.
|
||||||
|
|
||||||
Raise:
|
Raises:
|
||||||
HTTPError: Si le serveur renvoie un code d'erreur (4xx, 5xx).
|
HTTPError: Si le serveur renvoie un code d'erreur (4xx, 5xx).
|
||||||
"""
|
"""
|
||||||
target_url: str = self._url + subdir.lstrip("/")
|
target_url: str = self._url + subdir.lstrip("/")
|
||||||
response: Response = self._session.get(url=target_url, timeout=10)
|
# envoyer une requête GET sur la page si erreur, renvoie un raise
|
||||||
|
response: Response = self._session.get(url=target_url, timeout=30)
|
||||||
response.raise_for_status()
|
response.raise_for_status()
|
||||||
return response
|
return response
|
||||||
|
|
||||||
@@ -201,7 +247,7 @@ class Scraper:
|
|||||||
Returns:
|
Returns:
|
||||||
Response: L'objet réponse (cache ou nouvelle requête).
|
Response: L'objet réponse (cache ou nouvelle requête).
|
||||||
|
|
||||||
Raise:
|
Raises:
|
||||||
HTTPError: Si le serveur renvoie un code d'erreur (4xx, 5xx).
|
HTTPError: Si le serveur renvoie un code d'erreur (4xx, 5xx).
|
||||||
"""
|
"""
|
||||||
|
|
||||||
@@ -231,7 +277,7 @@ class Scraper:
|
|||||||
Returns:
|
Returns:
|
||||||
BeautifulSoup: L'objet parsé pour extraction de données.
|
BeautifulSoup: L'objet parsé pour extraction de données.
|
||||||
|
|
||||||
Raise:
|
Raises:
|
||||||
HTTPError: Si le serveur renvoie un code d'erreur (4xx, 5xx).
|
HTTPError: Si le serveur renvoie un code d'erreur (4xx, 5xx).
|
||||||
"""
|
"""
|
||||||
|
|
||||||
@@ -252,23 +298,20 @@ class Scraper:
|
|||||||
def getjsondata(self, subdir: str, id: str = "__NEXT_DATA__") -> _ScraperData:
|
def getjsondata(self, subdir: str, id: str = "__NEXT_DATA__") -> _ScraperData:
|
||||||
"""
|
"""
|
||||||
Extrait les données JSON contenues dans la balise __NEXT_DATA__ du site.
|
Extrait les données JSON contenues dans la balise __NEXT_DATA__ du site.
|
||||||
Beaucoup de sites modernes (Next.js) stockent leur état initial dans
|
|
||||||
une balise <script> pour l'hydratation côté client.
|
|
||||||
|
|
||||||
Args:
|
Args:
|
||||||
subdir (str): Le chemin de la page.
|
subdir (str): Le chemin de la page.
|
||||||
id (str, optional): L'identifiant de la balise script (par défaut __NEXT_DATA__).
|
id (str, optional): L'identifiant de la balise script.
|
||||||
|
|
||||||
Raises:
|
Raises:
|
||||||
HTTPError: Soulevée par `getresponse` si le serveur renvoie un code d'erreur (4xx, 5xx).
|
HTTPError: Erreur renvoyée par le serveur (4xx, 5xx).
|
||||||
JSONDecodeError: Soulevée par `loads` si le contenu de la balise n'est pas un JSON valide.
|
JSONDecodeError: Si le contenu de la balise n'est pas un JSON valide.
|
||||||
ValueError: Soulevée manuellement si l'une des clés attendues (props, pageProps, etc.)
|
ValueError: Si les clés 'props' ou 'pageProps' sont absentes.
|
||||||
est absente de la structure JSON.
|
|
||||||
|
|
||||||
Returns:
|
Returns:
|
||||||
dict[str, object]: Un dictionnaire contenant les données utiles
|
_ScraperData: Instance contenant les données extraites.
|
||||||
ou un dictionnaire vide en cas d'erreur.
|
|
||||||
"""
|
"""
|
||||||
|
|
||||||
soup: BeautifulSoup = self.getsoup(subdir)
|
soup: BeautifulSoup = self.getsoup(subdir)
|
||||||
script: Tag | None = soup.find("script", id=id)
|
script: Tag | None = soup.find("script", id=id)
|
||||||
|
|
||||||
@@ -285,3 +328,77 @@ class Scraper:
|
|||||||
|
|
||||||
return _ScraperData(cast(dict[str, object], current_data))
|
return _ScraperData(cast(dict[str, object], current_data))
|
||||||
|
|
||||||
|
def _geturlproductslist(self, subdir: str) -> list[str] | None:
|
||||||
|
"""
|
||||||
|
Récupère la liste des produits d'une page de catégorie.
|
||||||
|
"""
|
||||||
|
try:
|
||||||
|
data: dict[str, object] = self.getjsondata(subdir).getdata()
|
||||||
|
|
||||||
|
for element in ["initialReduxState", "categ", "content"]:
|
||||||
|
data: dict[str, object] = cast(dict[str, object], data.get(element))
|
||||||
|
if not isinstance(data, dict):
|
||||||
|
return None
|
||||||
|
|
||||||
|
products: list[str] = cast(list[str], data.get("products"))
|
||||||
|
if isinstance(products, list):
|
||||||
|
return products
|
||||||
|
|
||||||
|
except (JSONDecodeError, HTTPError):
|
||||||
|
return None
|
||||||
|
|
||||||
|
def getvins(self, subdir: str, filename: str, reset: bool) -> None:
|
||||||
|
"""
|
||||||
|
Scrape récursivement toutes les pages d'une catégorie et sauvegarde en CSV.
|
||||||
|
|
||||||
|
Args:
|
||||||
|
subdir (str): La catégorie (ex: '/vins-rouges').
|
||||||
|
filename (str): Nom du fichier de sortie (ex: 'vins.csv').
|
||||||
|
reset (bool): (Optionnel) pour réinitialiser le processus.
|
||||||
|
"""
|
||||||
|
with open(filename, "w") as f:
|
||||||
|
cache: set[str] = set[str]()
|
||||||
|
page = 0
|
||||||
|
_ = f.write("Appellation,Robert,Robinson,Suckling,Prix\n")
|
||||||
|
|
||||||
|
while True:
|
||||||
|
page += 1
|
||||||
|
products_list: list[str] | None = self._geturlproductslist(
|
||||||
|
f"{subdir}?page={page}"
|
||||||
|
)
|
||||||
|
|
||||||
|
if not products_list:
|
||||||
|
break
|
||||||
|
|
||||||
|
products_list_length = len(products_list)
|
||||||
|
for i, product in enumerate(products_list):
|
||||||
|
if not isinstance(product, dict):
|
||||||
|
continue
|
||||||
|
|
||||||
|
link = product.get("seoKeyword")
|
||||||
|
|
||||||
|
if link and link not in cache:
|
||||||
|
try:
|
||||||
|
infos = self.getjsondata(link).informations()
|
||||||
|
_ = f.write(infos + "\n")
|
||||||
|
print(
|
||||||
|
f"page: {page} | {i + 1}/{products_list_length} {link}"
|
||||||
|
)
|
||||||
|
cache.add(link)
|
||||||
|
except (JSONDecodeError, HTTPError) as e:
|
||||||
|
print(f"Erreur sur le produit {link}: {e}")
|
||||||
|
f.flush()
|
||||||
|
|
||||||
|
|
||||||
|
def main() -> None:
|
||||||
|
if len(argv) != 2:
|
||||||
|
raise ValueError(f"{argv[0]} <sous-url>")
|
||||||
|
scraper: Scraper = Scraper()
|
||||||
|
scraper.getvins(argv[1], "donnee.csv", False)
|
||||||
|
|
||||||
|
|
||||||
|
if __name__ == "__main__":
|
||||||
|
try:
|
||||||
|
main()
|
||||||
|
except Exception as e:
|
||||||
|
print(f"ERREUR: {e}")
|
||||||
0
tests/test_main.py
Normal file
0
tests/test_main.py
Normal file
@@ -1,8 +1,8 @@
|
|||||||
from json import dumps
|
from json import dumps
|
||||||
from bs4 import Tag
|
from unittest.mock import patch, mock_open
|
||||||
import pytest
|
import pytest
|
||||||
from requests_mock import Mocker
|
from requests_mock import Mocker
|
||||||
from main import Scraper
|
from scraper import Scraper
|
||||||
|
|
||||||
|
|
||||||
@pytest.fixture(autouse=True)
|
@pytest.fixture(autouse=True)
|
||||||
@@ -71,10 +71,10 @@ def mock_site():
|
|||||||
"_id": "J4131/22/C/CC/6-11652",
|
"_id": "J4131/22/C/CC/6-11652",
|
||||||
"partnumber": "J4131/22/C/CC/6",
|
"partnumber": "J4131/22/C/CC/6",
|
||||||
"taxRate": "H",
|
"taxRate": "H",
|
||||||
"listPrice": 390,
|
"listPrice": 842,
|
||||||
"offerPrice": 390,
|
"offerPrice": 842,
|
||||||
"seoKeyword": "nino-negri-5-stelle-sfursat-2022-c-cc-6.html",
|
"seoKeyword": "vin-de-charazade1867.html",
|
||||||
"shortdesc": "Un carton de 6 Bouteilles (75cl)",
|
"shortdesc": "Une bouteille du meilleur vin du monde?",
|
||||||
"attributes": {
|
"attributes": {
|
||||||
"promotion_o_n": {
|
"promotion_o_n": {
|
||||||
"valueId": "0",
|
"valueId": "0",
|
||||||
@@ -101,9 +101,9 @@ def mock_site():
|
|||||||
"isSpirit": False,
|
"isSpirit": False,
|
||||||
},
|
},
|
||||||
"nbunit": {
|
"nbunit": {
|
||||||
"valueId": "6",
|
"valueId": "1",
|
||||||
"name": "nbunit",
|
"name": "nbunit",
|
||||||
"value": "6",
|
"value": "1",
|
||||||
"isSpirit": False,
|
"isSpirit": False,
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
@@ -120,14 +120,14 @@ def mock_site():
|
|||||||
"appellation": {
|
"appellation": {
|
||||||
"valueId": "433",
|
"valueId": "433",
|
||||||
"name": "Appellation",
|
"name": "Appellation",
|
||||||
"value": "Sforzato di Valtellina",
|
"value": "Madame-Loïk",
|
||||||
"url": "sforzato-di-valtellina.html",
|
"url": "Madame-loik.html",
|
||||||
"isSpirit": False,
|
"isSpirit": False,
|
||||||
"groupIdentifier": "appellation_433",
|
"groupIdentifier": "appellation_433",
|
||||||
},
|
},
|
||||||
"note_rp": {
|
"note_rp": {
|
||||||
"valueId": "91",
|
"valueId": "91",
|
||||||
"name": "Parker",
|
"name": "Peter Parker",
|
||||||
"value": "91",
|
"value": "91",
|
||||||
"isSpirit": False,
|
"isSpirit": False,
|
||||||
},
|
},
|
||||||
@@ -138,8 +138,8 @@ def mock_site():
|
|||||||
"isSpirit": False,
|
"isSpirit": False,
|
||||||
},
|
},
|
||||||
"note_js": {
|
"note_js": {
|
||||||
"valueId": "93-94",
|
"valueId": "93-94.5",
|
||||||
"name": "J. Suckling",
|
"name": "J. cherazade",
|
||||||
"value": "93-94",
|
"value": "93-94",
|
||||||
"isSpirit": False,
|
"isSpirit": False,
|
||||||
},
|
},
|
||||||
@@ -166,6 +166,79 @@ def mock_site():
|
|||||||
text=html_product,
|
text=html_product,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
html_product = f"""
|
||||||
|
<html>
|
||||||
|
<body>
|
||||||
|
<h1>MILLESIMA</h1>
|
||||||
|
<script id="__NEXT_DATA__" type="application/json">
|
||||||
|
{dumps(json_data)}
|
||||||
|
</script>
|
||||||
|
</body>
|
||||||
|
</html>
|
||||||
|
"""
|
||||||
|
|
||||||
|
list_pleine = f"""
|
||||||
|
<html>
|
||||||
|
<body>
|
||||||
|
<h1>LE WINE</h1>
|
||||||
|
<script id="__NEXT_DATA__" type="application/json">
|
||||||
|
{dumps({
|
||||||
|
"props": {
|
||||||
|
"pageProps": {
|
||||||
|
"initialReduxState": {
|
||||||
|
"categ": {
|
||||||
|
"content": {
|
||||||
|
"products": [
|
||||||
|
{"seoKeyword": "/nino-negri-5-stelle-sfursat-2022.html",},
|
||||||
|
{"seoKeyword": "/poubelle",},
|
||||||
|
{"seoKeyword": "/",}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
)}
|
||||||
|
</script>
|
||||||
|
</body>
|
||||||
|
</html>
|
||||||
|
"""
|
||||||
|
|
||||||
|
list_vide = f"""
|
||||||
|
<html>
|
||||||
|
<body>
|
||||||
|
<h1>LE WINE</h1>
|
||||||
|
<script id="__NEXT_DATA__" type="application/json">
|
||||||
|
{dumps({
|
||||||
|
"props": {
|
||||||
|
"pageProps": {
|
||||||
|
"initialReduxState": {
|
||||||
|
"categ": {
|
||||||
|
"content": {
|
||||||
|
"products": [
|
||||||
|
]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
)}
|
||||||
|
</script>
|
||||||
|
</body>
|
||||||
|
</html>
|
||||||
|
"""
|
||||||
|
|
||||||
|
m.get(
|
||||||
|
"https://www.millesima.fr/wine.html",
|
||||||
|
complete_qs=False,
|
||||||
|
response_list=[
|
||||||
|
{"text": list_pleine},
|
||||||
|
{"text": list_vide},
|
||||||
|
],
|
||||||
|
)
|
||||||
|
|
||||||
# on return m sans fermer le server qui simule la page
|
# on return m sans fermer le server qui simule la page
|
||||||
yield m
|
yield m
|
||||||
|
|
||||||
@@ -190,7 +263,7 @@ def test_appellation(scraper: Scraper):
|
|||||||
contenu = scraper.getjsondata("nino-negri-5-stelle-sfursat-2022.html")
|
contenu = scraper.getjsondata("nino-negri-5-stelle-sfursat-2022.html")
|
||||||
assert vide.appellation() is None
|
assert vide.appellation() is None
|
||||||
assert poubelle.appellation() is None
|
assert poubelle.appellation() is None
|
||||||
assert contenu.appellation() == "Sforzato di Valtellina"
|
assert contenu.appellation() == "Madame-Loïk"
|
||||||
|
|
||||||
|
|
||||||
def test_fonctionprivee(scraper: Scraper):
|
def test_fonctionprivee(scraper: Scraper):
|
||||||
@@ -207,7 +280,6 @@ def test_fonctionprivee(scraper: Scraper):
|
|||||||
assert contenu._getattributes() is not None
|
assert contenu._getattributes() is not None
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
def test_critiques(scraper: Scraper):
|
def test_critiques(scraper: Scraper):
|
||||||
vide = scraper.getjsondata("")
|
vide = scraper.getjsondata("")
|
||||||
poubelle = scraper.getjsondata("poubelle")
|
poubelle = scraper.getjsondata("poubelle")
|
||||||
@@ -232,13 +304,23 @@ def test_prix(scraper: Scraper):
|
|||||||
contenu = scraper.getjsondata("nino-negri-5-stelle-sfursat-2022.html")
|
contenu = scraper.getjsondata("nino-negri-5-stelle-sfursat-2022.html")
|
||||||
assert vide.prix() is None
|
assert vide.prix() is None
|
||||||
assert poubelle.prix() is None
|
assert poubelle.prix() is None
|
||||||
assert contenu.prix() == 65.0
|
assert contenu.prix() == 842.0
|
||||||
|
|
||||||
|
|
||||||
def test_informations(scraper: Scraper):
|
def test_informations(scraper: Scraper):
|
||||||
contenu = scraper.getjsondata("nino-negri-5-stelle-sfursat-2022.html")
|
contenu = scraper.getjsondata("nino-negri-5-stelle-sfursat-2022.html")
|
||||||
assert contenu.informations() == "Sforzato di Valtellina,91,17,93.5,65.0"
|
assert contenu.informations() == "Madame-Loïk,91,17,93.5,842.0"
|
||||||
vide = scraper.getjsondata("")
|
vide = scraper.getjsondata("")
|
||||||
poubelle = scraper.getjsondata("poubelle")
|
poubelle = scraper.getjsondata("poubelle")
|
||||||
assert vide.informations() == "None,None,None,None,None"
|
assert vide.informations() == "None,None,None,None,None"
|
||||||
assert poubelle.informations() == "None,None,None,None,None"
|
assert poubelle.informations() == "None,None,None,None,None"
|
||||||
|
|
||||||
|
|
||||||
|
def test_search(scraper: Scraper):
|
||||||
|
m = mock_open()
|
||||||
|
with patch("builtins.open", m):
|
||||||
|
scraper.getvins("wine.html", "fake_file.csv", False)
|
||||||
|
|
||||||
|
assert m().write.called
|
||||||
|
all_writes = "".join(call.args[0] for call in m().write.call_args_list)
|
||||||
|
assert "Madame-Loïk,91,17,93.5,842.0" in all_writes
|
||||||
Reference in New Issue
Block a user