Discussion :

[débutant09]

Bonjour,

Sur python, je fais plusieurs requêtes sur cassandra, avec une boucle mais au bout d'un moment ça bloque et cette erreur apparaît :

Fichier "C:\Python34\lib\site-packages\cassandra\cluster.py", ligne 3533, dans _reconnect_internal
raise NoHostAvailable("Impossible de se connecter à un serveur", erreurs)
cassandra.cluster.NoHostAvailable : ("Impossible de se connecter à des serveurs", {'XXXX' : OperationTimedOut('errors=Expiration du délai de création de la connexion
n (5 secondes), last_host=Aucun',), 'XXXX' : OperationTimedOut('errors=Expiration du délai de création de la connexion (5 secondes), last_host=Aucun',), 'XXXX': OperationTimedOut('errors=Expiration du délai de création de la connexion (5 secondes), last_host=None',)}, 's'est produit à l'index 0')

Pourriez-vous m'aider à résoudre ce problème ?

Je vous remercie par avance infiniment

[fred1599]

Bonjour,

Apparemment ce n'est pas un bug sur le code car vous dîtes,

je fais plusieurs requêtes sur cassandra, avec une boucle mais au bout d'un moment ça bloque

Ce qui veut dire que ça fonctionne un moment aussi...

Mais vous dîtes ceci qui est contradictoire,

NoHostAvailable("Impossible de se connecter à un serveur", erreurs)

Est-ce que dans votre boucle, vous vous connectiez au serveur à chaque fois (à mon sens, ce n'est pas une bonne idée) ?

---------------

Pour commencer, augmentez le timeout dans les paramètres du driver Cassandra afin de donner plus de temps aux requêtes pour obtenir une réponse.
Si possible, réduisez la fréquence ou le volume des requêtes pour éviter de surcharger le cluster.

[débutant09]

Bonjour,

Oui effectivement c'est bien ça, cela marche pour les 50 premières itérations et ensuite cette erreur apparaît.
Aussi, Lorsque que je ne fais pas de boucle et que j'exécute individuellement chaque élément de la liste, cela marche très bien.
Dans mon driver cluster.py j'ai déjà augmenté les timeout suivants mais rien n'y fait, j'ai toujours ce problème.

Voilà les timeout que j'ai augmenté :
connect_timeout = 30 (qui était égal à 5 secondes de base)
"""
Timeout, in seconds, for creating new connections.

This timeout covers the entire connection negotiation, including TCP
establishment, options passing, and authentication.
"""

control_connection_timeout = float(36000) (qui était égal à 2 secondes)

"""
A timeout, in seconds, for queries made by the control connection, such
as querying the current schema and information about nodes in the cluster.
If set to :const:`None`, there will be no timeout for these queries.
"""

request_timeout = 30.0 (qui était de 10 secondes)
"""
Request timeout used when not overridden in :meth:`.Session.execute`
"""

J'effectue 3 requêtes sur cassandra à chaque boucle :
def concatenation_liste_valeurs_OP(site_id):
is_qal = False
SESSION = TPC.getSession(is_qal)

df_js_data1 = SESSION.prepare("SELECT * FROM click.table2 WHERE type = 'base' and key = 'cf_list' and id1 = '{}';".format(site_id))
js_data1 = SESSION.execute(df_js_data1)
df_results1 = pd.DataFrame(list(js_data1))


df_js_data2 = SESSION.prepare("SELECT * FROM click.conditionnal_zp where site_id = '{}' and type = 'list' and code = 'OP24';".format(site_id))
js_data2 = SESSION.execute(df_js_data2)
df_results2 = pd.DataFrame(list(js_data2))


df_js_data3 = SESSION.prepare("select * from click.conditionnal_zp where site_id = 'XXXX' and type='list' and code = 'XXXX' and source_id = 'XXXX'")
js_data3 = SESSION.execute(df_js_data3)
df_results3 = pd.DataFrame(list(js_data3))

Je comprends pas ce que je dois faire de plus pour que cette erreur n'apparaisse plus. Si vous avez d'autres idées ce serait super sympa de me les partager

[fred1599]

Oui effectivement c'est bien ça, cela marche pour les 50 premières itérations et ensuite cette erreur apparaît.

Il y aurait donc une limitation... Peut-être lié au nombre de sessions créés ?

La création d'une nouvelle session pour chaque itération de la boucle peut épuiser les ressources disponibles, en particulier si les sessions ne sont pas correctement fermées.
Il est recommandé de réutiliser la même session Cassandra pour toutes les requêtes, ou de s'assurer que les sessions sont fermées proprement après chaque utilisation.

[débutant09]

Oui vous avez peut-être raison je vais essayer de fermer la session après chaque utilisation mais il reste à trouver comment fermer la session.
J'ai essayé de chercher dans le driver j'ai une piste :

Example usage::

>>> from cassandra.cluster import Cluster
>>> cluster = Cluster(['192.168.1.1', '192.168.1.2'])
>>> session = cluster.connect()
>>> session.execute("CREATE KEYSPACE ...")
>>> ...
>>> cluster.shutdown()

Je vais essayer de cette façon :
def concatenation_liste_valeurs_OP(site_id):
is_qal = False
SESSION = TPC.getSession(is_qal)

df_js_data1 = SESSION.prepare("SELECT * FROM click.table2 WHERE type = 'base' and key = 'cf_list' and id1 = '{}';".format(site_id))
js_data1 = SESSION.execute(df_js_data1)
SESSION.shutdown()
df_results1 = pd.DataFrame(list(js_data1))


df_js_data2 = SESSION.prepare("SELECT * FROM click.conditionnal_zp where site_id = '{}' and type = 'list' and code = 'OP24';".format(site_id))
js_data2 = SESSION.execute(df_js_data2)
SESSION.shutdown()
df_results2 = pd.DataFrame(list(js_data2))


df_js_data3 = SESSION.prepare("select * from click.conditionnal_zp where site_id = 'XXXX' and type='list' and code = 'XXXX' and source_id = ''XXXX")
js_data3 = SESSION.execute(df_js_data3)
SESSION.shutdown()
df_results3 = pd.DataFrame(list(js_data3))

[fred1599]

La fermeture de la session se fait en appelant la méthode shutdown sur l'objet de la session

[débutant09]

J'ai fermé la session avec un SESSION.shutdown() après utilisation, ma boucle a tourné plus longtemps et a fait beaucoup plus d'itérations cependant au niveau des derniers éléments de la liste, je retrouve l'erreur que j'ai mentionné précédemment ('Unable to connect to any servers', {'XXXX': OperationTimedOut('errors=Timed out creating connection (10 seconds), last_host=None',), 'XXXX': OperationTimedOut('errors=Timed out creating connection (10 seconds), last_host=None',), 'XXXX': OperationTimedOut('errors=Timed out creating connection (10 seconds), last_host=None',)}). J'ai l'impression que j'ai un peu moins surchargé le cluster mais qu'à la fin il finit par se surcharger de toute façon. Je commence à voir le bout du tunnel mais je ne l'ai pas encore atteint .
Donc si vous avez encore d'autres suggestions pour améliorer ma connexion à cassandra, je suis preneuse !
Je vous remercie déjà pour les réponses pertinentes précédentes.

def concatenation_liste_valeurs_OP(site_id):
is_qal = False
SESSION = TPC.getSession(is_qal)

df_js_data1 = SESSION.prepare("SELECT * FROM click.table2 WHERE type = 'base' and key = 'cf_list' and id1 = '{}';".format(site_id))
js_data1 = SESSION.execute(df_js_data1)
df_results1 = pd.DataFrame(list(js_data1))

df_js_data2 = SESSION.prepare("SELECT * FROM click.conditionnal_zp where site_id = '{}' and type = 'list' and code = 'OP24';".format(site_id))
js_data2 = SESSION.execute(df_js_data2)
df_results2 = pd.DataFrame(list(js_data2))

df_js_data3 = SESSION.prepare("select * from click.conditionnal_zp where site_id = 'XXXX' and type='list' and code = 'XXXX' and source_id = 'C_AGR02'")
js_data3 = SESSION.execute(df_js_data3)
df_results3 = pd.DataFrame(list(js_data3))

SESSION.shutdown()

[fred1599]

J'ai l'impression que dans chaque boucle vous ouvrez et fermez une session, si c'est le cas, retirez de la boucle l'ouverture de la session ainsi que la fermeture

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
Ouverture de la session
 
boucle
    ...
    ...
 
Fermeture de la session

Ensuite concentrez vous sur le temps pour effectuer toutes ces requêtes, le Timed out doit être adapté pour éviter d'interrompre le travail.

[débutant09]

Après avoir mis l'ouverture de ma session avant ma boucle et la fermeture de ma session après ma boucle, je n'ai pas rencontré d'erreur. Vous avez trouvé d'où venez mon problème. Je vous remercie infiniment, vous êtes très fort

[fred1599]

Bonjour,

Ce n'est que mon expérience et le fait de s'appuyer sur vos messages d'erreur... dans votre cas, en faisant une recherche sur internet vous pouvez comprendre ce que cela veut dire, mais pas forcément quoi faire. À vous d'avoir du bon sens en vérifiant ce que vous avez fait et pourquoi ces messages d'erreur apparaissent.

Tout le travail n'est que interprétation