Skip to content

appender for AWS kinesis streams #79

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wesnest wants to merge 26 commits into
base: master
Choose a base branch
from
Open

appender for AWS kinesis streams #79

Changes from 1 commit
Commits
Show all changes
26 commits
Select commit Hold shift + click to select a range
277e5dd
appender for AWS kinesis streams
wesnest Jul 19, 2018
9ada6a3
added the required name space for the AWR.Kinesis
wesnest Jul 20, 2018
d046d47
added suggestion for AWR.Kinesis
wesnest Jul 20, 2018
eb4f4d0
commented out line 187
wesnest Jul 20, 2018
38e0925
fixed error
wesnest Jul 20, 2018
725a576
added a bracket to fix build error
wesnest Jul 20, 2018
3d3df51
added process id to the json layout
wesnest Jul 20, 2018
208538d
changed func to calling_function
wesnest Jul 20, 2018
f516047
added the.pid <- Sys.getpid() to layout.json
wesnest Jul 20, 2018
ba995f2
added namespace and id to json layout
wesnest Aug 6, 2018
cd2e7bb
removed namespace
wesnest Aug 6, 2018
ce92e4f
added the user_id and session_id
wesnest Aug 6, 2018
ba8793b
added some commas
wesnest Aug 6, 2018
754841d
made some fixes
wesnest Aug 6, 2018
8be46b8
added kinesis keys
wesnest Aug 7, 2018
4d06e3a
made some fixes
wesnest Aug 7, 2018
13afc2a
made some changes
wesnest Aug 7, 2018
1d5e66b
datapocket
wesnest Aug 7, 2018
f369048
made some changes to the appender
wesnest Aug 7, 2018
592c2ce
updated appender
wesnest Aug 7, 2018
ab857fc
made some changes
wesnest Aug 7, 2018
0967784
some changes
wesnest Aug 7, 2018
000b7d7
added the simple layout back
wesnest Aug 7, 2018
c9112de
calling function code
wesnest Aug 7, 2018
023eb34
added some NULLS
wesnest Aug 8, 2018
01b9678
changed null to NA
wesnest Aug 8, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 12 additions & 0 deletions R/appender.R
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -184,3 +184,15 @@ appender.graylog <- function(server, port, debug = FALSE) {
if (debug) print(ret)
}
}

appender.kinesis_handler <- function(stream,region_name,partition_key)
{

function(line) {
library(AWR.Kinesis)
Copy link
Contributor

@daroczig daroczig Jul 20, 2018

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

requireNamespace might be more appropriate here? And maybe adding to Suggests in the DESCRIPTION file.

AWR.Kinesis::kinesis_put_record(stream,region = region_name,line,partition_key)


}
}