[JAVA] Are you still exhausted by the sample video search? A button to send FANZA videos to Slack when pressed.
Overview
- When you press the AWS IoT Enterprise button, you get the URL of the sample video from FANZA's API and send it to Slack at random, so make a note of the technical details as a memorandum.
Purpose
- I bought AWS IoT at Nori, so try using it.
- I want to reduce the time to search sample videos several times a week.
- I wanted to develop AWS Lambda locally.
- I wanted to write Kotlin.
Target
- ʻFor those who want to use AWS Lambda`
- People who want to develop AWS Lambda while
debuging locally - People who want to send a message from the program to
Slack - ʻFor those who want to use the AWS IoT` button
- People who want to write ʻAWS Lambda
inJava` - People who want to write ʻAWS Lambda
inKotlin` - People who are exhausted by searching sample videos
Such.
Premise (environment, etc.)
- macOS :
macOS Mojave 10.14.5 - ʻYou have purchased the AWS IoT Enterprise Button`.
IntelliJ IDEAultimateDockerinstalled (required for local development)- FANZA API can be hit (DMM affiliate ID acquisition → FANZA API ID acquisition)
Source code
https://github.com/yu-suke-dev/fanza-bot
Creating a project
Plugin installation
- Install the plugin ʻAWS ToolKit`.
Start the project
- Select ʻAWS Setverless Application` to start the project.
The project hierarchy looks like this:
[sample]
├── HelloWorldFunction
│ ├── build.gradle
│ ├── gradle
│ │ └── wrapper
│ │ ├── gradle-wrapper.jar
│ │ └── gradle-wrapper.properties
│ ├── gradlew
│ ├── gradlew.bat
│ └── src
│ ├── main
│ │ └── java
│ │ └── helloworld
│ │ ├── App.java
│ │ └── GatewayResponse.java
│ └── test
│ └── java
│ └── helloworld
│ └── AppTest.java
├── README.md
├── sample.iml
└── template.yaml
Replace with Kotlin.
- build.gradle
build.gradle
plugins {
id 'org.jetbrains.kotlin.jvm' version '1.3.40'
}
apply plugin: 'kotlin'
repositories {
mavenCentral()
}
sourceCompatibility = '1.8'
targetCompatibility = '1.8'
jar {
manifest {
attributes('Main-Class': 'fanza.App')
}
from { configurations.compile.collect { it.isDirectory() ? it : zipTree(it) } }
}
dependencies {
compile "com.amazonaws:aws-lambda-java-core:1.2.0"
compile "org.jetbrains.kotlin:kotlin-stdlib-jdk8:1.3.40"
compile "com.squareup.okhttp3:okhttp:3.9.0"
compile "org.json:json:20180813"
testCompile "junit:junit:4.12"
}
- src Do the following:
[src]
├── main
│ └── kotlin
│ └── fanza
│ └── App.java
└── test
│ └── java
│ └── fanza
│ └── AppTest.java
- App.kt
App.kt
package fanza
import com.amazonaws.services.lambda.runtime.Context
import com.amazonaws.services.lambda.runtime.RequestHandler
import okhttp3.MediaType
import okhttp3.OkHttpClient
import okhttp3.Request
import okhttp3.RequestBody
import org.json.JSONObject
import java.io.IOException
/**
* Handler for requests to Lambda function.
*/
class App : RequestHandler<Any, Any> {
/**
* called method
*/
override fun handleRequest(input: Any, context: Context): Any {
try {
//ID required for fanza API
var fanzaApiId = System.getenv("FANZA_API_ID")
var affiliateId = System.getenv("FANZA_AFFILIATE_ID")
//Create the URL you want to search
val fanzaUrl: String = "https://api.dmm.com/affiliate/v3/ItemList"
.plus("?api_id=$fanzaApiId")
.plus("&affiliate_id=$affiliateId")
.plus("&site=FANZA&service=digital&floor=videoa")
.plus("&hits=20&sort=date&keyword=amateur&output=json")
//GET to FANZA
val fanzaInfo = get(fanzaUrl).replace("\\", "")
//Regular expression of the part you want to extract
val regex = Regex("https://www.dmm.co.jp/litevideo/-/part/=/cid=[a-z]{3,5}[0-9]{3,5}/size=720_480/")
//Randomly extract one from the extracted results
val result: String = regex.findAll(fanzaInfo)
.map { it.value }
.toList()
.random()
//Slack webhook URL
var slackUrl: String = System.getenv("SLACK_URL")
//What to send to Slack
var slackJson = JSONObject()
slackJson.put("channel", "#fanza")
slackJson.put("username", "fanza-bot")
slackJson.put("text", result)
slackJson.put("icon_emoji", ":womens:")
//post send
post(slackUrl, slackJson.toString())
return "Success"
} catch (e: IOException) {
return RuntimeException(e)
}
}
/**
* get
*/
@Throws(IOException::class)
operator fun get(url: String): String {
val request = Request.Builder()
.url(url)
.header("Content-Type", "application/json")
.addHeader("X-Custom-Header", "application/json")
.build()
val client = OkHttpClient.Builder().build()
val response = client.newCall(request).execute()
return response.body()!!.string()
}
/**
* post
*/
@Throws(IOException::class)
fun post(url: String, json: String): String {
val body = RequestBody
.create(MediaType.parse("application/json; charset=utf-8"), json)
val request = Request.Builder()
.url(url)
.put(body)
.build()
val client = OkHttpClient()
return client.newCall(request).execute().body()!!.string()
}
}
Setting environment variables
Operation check
Execution result
- If Slack receives a successful notification and the console displays the following, it is successful.
Jar file creation
- When you're done, create a Jar file.
gradle jar
Upload to Lambda
- Environment variable: Set the same as the one set locally.
- Upload the Jar file created above.
Linking AWS IoT Buttons with AWS Lambda
-
Register the product: Omitted. Register the product by referring to the following articles. https://qiita.com/shogo_m/items/9aa7b400a031e8503e7f
-
Create Project: Select ʻIoT 1-Click` from the AWS console screen
-
Specifying the project name
-
Specify the created Lambda function here.
Execution result
Press the * button. (Pochi)
- Check the execution result in Slack.
Summary
- This time, I tried only the operation when 1-click.
- Getting the Slack Webhook URL is omitted.
- For Java, try replacing it with Java.
- This time I set the environment variable in Lambda, but it is more secure to set it in AWS KMS.
- The test code, logs, and so on are poor, so I'd like to refactor it if I have time.
Referenced article (Thank you)
- https://qiita.com/naokiur/items/548fc01240c2488de15c
- https://qiita.com/shogo_m/items/9aa7b400a031e8503e7f
Recommended Posts