使用 if 语句将数据加载到 postgres 时出错

Question

我正在尝试使用 python 将本地报纸的一系列推文保存在 postgres 数据库中。当我尝试手动加载数据时，我的 SQL 查询在 PgAdmin 中运行良好。当我尝试使用 Python 自动化该过程时，我的问题就出现了。任何人都可以查看我的代码，我尝试了我能想到的一切。

def obtiene_tweets(usuario, auth = auth_titter(), cantidad = 100):

fuente = obtiene_id(usuario)


##Conección a twitter

##API
api = tweepy.API(auth)

## Aertura de conección a base
conn = psycopg2.connect(dbname = config.DB_NAME, 
                            user = config.DB_USER,
                            password = config.DB_PASSWORD,
                            host = config.DB_HOST)
##Tweets 
### Este loop accede a los tweets del usuario y obtiene la información de interés para que despúes
### Se la pongamos a la base de datos
cur = conn.cursor()
for tweet in tweepy.Cursor(api.user_timeline, screen_name = fuente.loc['usuario',].values[0], tweet_mode= 'extended').items(cantidad):
    #print(json.dumps(tweet._json, indent=2))
    
    full_text = tweet._json['full_text']
    id = fuente.loc['id',].values[0]
    fecha = tweet._json['created_at']
    try: 
        hashtags = str(tweet._json['entities']['hashtags']).replace('[','')
        hashtags = hashtags.replace(']','')
        if hashtags == '':
            hashtags = 'Null'
    except:
        pass
    try:
     url = tweet._json['entities']['urls'][0]['expanded_url']
    except:
        url = 'Null'
    try:
     likes = tweet._json['favorite_count']
     rts = tweet._json['retweet_count']
    except:
        pass
    cur.execute(sql_statements.CARGA_TWEETS, (full_text.replace("'",'"'),id,full_text.replace("'",'"'), fecha, hashtags, url, likes, rts))
    

cur.close()
conn.close()
    
    

这里是sql查询：

CARGA_TWEETS = """
                DO $$
                BEGIN
                IF EXISTS(SELECT tweet FROM tweets WHERE tweet = %s ) THEN

                raise notice 'Se encuentra el tweet';

                ELSE
                insert into tweets(id_usuario, tweet, fecha, hashtags, urls, likes, rts)
                values(%s, %s, %s, %s, %s, %s, %s );
                

                END IF;

                END $$





            """

我的错误如下所示：

(resumen_noticias) mariano@mariano-HP-Laptop-15-da2xxx:/media/mariano/Nuevo vol/CarpetaProtegida/Provincia/Propuestas/Proyectos/resumen-noticias (main)$ /home/mariano/anaconda3/envs/resumen_noticias/bin/python "/media/mariano/Nuevo vol/CarpetaProtegida/Provincia/Propuestas/Proyectos/resumen-noticias/funciomes.py"
Traceback (most recent call last):
  File "/media/mariano/Nuevo vol/CarpetaProtegida/Provincia/Propuestas/Proyectos/resumen-noticias/funciomes.py", line 121, in <module>
    obtiene_tweets('clarineconomico')
  File "/media/mariano/Nuevo vol/CarpetaProtegida/Provincia/Propuestas/Proyectos/resumen-noticias/funciomes.py", line 111, in obtiene_tweets
    cur.execute(sql_statements.CARGA_TWEETS, (full_text.replace("'",''),id,full_text.replace("'",''), fecha, hashtags, url, likes, rts))
psycopg2.errors.StringDataRightTruncation: value too long for type character varying(200)
CONTEXT:  SQL statement "insert into tweets(id_usuario, tweet, fecha, hashtags, urls, likes, rts)
                    values(9, 'José Mujica: Me he puesto viejo sintiendo de crisis en Argentina y sin embargo, no sé cómo, pero siempre salen adelante url', 'Fri Aug 27 13:26:22 +0000 2021', 'Null', 'extended_url', 7, 1 )"
PL/pgSQL function inline_code_block line 8 at SQL statement

感谢所有花时间回答的人。

Answer 1

请分享tweet 表定义。
看起来你的字段太长了。

value too long for type character varying(200)
您有 2 个选项：（或在选项之间）

1. 截断字段
2. 更改表定义