Skip to contents

Capture Tweets from a Search as They Are Published (experimental)

Source: R/getTweetsLiveAPI.R
getTweetsLiveAPI.Rd

[Experimental]

Sigue una busqueda "hacia adelante": repite getTweetsSearchAPI() (pestania "Latest") cada interval segundos durante duration segundos y acumula solo los tweets nuevos. Desde la segunda ronda la consulta lleva el operador since_id: con el ID mas reciente ya recolectado, asi que X devuelve solo lo publicado despues y no se vuelve a gastar cupo en lo ya traido.

No es un streaming real: la granularidad es interval. Si en una ronda aparecen n_tweets o mas tweets nuevos, los que exceden el tope quedan sin recolectar (se avisa con un mensaje); en ese caso conviene bajar interval o subir n_tweets. Un error en una ronda se informa y la captura sigue con la proxima. Interrumpir con Esc / Ctrl+C termina la captura y devuelve lo acumulado hasta ese momento.

Guardado y reanudacion: con save = TRUE o db, cada ronda se guarda en una base SQLite apenas llega. Para continuar una captura cortada, llama de nuevo con el mismo search y db = "<ruta>.sqlite": la primera ronda pide lo posterior al tweet mas reciente guardado y duration cuenta desde la nueva llamada.

Usage

getTweetsLiveAPI(
  search = "#RStats",
  interval = 300,
  duration = 3600,
  n_tweets = 100,
  max_tweets = Inf,
  db = NULL,
  dir = getwd(),
  save = FALSE
)

Arguments

Consulta de busqueda (soporta operadores de X, p.ej. "lang:es", "-filter:retweets"). Por defecto "#RStats".

interval

Segundos entre rondas. Minimo 60. Por defecto 300.

duration

Segundos totales de captura. Por defecto 3600 (una hora).

n_tweets

Tope de tweets por ronda. La primera ronda trae hasta n_tweets de los mas recientes como punto de partida. Por defecto 100.

max_tweets

La captura termina cuando la base llega a este total de tweets. Por defecto Inf (solo limita duration).

db

Ruta a una base .sqlite. Si no existe se crea; si existe, se continua la captura guardada en ella. Por defecto NULL.

dir

Directorio donde se crea la base cuando save = TRUE y no se pasa db. Por defecto el de trabajo.

save

Logico. Si TRUE y no se pasa db, crea una base nueva api_live_<consulta>_<fecha>.sqlite en dir. Por defecto FALSE: se usa una base temporal que se borra al terminar.

Value

Un tibble con un tweet por fila, del mas nuevo al mas viejo (mismas columnas que getTweetsSearchAPI()). Al continuar una captura incluye lo guardado antes.

Examples

if (FALSE) { # \dontrun{
importSessionX(auth_token = "...", ct0 = "...")
# Una hora de captura, una ronda cada 5 minutos, guardando en cada ronda
vivo <- getTweetsLiveAPI("#RStats", interval = 300, duration = 3600, save = TRUE)
} # }