1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
|
% Generated by roxygen2: do not edit by hand
% Please edit documentation in R/rt_stream.R
\name{stream}
\alias{stream}
\alias{filtered_stream}
\alias{stream_add_rule}
\alias{stream_rm_rule}
\alias{sample_stream}
\title{Streaming}
\usage{
filtered_stream(
timeout,
file = tempfile(),
expansions = NA,
fields = NA,
...,
token = NULL,
append = TRUE,
parse = TRUE
)
stream_add_rule(query, dry = FALSE, token = NULL)
stream_rm_rule(query, dry = FALSE, token = NULL)
sample_stream(
timeout,
file = tempfile(),
expansions = NA,
fields = NA,
...,
token = NULL,
parse = TRUE,
append = TRUE
)
}
\arguments{
\item{timeout}{time, in seconds, of the recording stream.}
\item{file}{Path to a file where the raw streaming should be stored.}
\item{expansions}{Expansions you want to use see \code{\link[=tweet_expansions]{tweet_expansions()}}.
Use NULL to get all expansions, use NA to not use any field, or a vector
with the fields you want.}
\item{fields}{Fields you want to retrieve see \link{Fields}. Use NULL to get all
allowed fields, use NA to not use any field, pass a list with the fields you want.}
\item{...}{Other parameters passed to the body of the request.}
\item{token}{Expert use only. Use this to override authentication for
a single API call. In most cases you are better off changing the
default for all calls. See \code{\link[=auth_as]{auth_as()}} for details.}
\item{append}{Append streaming to the file? Default does but it is
recommended to have a new file for each call.}
\item{parse}{If \code{TRUE}, the default, returns a tidy data frame. Use \code{FALSE}
to return the "raw" list corresponding to the JSON returned from the
Twitter API.}
\item{query}{If \code{NULL} returns the current rules, else depending:
\itemize{
\item In stream_add_rule it should be a list of value and tag.
\item In stream_rm_rule it should be a vector of ids of rules to be removed
}}
\item{dry}{Check if the addition or removal of the rule works.}
}
\value{
The records in the streaming.
}
\description{
Open a streaming connection with Twitter and stores tweets for as long as you
wish.
}
\details{
The connection can be left open as long as you wish, the data is appended to
the file provided. Be aware that the stream might have incomplete records
(you won't be able to read directly from the json file).
One tweet might belong to multiple rules.
}
\section{Functions}{
\itemize{
\item \code{filtered_stream()}: Start a filtered stream according to the rules.
\item \code{stream_add_rule()}: Add rules for the filtered streaming.
\item \code{stream_rm_rule()}: Remove rules from the filtered streaming
\item \code{sample_stream()}: Retrieve a sample of the tweets posted.
}}
\examples{
# Requires a bearer token
if (FALSE) {
# How many rules do we have
stream_add_rule(NULL)
# Add new rule
new_rule <- stream_add_rule(list(value = "#rstats", tag = "rstats"))
new_rule
# Open filtered streaming connection for 30s
filtered_stream(file = tempfile(), timeout = 30)
# Remove rule
stream_rm_rule(ids(new_rule))
# Open random streaming connection
sample_stream(file = tempfile(), timeout = 3)
}
}
\seealso{
Rules for filtered stream: \url{https://developer.twitter.com/en/docs/twitter-api/tweets/filtered-stream/integrate/build-a-rule}
Sampled stream: \url{https://developer.twitter.com/en/docs/twitter-api/tweets/volume-streams/api-reference/get-tweets-sample-stream}
Filtered stream: \url{https://developer.twitter.com/en/docs/twitter-api/tweets/filtered-stream/api-reference/get-tweets-search-stream}
\link{ids}
}
|
